runner

package

Go to main page

Versions in this module

v1

v1.0.21

Jan 23, 2025

v1.0.20

Jan 23, 2025

v1.0.19

Jan 23, 2025

v1.0.18

Jan 22, 2025

v1.0.17

Jan 21, 2025

v1.0.16

Jan 21, 2025

v1.0.15

Jan 21, 2025

Changes in this version

type ReceiveTermType

+ const ReceiveTermTypeReceiveTermTypeContextCanceled

v1.0.14

Jan 21, 2025

Changes in this version

+ type ReceiveTermData struct

+ Err error

+ Type ReceiveTermType

v1.0.13

Jan 21, 2025

v1.0.12

Jan 21, 2025

v1.0.11

Jan 21, 2025

v1.0.10

Jan 21, 2025

v1.0.9

Jan 21, 2025

Changes in this version

+ var FlowRunnerActionsList = []ActionType

+ var MassExecuteRunnerActionsList = []ActionType

+ var MemoryValueRunnerActionsList = []ActionType

+ var OneExecuteRunnerActionsList = []ActionType

+ var SlaveConnectRunnerActionsList = []ActionType

+ var StoreImportRunnerActionsList = []ActionType

+ var StoreValueRunnerActionsList = []ActionType

+ type Action struct

+ ID *string

+ On []ActionOn

+ Type *string

+ func (a Action) Validate(valid *ValidAction) error

+ type ActionCastData struct

+ Action ActionType

+ ActionID string

+ type ActionCaster map[ActionType]chan struct

+ func NewActionCasterFromRunnerKind(kind Kind) (ActionCaster, error)

+ func (c ActionCaster) Close()

+ func (c ActionCaster) FindChannel(actionType ActionType) (chan struct{}, bool)

+ func (c ActionCaster) Send(ctx context.Context, actionType ActionType)

+ type ActionOn struct

+ Event *string

+ Flow *string

+ func (a ActionOn) Validate() (ValidActionOn, error)

+ type ActionType string

+ const ActionTypeTermWithErr

+ const ActionTypeTermWithoutErr

+ const SlaveConnectRunnerActionDisconnect

+ type Actions []Action

+ func (a Actions) Validate() (ValidActions, error)

type ConnectionContainer

+ func (c *ConnectionContainer) Disconnect(_ context.Context, slaveIDs []string) error

type FlowStepFlow

+ Actions Actions

+ type ValidAction struct

+ ID string

+ On []ValidActionOn

+ Type ActionType

+ type ValidActionOn struct

+ Event Event

+ Flow string

+ type ValidActions []ValidAction

type ValidFlowStepFlow

+ NotifyActionChan <-chan ActionCastData

+ ValidActions ValidActions

v1.0.8

Jan 21, 2025

v1.0.7

Jan 19, 2025

v1.0.6

Jan 19, 2025

v1.0.5

Jan 19, 2025

v1.0.4

Jan 15, 2025

v1.0.3

Jan 15, 2025

v1.0.2

Jan 14, 2025

v1.0.1

Jan 14, 2025

v1.0.0

Jan 13, 2025

Changes in this version

+ const DefaultChunkSize

+ func Run(ctr *container.Container, filename string, data map[string]any) error

+ func RunAsyncProcessing(ctx context.Context, reqTermChan <-chan struct{}, log logger.Logger, id int, ...)

+ type AttachRequestInfo func(ctx context.Context, req *http.Request) error

+ type AuthenticatorFactor interface

+ Factorize func(ctx context.Context, authID string, isDefault bool) (auth.SetAuthor, error)

+ IsDefault func(authID string) bool

+ type BaseExecutor struct

+ AuthFactor AuthenticatorFactor

+ EncryptCtr encrypt.Container

+ Env string

+ Logger logger.Logger

+ OutputFactor OutputFactor

+ SlaveConnectContainer *ConnectionContainer

+ Store Store

+ TargetFactor TargetFactor

+ TmplFactor TmplFactor

+ func (e BaseExecutor) Execute(ctx context.Context, filename string, str *sync.Map, threadOnlyStr *sync.Map, ...) error

+ type ConnectionContainer struct

+ func NewConnectionContainer() *ConnectionContainer

+ func (c *ConnectionContainer) AllDisconnect(_ context.Context) error

