donewait

Documentation

Index

• func AsyncWait(ctx context.Context, msg DoneMsg, broker *signal.Broker) func() error
• func SerializeDoneMsg(msg DoneMsg) string
• func StartDoneWaitListener(ctx context.Context, kafkaConf kafka.Config, topics []string, ...) (err error)
• func WaitForDone(ctx context.Context, msg DoneMsg, broker *signal.Broker) error
• type DoneMsg

Functions

func AsyncWait

func AsyncWait(ctx context.Context, msg DoneMsg, broker *signal.Broker) func() error

func SerializeDoneMsg

func SerializeDoneMsg(msg DoneMsg) string

func StartDoneWaitListener

func StartDoneWaitListener(ctx context.Context, kafkaConf kafka.Config, topics []string, broker *signal.Broker) (err error)

func WaitForDone

func WaitForDone(ctx context.Context, msg DoneMsg, broker *signal.Broker) error

Types

type DoneMsg

type DoneMsg struct {
	ResourceKind string `json:"resource_kind"`
	ResourceId   string `json:"resource_id"`
	Command      string `json:"command"` // PUT | DELETE | RIGHTS
	Handler      string `json:"handler"` // e.g. github.com/SENERGY-Platform/permission-search, may be empty in WaitForDone
}