worker

Dec 19, 2023

Changes in this version

+ 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 interface

+ GetClient func() *opensearch.Client

+ GetResourceEntry func(kind string, resource string) (result model.Entry, version model.ResourceVersion, err error)

+ ResourceExists func(kind string, resource string) (exists bool, err error)

+ type Worker struct

+ func New(ctx context.Context, config configuration.Config, query Query) (result *Worker, err error)

+ 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)