+ func (c *ConnectionContainer) Connect(ctx context.Context, log logger.Logger, env string, ...) error

+ func (c *ConnectionContainer) Find(slaveID string) (*ConnectionMapData, bool)

+ type ConnectionMapData struct

+ Cli pb.BloaderSlaveServiceClient

+ ConnectionID string

+ ReceiveTermChan <-chan ReceiveTermType

+ ReqChan <-chan *pb.ReceiveChanelConnectResponse

+ type CredentialEncryptConfig struct

+ Enabled bool

+ EncryptID *string

+ func (c CredentialEncryptConfig) Validate() (ValidCredentialEncryptConfig, error)

+ type DefaultEventCaster struct

+ Caster *utils.Broadcaster[Event]

+ func NewDefaultEventCaster() *DefaultEventCaster

+ func NewDefaultEventCasterWithBroadcaster(broadcaster *utils.Broadcaster[Event]) *DefaultEventCaster

+ func (ec *DefaultEventCaster) CastEvent(_ context.Context, event Event) error

+ func (ec *DefaultEventCaster) CastEventWithWait(ctx context.Context, event Event) error

+ func (ec *DefaultEventCaster) Close(_ context.Context) error

+ func (ec *DefaultEventCaster) Subscribe(_ context.Context) error

+ func (ec *DefaultEventCaster) Unsubscribe(_ context.Context, ch chan Event) error

+ type Event string

+ const RunnerEventStart

+ const RunnerEventStoreImported

+ const RunnerEventStoreImporting

+ const RunnerEventTerminated

+ const RunnerEventValidated

+ const RunnerEventValidating

+ const SlaveConnectRunnerEventConnected

+ const SlaveConnectRunnerEventConnecting

+ type EventCaster interface

+ CastEvent func(ctx context.Context, event Event) error

+ CastEventWithWait func(ctx context.Context, event Event) error

+ Close func(ctx context.Context) error

+ Subscribe func(ctx context.Context) error

+ Unsubscribe func(ctx context.Context, ch chan Event) error

+ type ExecRequestData struct

+ Extractor *matcher.DataExtractor

+ Key *string

+ func (d ExecRequestData) Validate() (ValidExecRequestData, error)

+ type ExecRequestStoreData struct

+ BucketID *string

+ Encrypt CredentialEncryptConfig

+ Extractor *matcher.DataExtractor

+ StoreKey *string

+ func (d ExecRequestStoreData) Validate() (ValidExecRequestStoreData, error)

+ type Flow struct

+ Step FlowStep

+ func (r Flow) Validate() (ValidFlow, error)

+ type FlowStep struct

+ Concurrency *int

+ Flows []FlowStepFlow

+ func (r FlowStep) Validate() (ValidFlowStep, error)

+ type FlowStepFlow struct

+ Concurrency *int

+ Count *int

+ DependsOn []FlowStepFlowDependsOn

+ Executors []FlowStepFlowExecutor

+ File *string

+ Flows []FlowStepFlow

+ ID *string

+ Mkdir bool

+ ThreadOnlyValues []FlowStepFlowValue

+ Type *string

+ Values []FlowStepFlowValue

+ func (f FlowStepFlow) Validate(valid *ValidFlowStepFlow, idSet map[string]struct{}) error

+ type FlowStepFlowDependsOn struct

+ Event *string

+ Flow *string

+ func (r FlowStepFlowDependsOn) Validate() (ValidFlowStepFlowDependsOn, error)

+ type FlowStepFlowExecutor struct

+ AdditionalThreadOnlyValues []FlowStepFlowValue

+ AdditionalValues []FlowStepFlowValue

+ InheritValues bool

+ Output FlowStepFlowExecutorOutput

+ SlaveID *string

+ func (r FlowStepFlowExecutor) Validate() (ValidFlowStepFlowExecutor, error)

+ type FlowStepFlowExecutorOutput struct

+ Enabled bool

+ RootPath *string

+ func (r FlowStepFlowExecutorOutput) Validate() (ValidFlowStepFlowExecutorOutput, error)

+ type FlowStepFlowType string

+ const FlowStepFlowTypeFile

+ const FlowStepFlowTypeFlow

+ const FlowStepFlowTypeSlaveCmd

+ type FlowStepFlowValue struct

