kafka

type Command struct {
	Command string               `json:"command"`
	Id      string               `json:"id"`
	Rights  *ResourcePermissions `json:"rights"`
	Owner   string               `json:"owner,omitempty"`
}

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

type KafkaProducerProvider struct{}

type KeySeparationBalancer struct {
	SubBalancer kafka.Balancer
	Seperator   string
}

type Producer interface {
	Close() error
	SendPermissions(ctx context.Context, topic model.Topic, id string, permissions model.ResourcePermissions) (err error)
}

type Provider interface {
	GetProducer(config configuration.Config, topic model.Topic) (Producer, error)
}

type ResourcePermissions struct {
	UserRights           map[string]Right `json:"user_rights"`
	GroupRights          map[string]Right `json:"group_rights"`
	KeycloakGroupsRights map[string]Right `json:"keycloak_groups_rights"`
}

type Right struct {
	Read         bool `json:"read"`
	Write        bool `json:"write"`
	Execute      bool `json:"execute"`
	Administrate bool `json:"administrate"`
}

type VoidProducer struct{}

type VoidProducerProvider struct{}