event

Documentation

Index

• func HandleEvent(ctx context.Context, projectName string, eventType string, ...) error
• type HandleEventReq
• type HandleEventResult
  • func HandleEvents(ctx context.Context, projectName string, r *HandleEventReq) []*HandleEventResult
  • func OnEventReceived(ctx context.Context, projectName string, r *eventpb.Event) (ret *HandleEventResult, err error)

Functions

func HandleEvent

func HandleEvent(ctx context.Context, projectName string, eventType string, ret *HandleEventResult, payload []byte) error

Types

type HandleEventReq

type HandleEventReq struct {
	Events []eventpb.Event `json:"events"`
}

type HandleEventResult

type HandleEventResult struct {
	ProjectName string                   `json:"projectName"`
	PubID       types.SFID               `json:"pubID,omitempty"`
	PubName     string                   `json:"pubName,omitempty"`
	EventID     string                   `json:"eventID"`
	ErrMsg      string                   `json:"errMsg,omitempty"`
	WasmResults []wasm.EventHandleResult `json:"wasmResults"`
}

func HandleEvents

func HandleEvents(ctx context.Context, projectName string, r *HandleEventReq) []*HandleEventResult

func OnEventReceived

func OnEventReceived(ctx context.Context, projectName string, r *eventpb.Event) (ret *HandleEventResult, err error)