+ Key *string

+ Value *any

+ func (r FlowStepFlowValue) Validate() (ValidFlowStepFlowValue, error)

+ type HTTPRequest struct

+ AttachRequestInfo AttachRequestInfo

+ AuthFactor AuthenticatorFactor

+ Body any

+ BodyType HTTPRequestBodyType

+ Headers map[string]any

+ IsMass bool

+ Method string

+ OutputFactor OutputFactor

+ PathVariables map[string]string

+ QueryParams map[string]any

+ ReplaceData *sync.Map

+ ReqIndex int

+ TargetFactor TargetFactor

+ TmplStr string

+ URL string

+ func (r HTTPRequest) CreateRequest(ctx context.Context, log logger.Logger, count int) (*http.Request, error)

+ type HTTPRequestBodyType string

+ const DefaultHTTPRequestBodyType

+ const HTTPRequestBodyTypeForm

+ const HTTPRequestBodyTypeJSON

+ const HTTPRequestBodyTypeMultipart

+ type ImportCallback func(ctx context.Context, data ValidStoreImportData, val any, valBytes []byte) error

+ type Kind string

+ const RunnerKindFlow

+ const RunnerKindMassExecute

+ const RunnerKindMemoryValue

+ const RunnerKindOneExecute

+ const RunnerKindSlaveConnect

+ const RunnerKindStoreImport

+ const RunnerKindStoreValue

+ type LocalAuthenticatorFactor struct

+ func NewLocalAuthenticatorFactor(authCtr auth.AuthenticatorContainer) *LocalAuthenticatorFactor

+ func (l LocalAuthenticatorFactor) Factorize(_ context.Context, authID string, isDefault bool) (auth.SetAuthor, error)

+ func (l LocalAuthenticatorFactor) IsDefault(authID string) bool

+ type LocalOutputFactor struct

+ func NewLocalOutputFactor(outputCtr output.Container) LocalOutputFactor

+ func (f LocalOutputFactor) Factorize(_ context.Context, outputID string) (output.Output, error)

+ type LocalStore struct

+ func NewLocalStore(encCtr encrypt.Container, str store.Store) *LocalStore

+ func (l LocalStore) Import(ctx context.Context, data []ValidStoreImportData, cb ImportCallback) error

+ func (l LocalStore) Store(ctx context.Context, data []ValidStoreValueData, cb StoreCallback) error

+ func (l LocalStore) StoreWithExtractor(ctx context.Context, res any, data []ValidExecRequestStoreData, ...) error

+ type LocalTargetFactor struct

+ func NewLocalTargetFactor(targets target.Container) *LocalTargetFactor

+ func (l LocalTargetFactor) Factorize(_ context.Context, targetID string) (target.Target, error)

+ type LocalTmplFactor struct

+ func NewLocalTmplFactor(basePath string) *LocalTmplFactor

+ func (l LocalTmplFactor) TmplFactorize(_ context.Context, path string) (string, error)

+ type MassExec struct

+ Auth MassExecAuth

+ Output MassExecOutput

+ Requests []MassExecRequest

+ Type *string

+ func (r MassExec) Validate(ctx context.Context, log logger.Logger, authFactor AuthenticatorFactor, ...) (ValidMassExec, error)

+ type MassExecAuth struct

+ AuthID *string

+ Enabled bool

+ func (a MassExecAuth) Validate(ctx context.Context, authFactor AuthenticatorFactor) (auth.SetAuthor, error)

+ type MassExecOutput struct

+ Enabled bool

+ IDs []string

+ func (o MassExecOutput) Validate(ctx context.Context, outFactor OutputFactor) ([]output.Output, error)

+ type MassExecRequest struct

+ AwaitPrevResp bool

+ Body any

+ BodyType *string

+ Break MassExecRequestBreak

+ Data []ExecRequestData

+ Endpoint *string

+ Headers map[string]any

+ Interval *string

+ Method *string

+ PathVariables map[string]string

+ QueryParam map[string]any

+ RecordExcludeFilter MassExecRequestRecordExcludeFilter

+ ResponseType *string

+ SuccessBreak []string

+ TargetID *string

+ func (r MassExecRequest) Validate(ctx context.Context, log logger.Logger, targetFactor TargetFactor, ...) (ValidMassExecRequest, error)

