Versions in this module Expand all Collapse all v0 v0.1.1 Oct 28, 2022 Changes in this version + type Config struct + Host string + MaxBufferSize int + Mode modes.DaprMode + Port int + Protocol runtime.Protocol + type Event struct + func NewEvent(ctx *context.Context, bindingEvent *common.BindingEvent, ...) Event + type EventResponse struct + Data []byte + Error error + type Runtime struct + 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()
Go to main page