Documentation ¶
Index ¶
- func InitEventHandling(ctx context.Context, config configuration.Config, worker *Worker) (err error)
- func UseJsonPath(msg []byte, feature configuration.Feature) (result interface{}, err error)
- type Query
- type Worker
- func (this *Worker) DeleteFeatures(kind string, command model.CommandWrapper) (err error)
- func (this *Worker) DeleteGroupRight(kind string, resource string, group string) (err error)
- func (this *Worker) DeleteUserRight(kind string, resource string, user string) (err error)
- func (this *Worker) GetAnnotationHandler(annotationTopic string, resources []string) func(delivery []byte) error
- func (this *Worker) GetClient() *opensearch.Client
- func (this *Worker) GetQuery() Query
- func (this *Worker) GetResourceCommandHandler(resourceName string) func(delivery []byte) error
- func (this *Worker) HandleAnnotationMsg(annotationTopic string, resource string, msg []byte) error
- func (this *Worker) HandlePermissionCommand(msg []byte) (err error)
- func (this *Worker) MsgToAnnotations(kind string, annotationTopic string, msg []byte) (result map[string]interface{}, err error)
- func (this *Worker) MsgToFeatures(kind string, msg []byte) (result map[string]interface{}, err error)
- func (this *Worker) MsgToRights(msg []byte) (result *model.ResourceRightsBase, err error)
- func (this *Worker) SendDone(msg model.Done) error
- func (this *Worker) SetGroupRight(kind string, resource string, group string, rights string) (err error)
- func (this *Worker) SetUserRight(kind string, resource string, user string, rights string) (err error)
- func (this *Worker) UpdateFeatures(kind string, msg []byte, command model.CommandWrapper) (err error)
- func (this *Worker) UpdateRights(kind string, msg []byte, command model.CommandWrapper) (err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitEventHandling ¶
func UseJsonPath ¶
func UseJsonPath(msg []byte, feature configuration.Feature) (result interface{}, err error)
Types ¶
type Worker ¶
type Worker struct {
// contains filtered or unexported fields
}
func (*Worker) DeleteFeatures ¶
func (this *Worker) DeleteFeatures(kind string, command model.CommandWrapper) (err error)
func (*Worker) DeleteGroupRight ¶
func (*Worker) DeleteUserRight ¶
func (*Worker) GetAnnotationHandler ¶
func (*Worker) GetResourceCommandHandler ¶
func (*Worker) HandleAnnotationMsg ¶
func (*Worker) HandlePermissionCommand ¶
func (*Worker) MsgToAnnotations ¶
func (*Worker) MsgToFeatures ¶
func (*Worker) MsgToRights ¶
func (this *Worker) MsgToRights(msg []byte) (result *model.ResourceRightsBase, err error)
func (*Worker) SetGroupRight ¶
func (*Worker) SetUserRight ¶
func (*Worker) UpdateFeatures ¶
func (*Worker) UpdateRights ¶
Click to show internal directories.
Click to hide internal directories.