+ type MassExecRequestBreak struct

+ Count *int

+ ParseError bool

+ ResponseBody matcher.BodyConditions

+ StatusCode matcher.StatusCodeConditions

+ SysError bool

+ Time *string

+ WriteError bool

+ func (b MassExecRequestBreak) Validate(ctx context.Context, log logger.Logger) (ValidMassExecRequestBreak, error)

+ type MassExecRequestRecordExcludeFilter struct

+ Count matcher.CountConditions

+ ResponseBody matcher.BodyConditions

+ StatusCode matcher.StatusCodeConditions

+ func (f MassExecRequestRecordExcludeFilter) Validate(ctx context.Context, log logger.Logger) (ValidMassExecRequestRecordExcludeFilter, error)

+ type MassExecType string

+ const MassExecTypeHTTP

+ type MassiveExecThreadExecutor struct

+ ID int

+ ReqTermChan chan<- struct{}

+ RequestExecutor httpexec.MassRequestExecutor

+ TermChan chan TermChanType

+ func (e *MassiveExecThreadExecutor) Close(_ context.Context) error

+ func (e *MassiveExecThreadExecutor) Execute(ctx context.Context, log logger.Logger, startChan <-chan struct{}) error

+ type MemoryValue struct

+ Data []MemoryValueData

+ func (r MemoryValue) Validate() (ValidMemoryValue, error)

+ type MemoryValueData struct

+ Key *string

+ Value *any

+ func (d MemoryValueData) Validate() (ValidMemoryValueData, error)

+ type OneExec struct

+ Auth OneExecAuth

+ Output OneExecOutput

+ Request *OneExecRequest

+ Type *string

+ func (r OneExec) Validate(ctx context.Context, authFactor AuthenticatorFactor, outFactor OutputFactor, ...) (ValidOneExec, error)

+ type OneExecAuth struct

+ AuthID *string

+ Enabled bool

+ func (a OneExecAuth) Validate(ctx context.Context, authFactor AuthenticatorFactor) (auth.SetAuthor, error)

+ type OneExecOutput struct

+ Enabled bool

+ IDs []string

+ func (o OneExecOutput) Validate(ctx context.Context, outFactor OutputFactor) ([]output.Output, error)

+ type OneExecRequest struct

+ Body any

+ BodyType *string

+ Data []ExecRequestData

+ Endpoint *string

+ Headers map[string]any

+ MemoryData []ExecRequestData

+ Method *string

+ PathVariables map[string]string

+ QueryParam map[string]any

+ ResponseType *string

+ StoreData []ExecRequestStoreData

+ TargetID *string

+ func (r OneExecRequest) Validate(ctx context.Context, targetFactor TargetFactor) (ValidOneExecRequest, error)

+ type OneExecType string

+ const OneExecTypeHTTP

+ type OutputFactor interface

+ Factorize func(ctx context.Context, outputID string) (output.Output, error)

+ type ReceiveTermType string

+ const ReceiveTermTypeReceiveTermTypeDisconnected

+ const ReceiveTermTypeReceiveTermTypeEOF

+ const ReceiveTermTypeReceiveTermTypeResponseReceiveError

+ const ReceiveTermTypeReceiveTermTypeStreamContextDone

+ type ResponseDataConsumer func(ctx context.Context, log logger.Logger, id int, data WriteData) error

+ type RunStoreImport struct

+ Data []StoreImportData

+ Enabled bool

+ func (r RunStoreImport) Validate() (ValidRunnerStoreImport, error)

+ type Runner struct

+ Kind *string

+ Sleep Sleep

+ StoreImport RunStoreImport

+ func (r Runner) Validate() (ValidRunner, error)

+ type SlaveConnect struct

+ Slaves []SlaveConnectData

+ func (r SlaveConnect) Validate() (ValidSlaveConnect, error)

+ type SlaveConnectCertificate struct

+ CACert *string

+ Enabled bool

+ InsecureSkipVerify bool

+ ServerNameOverride string

+ func (c SlaveConnectCertificate) Validate() (ValidSlaveConnectCertificate, error)

+ type SlaveConnectData struct

+ Certificate SlaveConnectCertificate

+ Encrypt CredentialEncryptConfig

+ ID *string

+ URI *string

