roles

Documentation

Index

• Variables
• type Event
  • func NewEvent(ctx context.Context, data map[string]interface{}) *Event
  • func (ev *Event) String() string
  • func (ev *Event) WithTopic(topic string) *Event
• type EventHandler
• type EventPayload
• type Instance
• type Role

Variables

var ErrRoleNotConfigured = errors.New("role: Not configured")

Types

type Event

type Event struct {
	Payload EventPayload
	Context context.Context
	// contains filtered or unexported fields
}

func NewEvent

func NewEvent(ctx context.Context, data map[string]interface{}) *Event

func (*Event) String

func (ev *Event) String() string

func (*Event) WithTopic

func (ev *Event) WithTopic(topic string) *Event

type EventHandler

type EventHandler func(ev *Event)

type EventPayload

type EventPayload struct {
	Data                 map[string]interface{}
	RelatedObjectKey     *storage.Key
	RelatedObjectOptions []clientv3.OpOption
}

type Instance

type Instance interface {
	KV() *storage.Client
	Log() *zap.Logger
	DispatchEvent(topic string, ev *Event)
	AddEventListener(topic string, handler EventHandler)
}

type Role

type Role interface {
	Start(ctx context.Context, config []byte) error
	Stop()
}