receiver

Documentation

Index

• type Executable
• type HTTPAction
  • func NewHTTPAction(header http.Header, method, url string) *HTTPAction
  • func (a *HTTPAction) Exec(ctx context.Context, payload []byte) error
• type Subscriber
  • func New(ctx context.Context) (Subscriber, error)

Types

type Executable

type Executable interface {
	Exec(context.Context, []byte) error
}

Executable provides Exec method for action.

type HTTPAction

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

HTTPAction implements action for HTTP.

func NewHTTPAction

func NewHTTPAction(header http.Header, method, url string) *HTTPAction

NewHTTPAction returns a new http action.

func (*HTTPAction) Exec

func (a *HTTPAction) Exec(ctx context.Context, payload []byte) error

Exec executes pubsub action.

type Subscriber

type Subscriber interface {
	Subscribe(ctx context.Context, subscription string, fn func(context.Context, []byte) bool) error
}

Subscriber provides pubsub subscriber.

func New

func New(ctx context.Context) (Subscriber, error)

New returns Subscriber.