runtime

Documentation

Index

• type Config
• type Event
  • func NewEvent(ctx *context.Context, bindingEvent *common.BindingEvent, ...) Event
• type EventResponse
• type Runtime
  • func NewFuncRuntime(config *Config, ctx *ofctx.FunctionContext) *Runtime
  • func (r *Runtime) CreateFuncChannel() error
  • func (r *Runtime) EnqueueEvent(event *Event)
  • func (r *Runtime) GetPendingEventsCount() int
  • func (r *Runtime) OnBindingEvent(ctx *context.Context, event *common.BindingEvent) ([]byte, error)
  • func (r *Runtime) OnTopicEvent(ctx *context.Context, event *common.TopicEvent) error
  • func (r *Runtime) ProcessEvents()

Types

type Config

type Config struct {
	Protocol runtime.Protocol
	Host     string
	Port     int
	Mode     modes.DaprMode

	MaxBufferSize int
	// contains filtered or unexported fields
}

type Event

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

func NewEvent

func NewEvent(ctx *context.Context,
	bindingEvent *common.BindingEvent,
	topicEvent *common.TopicEvent,
	respCh chan *EventResponse) Event

type EventResponse

type EventResponse struct {
	Data  []byte
	Error error
}

type Runtime

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

func NewFuncRuntime

func NewFuncRuntime(config *Config, ctx *ofctx.FunctionContext) *Runtime

func (*Runtime) CreateFuncChannel

func (r *Runtime) CreateFuncChannel() error

func (*Runtime) EnqueueEvent

func (r *Runtime) EnqueueEvent(event *Event)

func (*Runtime) GetPendingEventsCount

func (r *Runtime) GetPendingEventsCount() int

func (*Runtime) OnBindingEvent

func (r *Runtime) OnBindingEvent(ctx *context.Context, event *common.BindingEvent) ([]byte, error)

func (*Runtime) OnTopicEvent

func (r *Runtime) OnTopicEvent(ctx *context.Context, event *common.TopicEvent) error

func (*Runtime) ProcessEvents

func (r *Runtime) ProcessEvents()