runtime

package

v0.428.2 Latest Latest Go to latest Published: Dec 1, 2025 License: AGPL-3.0 Imports: 25 Imported by: 0

Details

This section is empty.

View Source

var Version string

func GetVersion() string

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

NewApiHandler handles requests to the customer APIs.

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

NewAuthHandler handles requests to the authentication endpoints.

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

NewFlowsHandler handles requests to the customer flows.

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

func NewRouter(s *proto.Schema) *httprouter.Router

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

NewTasksHandler handles requests to the tasks api.

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

func NewJobHandler(currSchema *proto.Schema) JobHandler

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

RunJob will run the job function in the runtime.

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

func NewSubscriberHandler(currSchema *proto.Schema) SubscriberHandler

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.