+ func (d SlaveConnectData) Validate() (ValidSlaveConnectData, error)

+ type SlaveRequestHandler struct

+ func NewSlaveRequestHandler(resChan <-chan *pb.ReceiveChanelConnectResponse, ...) *SlaveRequestHandler

+ func (rh *SlaveRequestHandler) HandleResponse(ctx context.Context, log logger.Logger, tmplFactor TmplFactor, ...) error

+ type Sleep struct

+ Enabled bool

+ Values []SleepValue

+ func (r Sleep) Validate() (ValidRunnerSleep, error)

+ type SleepValue struct

+ After *string

+ Duration *string

+ func (r SleepValue) Validate() (ValidRunnerSleepValue, error)

+ type SleepValueAfter string

+ const RunnerSleepValueAfterExec

+ const RunnerSleepValueAfterFailedExec

+ const RunnerSleepValueAfterInit

+ type Store interface

+ Import func(ctx context.Context, data []ValidStoreImportData, cb ImportCallback) error

+ Store func(ctx context.Context, data []ValidStoreValueData, cb StoreCallback) error

+ StoreWithExtractor func(ctx context.Context, res any, data []ValidExecRequestStoreData, ...) error

+ type StoreCallback func(ctx context.Context, data ValidStoreValueData, valBytes []byte) error

+ type StoreImport struct

+ Data []StoreImportData

+ func (r StoreImport) Validate() (ValidStoreImport, error)

+ type StoreImportData struct

+ BucketID *string

+ Encrypt CredentialEncryptConfig

+ Key *string

+ StoreKey *string

+ ThreadOnly bool

+ func (d StoreImportData) Validate() (ValidStoreImportData, error)

+ type StoreValue struct

+ Data []StoreValueData

+ func (r StoreValue) Validate() (ValidStoreValue, error)

+ type StoreValueData struct

+ BucketID *string

+ Encrypt CredentialEncryptConfig

+ Key *string

+ Value *any

+ func (d StoreValueData) Validate() (ValidStoreValueData, error)

+ type StoreWithExtractorCallback func(ctx context.Context, data ValidExecRequestStoreData, valBytes []byte) error

+ type TargetFactor interface

+ Factorize func(ctx context.Context, targetID string) (target.Target, error)

+ type TermChanType struct

+ func NewTermChanType(termType matcher.TerminateType, param string) TermChanType

+ type TmplFactor interface

+ TmplFactorize func(ctx context.Context, path string) (string, error)

+ type ValidCredentialEncryptConfig struct

+ Enabled bool

+ EncryptID string

+ type ValidExecRequestData struct

+ Extractor matcher.ValidDataExtractor

+ Key string

+ type ValidExecRequestDataSlice []ValidExecRequestData

+ func (s ValidExecRequestDataSlice) ExtractHeader() []string

+ type ValidExecRequestStoreData struct

+ BucketID string

+ Encrypt ValidCredentialEncryptConfig

+ Extractor matcher.ValidDataExtractor

+ StoreKey string

+ type ValidFlow struct

+ Step ValidFlowStep

+ func (f *ValidFlow) Run(ctx context.Context, env string, log logger.Logger, ...) error

+ type ValidFlowStep struct

+ Concurrency int

+ Flows []ValidFlowStepFlow

+ type ValidFlowStepFlow struct

+ Concurrency int

+ Count int

+ DependsOn []ValidFlowStepFlowDependsOn

+ Executors []ValidFlowStepFlowExecutor

+ File string

+ Flows []ValidFlowStepFlow

+ ID string

+ Mkdir bool

+ ThreadOnlyValues []ValidFlowStepFlowValue

+ Type FlowStepFlowType

+ Values []ValidFlowStepFlowValue

+ type ValidFlowStepFlowDependsOn struct

+ Event Event

+ Flow string

+ type ValidFlowStepFlowExecutor struct

+ AdditionalThreadOnlyValues []ValidFlowStepFlowValue

+ AdditionalValues []ValidFlowStepFlowValue

+ InheritValues bool

+ Output ValidFlowStepFlowExecutorOutput

+ SlaveID string

+ type ValidFlowStepFlowExecutorOutput struct

+ Enabled bool

+ RootPath string

+ type ValidFlowStepFlowValue struct

+ Key string

+ Value any

+ type ValidMassExec struct

