actions

package

Go to main page

Versions in this module

v0

v0.6.3

Jun 26, 2021

v0.6.2

Jun 4, 2021

v0.6.1

Jun 2, 2021

v0.6.0

Jun 2, 2021

v0.5.1

Jun 2, 2021

v0.5.0

May 31, 2021

Changes in this version

type WorkerRequest

+ func NewWorker(name string, topic string, grp string, action Action) WorkerRequest

v0.4.9

May 31, 2021

v0.4.8

May 29, 2021

v0.4.7

May 29, 2021

v0.4.6

May 29, 2021

v0.4.5

May 29, 2021

v0.4.4

May 29, 2021

Changes in this version

type WorkRequest

+ Ctx context.Context

v0.4.3

May 22, 2021

v0.4.2

May 22, 2021

v0.4.1

May 22, 2021

v0.4.0

May 22, 2021

Changes in this version

+ const DefaultIdleness

+ const DefaultMaxWorkers

+ const DefaultMessageAcceptWait

+ const DefaultMessageBuffer

+ const DefaultMinWorkers

+ type Action interface

+ Do func(ctx context.Context, j Job)

+ type ActionFunc func(ctx context.Context, job Job)

+ func (a ActionFunc) Do(ctx context.Context, job Job)

+ type ActionHub struct

+ CancelFn context.CancelFunc

+ Context context.Context

+ EscalationFunc EscalationNotification

+ Injector *injectors.Injector

+ Logger sabuhp.Logger

+ Pubsub sabuhp.MessageBus

+ Relay *sabuhp.BusRelay

+ WorkRegistry *WorkerTemplateRegistry

+ func NewActionHub(ctx context.Context, escalationHandler EscalationNotification, ...) *ActionHub

+ func (ah *ActionHub) Do(actionName string, creator WorkGroupCreator, slaves ...SlaveWorkerRequest) error

+ func (ah *ActionHub) DoAlias(actionName string, pubsubTopic string, creator WorkGroupCreator, ...) error

+ func (ah *ActionHub) Start()

+ func (ah *ActionHub) Stats() []WorkerStat

+ func (ah *ActionHub) Stop()

+ func (ah *ActionHub) Wait()

+ type BehaviourType int

+ const DoNothing

+ const RestartAll

+ const RestartOne

+ const StopAllAndEscalate

+ type Escalation struct

+ Data interface{}

+ Err error

+ GroupProtocol EscalationProtocol

+ OffendingMessage *sabuhp.Message

+ PendingMessages chan *sabuhp.Message

+ WorkerProtocol WorkerProtocol

+ type EscalationNotification func(escalation Escalation, hub *ActionHub)

+ type EscalationProtocol int

+ const KillAndEscalateProtocol

+ const RestartProtocol

+ type InstanceType int

+ const NullInstance

+ const OneTimeInstance

+ const ScalingInstances

+ const SingleInstance

+ type Job struct

+ DI *injectors.Injector

+ Msg *sabuhp.Message

+ To string

+ Transport sabuhp.Transport

+ type MasterWorkerGroup struct

+ Master *WorkerGroup

+ Slaves map[string]*WorkerGroup

+ func (mg *MasterWorkerGroup) AddSlave(slave *WorkerGroup)

+ func (mg *MasterWorkerGroup) Start()

+ func (mg *MasterWorkerGroup) Stats() []WorkerStat

+ func (mg *MasterWorkerGroup) Stop()

+ type SlaveWorkerRequest struct

+ Action Action

+ ActionName string

+ GroupName string

+ MaxIdleness time.Duration

+ MaxWorkers int

+ MessageBufferSize int

+ MessageDeliveryWait time.Duration

+ MinWorker int

+ type WorkGroupCreator func(config WorkerConfig) *WorkerGroup

+ type WorkRequest struct

+ Message *sabuhp.Message

+ Transport sabuhp.Transport

+ type WorkerConfig struct

+ Action Action

+ ActionName string

+ Addr string

+ Behaviour BehaviourType

+ Context context.Context

+ EscalationNotification WorkerEscalationNotification

+ Injector *injectors.Injector

+ Instance InstanceType

+ MaxIdleness time.Duration

+ MaxWorkers int

+ MessageBufferSize int

+ MessageDeliveryWait time.Duration

+ MinWorker int

+ type WorkerEscalationNotification func(escalation *Escalation, wk *WorkerGroup)

+ type WorkerGroup struct

+ func NewWorkGroup(config WorkerConfig) *WorkerGroup

+ func (w *WorkerGroup) Ctx() context.Context

+ func (w *WorkerGroup) HandleMessage(message sabuhp.Message, t sabuhp.Transport) error

+ func (w *WorkerGroup) Start()

+ func (w *WorkerGroup) Stats() WorkerStat

+ func (w *WorkerGroup) Stop()

+ func (w *WorkerGroup) Wait()

+ func (w *WorkerGroup) WaitRestart()

+ type WorkerProtocol int

+ const PanicProtocol

+ type WorkerRequest struct

+ ActionName string

+ Err chan error

+ PubSubGroup string

+ PubSubTopic string

+ Slaves []SlaveWorkerRequest

+ WorkerCreator WorkGroupCreator

+ type WorkerStat struct

+ Addr string

+ AvailableWorkerCapacity int

+ BehaviourType BehaviourType

+ Instance InstanceType

+ MaxWorkers int

+ MinWorkers int

+ TotalCreatedWorkers int

+ TotalCurrentWorkers int

+ TotalEscalations int

+ TotalIdledWorkers int

+ TotalKilledWorkers int

+ TotalMessageProcessed int

+ TotalMessageReceived int

+ TotalPanics int

+ TotalRestarts int

+ func (w WorkerStat) EncodeObject(encoder npkg.ObjectEncoder)

+ type WorkerStats []WorkerStat

+ func (items WorkerStats) EncodeList(encoder npkg.ListEncoder)

+ type WorkerTemplateRegistry struct

+ func NewWorkerTemplateRegistry() *WorkerTemplateRegistry

+ func (ar *WorkerTemplateRegistry) Delete(actionName string)

+ func (ar *WorkerTemplateRegistry) Has(actionName string) bool

+ func (ar *WorkerTemplateRegistry) Register(template WorkerRequest)

+ func (ar *WorkerTemplateRegistry) Template(actionName string) WorkerRequest

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