domain

Documentation

Index

• func NewTag(optFuncs ...MessageOptsFunc) string
• type Action
• type MessageOpts
• type MessageOptsFunc
  • func WithRandomTag() MessageOptsFunc
  • func WithTag(tag string) MessageOptsFunc
  • func WithUUID() MessageOptsFunc
• type Output
• type Request
  • func NewRequest(output Output) *Request
  • func NewRequestError(err error) *Request
• type Response
• type Stub
• type Trigger

Functions

func NewTag

func NewTag(optFuncs ...MessageOptsFunc) string

Types

type Action

type Action interface {
	Invoke(stub Stub, input map[string]interface{}) (output map[string]interface{}, err error)
}

type MessageOpts

type MessageOpts struct {
	// contains filtered or unexported fields
}

type MessageOptsFunc

type MessageOptsFunc func(opt *MessageOpts)

func WithRandomTag

func WithRandomTag() MessageOptsFunc

func WithTag

func WithTag(tag string) MessageOptsFunc

func WithUUID

func WithUUID() MessageOptsFunc

type Output

type Output map[string]interface{}

type Request

type Request struct {
	Tag    string
	Output Output
	Error  error
}

func NewRequest

func NewRequest(output Output) *Request

func NewRequestError

func NewRequestError(err error) *Request

type Response

type Response struct {
	Message map[string]interface{}
	Error   error
}

type Stub

type Stub interface {
	logger.Logger
}

type Trigger

type Trigger interface {
	// Init: must NOT block, start long running processes in a go routine
	Init(stub Stub, config []byte) (err error)

	// NextMessage: request the next message that was produced/receveid by the trigger
	NextMessage() (tag string, message map[string]interface{}, err error)

	// Respond: is called by the adapter base after the message (with tag `tag`), which was initially received
	// by the Trigger, has passed through the actions in the pipeline. Respond is used to send a response back to
	// the caller of the Trigger. In case of an error during invocation of an action component, the adapter base will
	// discontinue invocation of other actions in the pipeline and call Respond.
	Respond(tag string, response map[string]interface{}, err error) error

	Close() error
}