azure

Documentation

Index

• func ErrorStatusCode(err error) int
• func HelperModule(extraOptions fx.Option) fx.Option
• func WriteError(w http.ResponseWriter, err error)
• type Helper
  • func NewDefaultHelper(ctx context.Context, handler *cloudevents.HandlerWrapper) *Helper
  • func NewHelper(ctx context.Context, options *Options, handler *cloudevents.HandlerWrapper) *Helper
  • func (h *Helper) Start()
• type InvokeRequest
• type InvokeResponse
• type Options
  • func DefaultOptions() (*Options, error)

Functions

func ErrorStatusCode

func ErrorStatusCode(err error) int

ErrorStatusCode translates to the respective status code.

func HelperModule

func HelperModule(extraOptions fx.Option) fx.Option

HelperModule returns fx module for initialization of helper to start NATS client for handlers.

The module is only loaded once.

func WriteError

func WriteError(w http.ResponseWriter, err error)

Types

type Helper

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

Helper assists in creating event handlers.

func NewDefaultHelper

func NewDefaultHelper(ctx context.Context, handler *cloudevents.HandlerWrapper) *Helper

NewDefaultHelper returns a new Helper with default options.

func NewHelper

func NewHelper(ctx context.Context, options *Options,
	handler *cloudevents.HandlerWrapper) *Helper

NewHelper returns a new Helper with options.

func (*Helper) Start

func (h *Helper) Start()

type InvokeRequest

type InvokeRequest struct {
	Data     map[string]json.RawMessage
	Metadata map[string]interface{}
}

type InvokeResponse

type InvokeResponse struct {
	Outputs     map[string]interface{}
	Logs        []string
	ReturnValue interface{}
}

type Options

type Options struct {
	Port string
	Name string
}

Options can be used to create customized handler.

func DefaultOptions

func DefaultOptions() (*Options, error)

DefaultOptions returns options based in config.