+ Auth auth.SetAuthor

+ Output []output.Output

+ Requests []ValidMassExecRequest

+ Type MassExecType

+ func (r ValidMassExec) Run(ctx context.Context, log logger.Logger, outputRoot string, ...) error

+ type ValidMassExecRequest struct

+ AwaitPrevResp bool

+ Body any

+ BodyType HTTPRequestBodyType

+ Break ValidMassExecRequestBreak

+ Data ValidExecRequestDataSlice

+ Headers map[string]any

+ Interval time.Duration

+ Method string

+ PathVariables map[string]string

+ QueryParams map[string]any

+ RecordExcludeFilter ValidMassExecRequestRecordExcludeFilter

+ ReplaceData *sync.Map

+ ResponseType string

+ SuccessBreak matcher.TerminateTypeAndParamsSlice

+ TmplStr string

+ URL string

+ type ValidMassExecRequestBreak struct

+ Count httpexec.RequestCountLimit

+ ParseError bool

+ ResponseBodyMatcher matcher.BodyConditionsMatcher

+ StatusCodeMatcher matcher.StatusCodeConditionsMatcher

+ SysError bool

+ Time struct{ ... }

+ WriteError bool

+ type ValidMassExecRequestRecordExcludeFilter struct

+ CountFilter matcher.CountConditionsMatcher

+ ResponseBodyFilter matcher.BodyConditionsMatcher

+ StatusCodeFilter matcher.StatusCodeConditionsMatcher

+ type ValidMemoryValue struct

+ Data []ValidMemoryValueData

+ func (r ValidMemoryValue) Run(_ context.Context, store *sync.Map) error

+ type ValidMemoryValueData struct

+ Key string

+ Value any

+ type ValidOneExec struct

+ Auth auth.SetAuthor

+ Output []output.Output

+ Request ValidOneExecRequest

+ Type OneExecType

+ func (r ValidOneExec) Run(ctx context.Context, outputRoot string, str *sync.Map, log logger.Logger, ...) error

+ type ValidOneExecRequest struct

+ Body any

+ BodyType HTTPRequestBodyType

+ Data ValidExecRequestDataSlice

+ Headers map[string]any

+ MemoryData ValidExecRequestDataSlice

+ Method string

+ PathVariables map[string]string

+ QueryParam map[string]any

+ ResponseType string

+ StoreData []ValidExecRequestStoreData

+ URL string

+ type ValidRunner struct

+ Kind Kind

+ Sleep ValidRunnerSleep

+ StoreImport ValidRunnerStoreImport

+ func (r ValidRunner) RetrieveSleepValue(after SleepValueAfter) (time.Duration, bool)

+ type ValidRunnerSleep struct

+ Enabled bool

+ Values []ValidRunnerSleepValue

+ type ValidRunnerSleepValue struct

+ After SleepValueAfter

+ Duration time.Duration

+ type ValidRunnerStoreImport struct

+ Data []ValidStoreImportData

+ Enabled bool

+ type ValidSlaveConnect struct

+ Slaves []ValidSlaveConnectData

+ type ValidSlaveConnectCertificate struct

+ CACert string

+ Enabled bool

+ InsecureSkipVerify bool

+ ServerNameOverride string

+ type ValidSlaveConnectData struct

+ Certificate ValidSlaveConnectCertificate

+ Encrypt ValidCredentialEncryptConfig

+ ID string

+ URI string

+ type ValidStoreImport struct

+ Data []ValidStoreImportData

+ func (r ValidStoreImport) Run(ctx context.Context, str Store, store *sync.Map) error

+ type ValidStoreImportData struct

+ BucketID string

+ Encrypt ValidCredentialEncryptConfig

+ Key string

+ StoreKey string

+ ThreadOnly bool

+ type ValidStoreValue struct

+ Data []ValidStoreValueData

+ func (r ValidStoreValue) Run(ctx context.Context, str Store) error

+ type ValidStoreValueData struct

+ BucketID string

+ Encrypt ValidCredentialEncryptConfig

+ Key string

+ Value any

+ type WriteData struct

+ Count int

+ RawData any

+ ReceivedDatetime string

+ ResponseTime int

+ SendDatetime string

+ StatusCode string

+ Success bool

+ func (d WriteData) ToSlice() []string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL