runner

package

v0.1.0-pre.3 Latest Latest Go to latest Published: Oct 10, 2024 License: MIT Imports: 15 Imported by: 0

Details

This section is empty.

This section is empty.

func StdCheck(L *lua.LState, tbl *lua.LTable, b any)

func StdCheckDefinition(fn lua.LGFunction) *spec.Function

func StdCheckError(ctx context.Context, tbl *lua.LTable, b any) error

func WithSaveFunc(ctx context.Context, fn SaveFunc) context.Context

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

func NewGQLRunner(server http.Handler) *GQL

func (g *GQL) Functions() []*spec.Function

func (g *GQL) Name() string

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

func NewPubSub(doPublish PubSubHook) *PubSub

func (g *PubSub) Functions() []*spec.Function

func (p *PubSub) Name() string

func (p *PubSub) Receive(topic string, msg PubSubMessage)

func (p *PubSub) Send(topic string, msg PubSubMessage)

type PubSubHook func(topic string, msg PubSubMessage) error

type PubSubMessage struct {
	Msg        map[string]any    `json:"msg"`
	Attributes map[string]string `json:"attributes"`
}

type PubSubTopic struct {
	Sent     []PubSubMessage
	Received []PubSubMessage
}

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

func NewRestRunner(server http.Handler) *REST

func (s *REST) Functions() []*spec.Function

func (r *REST) Name() string

type Reporter interface {
	Error(msg string, args ...any)
}

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

func NewSQLRunner(db *pgxpool.Pool) *SQL

func (s *SQL) Functions() []*spec.Function

func (s *SQL) HelperFunctions() []*spec.Function

func (s *SQL) Name() string

type SaveFunc func(key string, value any)