waiter

Documentation

Index

• func GenerateUuid() string
• func GetBytes(d interface{}) ([]byte, error)
• type Callback
• type CallbackType
• type WaitService

Functions

func GenerateUuid

func GenerateUuid() string

func GetBytes

func GetBytes(d interface{}) ([]byte, error)

Types

type Callback

type Callback interface {
	Notify(data map[string][]byte, isTimeout bool) error
	GetType() CallbackType
}

type CallbackType

type CallbackType string

type WaitService

type WaitService interface {
	WaitOn(ctx context.Context, cb CallbackType, notifyIds ...string) error

	Done(ctx context.Context, notifyId string, data interface{}) error

	RegisterCallback(cb Callback) error
}