runtime

Documentation

Index

• Variables
• func GetVersion() string
• func NewApiHandler(s *proto.Schema) common.HandlerFunc
• func NewAuthHandler(schema *proto.Schema) func(http.ResponseWriter, *http.Request) common.Response
• func NewHttpHandler(currSchema *proto.Schema) http.Handler
• type JobHandler
  • func NewJobHandler(currSchema *proto.Schema) JobHandler
  • func (handler JobHandler) RunJob(ctx context.Context, jobName string, inputs map[string]any, ...) error
• type SubscriberHandler
  • func NewSubscriberHandler(currSchema *proto.Schema) SubscriberHandler
  • func (handler SubscriberHandler) RunSubscriber(ctx context.Context, subscriberName string, event *events.Event) error

Variables

var Version string

Functions

func GetVersion

func GetVersion() string

func NewApiHandler

func NewApiHandler(s *proto.Schema) common.HandlerFunc

NewApiHandler handles requests to the customer APIs

func NewAuthHandler

func NewAuthHandler(schema *proto.Schema) func(http.ResponseWriter, *http.Request) common.Response

NewAuthHandler handles requests to the authentication endpoints

func NewHttpHandler

func NewHttpHandler(currSchema *proto.Schema) http.Handler

Types

type JobHandler

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

func NewJobHandler

func NewJobHandler(currSchema *proto.Schema) JobHandler

func (JobHandler) RunJob

func (handler JobHandler) RunJob(ctx context.Context, jobName string, inputs map[string]any, trigger functions.TriggerType) error

RunJob will run the job function in the runtime.

type SubscriberHandler

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

func NewSubscriberHandler

func NewSubscriberHandler(currSchema *proto.Schema) SubscriberHandler

func (SubscriberHandler) RunSubscriber

func (handler SubscriberHandler) RunSubscriber(ctx context.Context, subscriberName string, event *events.Event) error

RunSubscriber will run the subscriber function in the runtime with the event payload.