lib

package

v0.0.3 Latest Latest Go to latest Published: Aug 21, 2024 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

func DeleteGroupRight(kind, resource, group string) error

func DeleteUserRight(kind, resource, user string) error

func GetBroker(bootstrapUrl string) (brokers []string, err error)

func GetKafkaWriter(broker []string, topic string, debug bool) (writer *kafka.Writer, err error)

func HandleDefaultValues(config ConfigType)

func HandleEnvironmentVars(config ConfigType)

preparations for docker

func HasAdminRight(impersonate string, kind string, id string) error

func InitEventConn()

func InitTopic(bootstrapUrl string, topics ...string) (err error)

func LoadConfig(location string) error

func SetGroupRight(kind, resource, group, right string) error

func SetUserRight(kind, resource, user, right string) error

func StartApi()

func StopEventConn()

type ConfigStruct struct {
	ServerPort string
	LogLevel   string

	PermissionsViewUrl string
	KafkaUrl           string

	PermTopic string
}

type ConfigType *ConfigStruct

var Config ConfigType

type PermCommandMsg struct {
	Command  string `json:"command"`
	Kind     string
	Resource string
	User     string
	Group    string
	Right    string
}

type Publisher struct {
	// contains filtered or unexported fields
}

func NewPublisher() (*Publisher, error)

func (this *Publisher) Publish(command PermCommandMsg) (err error)

Path	Synopsis
auth
util