Documentation
¶
Index ¶
- func CacheCancelFunc(f context.CancelFunc)
- func CancelScripts()
- func PrepareScript(coll *data.Collection, requestName string, currentEnv string, ...) (string, data.EnvMapValue, error)
- type Identifier
- type KafkaConsumer
- type KafkaPrinter
- type KafkaProducer
- type LoopChecker
- type ScriptCanceller
- type State
- type WSClient
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func CacheCancelFunc ¶
func CacheCancelFunc(f context.CancelFunc)
func CancelScripts ¶
func CancelScripts()
func PrepareScript ¶
func PrepareScript( coll *data.Collection, requestName string, currentEnv string, overrides data.EnvMapValue, ) (string, data.EnvMapValue, error)
Types ¶
type Identifier ¶
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 LoopChecker ¶
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 ScriptCanceller ¶
type State ¶
type State struct { *lua.LState Cancel context.CancelFunc // 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)
Click to show internal directories.
Click to hide internal directories.