exec

Documentation

Index

• func PrepareScript(coll *data.Collection, requestName string, currentEnv string, ...) (string, data.EnvMapValue, error)
• type Identifier
  • func (i Identifier) String() string
• type KafkaConsumer
• type KafkaPrinter
  • func NewKafkaPrinter(tag string) (*KafkaPrinter, error)
  • func (p *KafkaPrinter) Printf(msg string, args ...any)
• type KafkaProducer
• type LoopChecker
  • func NewLoopChecker() LoopChecker
  • func (lc LoopChecker) AddIdent(ident Identifier) bool
  • func (lc LoopChecker) ClearIdent(ident Identifier)
• type State
  • func CreateState(ident Identifier, currentEnv string, env data.EnvMapValue, ...) *State
  • func ExecuteRequest(coll *data.Collection, requestName string, currentEnv string, ...) (*State, error)
  • func (s *State) CancelErr(format string, args ...any) int

Functions

func PrepareScript

func PrepareScript(
	coll *data.Collection,
	requestName string,
	currentEnv string,
	overrides data.EnvMapValue,
) (string, data.EnvMapValue, error)

Types

type Identifier

type Identifier struct {
	Path       string
	Collection string
	Request    string
}

func (Identifier) String

func (i Identifier) String() string

type KafkaConsumer

type KafkaConsumer struct {
	*kafka.Reader
}

type KafkaPrinter

type KafkaPrinter struct {
	Tag string
	// contains filtered or unexported fields
}

func NewKafkaPrinter

func NewKafkaPrinter(tag string) (*KafkaPrinter, error)

func (*KafkaPrinter) Printf

func (p *KafkaPrinter) Printf(msg string, args ...any)

type KafkaProducer

type KafkaProducer struct {
	*kafka.Writer
	Config struct {
		Topic   string
		Timeout time.Duration
	}
}

type LoopChecker

type LoopChecker map[string]bool

func NewLoopChecker

func NewLoopChecker() LoopChecker

func (LoopChecker) AddIdent

func (lc LoopChecker) AddIdent(ident Identifier) bool

func (LoopChecker) ClearIdent

func (lc LoopChecker) ClearIdent(ident Identifier)

type State

type State struct {
	*lua.LState
	// contains filtered or unexported fields
}

func CreateState

func CreateState(
	ident Identifier,
	currentEnv string,
	env data.EnvMapValue,
	loopCheck LoopChecker,
) *State

func ExecuteRequest

func ExecuteRequest(
	coll *data.Collection,
	requestName string,
	currentEnv string,
	overrides data.EnvMapValue,
	loopCheck LoopChecker,
) (*State, error)

func (*State) CancelErr

func (s *State) CancelErr(format string, args ...any) int