mfgrc

package
v1.13.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 29, 2024 License: BSD-3-Clause Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	WORKER_MONOGROUP_STATUS_READY     = "monogroup.status.ready"
	WORKER_MONOGROUP_STATUS_PENDING   = "monogroup.status.pending"
	WORKER_MONOGROUP_STATUS_EXECUTING = "monogroup.status.executing"
	WORKER_MONOGROUP_STATUS_COMPLETE  = "monogroup.status.complete"
	WORKER_MONOGROUP_STATUS_FAILED    = "monogroup.status.failed"
)
View Source 
const (
	WORKER_MONO_STATUS_READY     = "mono.status.ready"
	WORKER_MONO_STATUS_PENDING   = "mono.status.pending"
	WORKER_MONO_STATUS_EXECUTING = "mono.status.executing"
	WORKER_MONO_STATUS_RETRYING  = "mono.status.retrying"
	WORKER_MONO_STATUS_COMPLETE  = "mono.status.complete"
	WORKER_MONO_STATUS_FAILED    = "mono.status.failed"
	WORKER_MONO_STATUS_REVOKE    = "mono.status.revoke"
	WORKER_MONO_STATUS_TIMEOUT   = "mono.status.timeout"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type MfgrcGroup added in v1.9.0 

type MfgrcGroup interface {
	structs.ZeroMetaDef

	XgroupId() string
	XuniqueCode() string
	Xoption() string
	Xmonos() []MfgrcMono

	State() string
	AddWorker(*ZeroMfgrcGroupWorker)

	Ready(ZeroMfgrcGroupStore) error
	Pending() error
	Executing() error
	Complete() error
	Failed(string) error

	Do() error
	Export() (map[string]interface{}, error)

	Store(ZeroMfgrcGroupStore)
	UseStore() ZeroMfgrcGroupStore
	EventListener(ZeroMfgrcGroupEventListener)
}

type MfgrcMono added in v1.9.0 

type MfgrcMono interface {
	structs.ZeroMetaDef

	XmonoId() string
	XuniqueCode() string
	Xoption() string
	Xprogress() int

	State() string

	Pending(*ZeroMfgrcFlux) error
	Revoke() error
	Timeout() error
	Executing() error
	Retrying(string) error
	Complete() error
	Failed(string) error

	Do() error
	Export() (map[string]interface{}, error)

	Store(ZeroMfgrcMonoStore)
	EventListener(ZeroMfgrcMonoEventListener)
}

type ZeroMfgrcFlux 

type ZeroMfgrcFlux struct {
	UniqueId string
	// contains filtered or unexported fields
}

func (*ZeroMfgrcFlux) Check added in v1.9.0 

func (flux *ZeroMfgrcFlux) Check(mono MfgrcMono) bool

func (*ZeroMfgrcFlux) Export added in v1.9.0 

func (flux *ZeroMfgrcFlux) Export() (map[string]interface{}, error)

func (*ZeroMfgrcFlux) Join added in v1.9.0 

func (flux *ZeroMfgrcFlux) Join(mono MfgrcMono, keeper *ZeroMfgrcKeeper) error

func (*ZeroMfgrcFlux) Push added in v1.9.0 

func (flux *ZeroMfgrcFlux) Push(mono MfgrcMono) error

func (*ZeroMfgrcFlux) Revoke added in v1.9.0 

func (flux *ZeroMfgrcFlux) Revoke(mono MfgrcMono) error

func (*ZeroMfgrcFlux) Start added in v1.9.0 

func (flux *ZeroMfgrcFlux) Start(worker *ZeroMfgrcWorker)

type ZeroMfgrcGroup added in v1.9.0 

type ZeroMfgrcGroup struct {
	structs.ZeroCoreStructs

	UniqueCode string `json:"uniqueCode,omitempty"`
	Option     string `json:"option,omitempty"`

	Monos []MfgrcMono `json:"monos,omitempty"`
	// contains filtered or unexported fields
}

func (*ZeroMfgrcGroup) AddWorker added in v1.9.0 

func (group *ZeroMfgrcGroup) AddWorker(worker *ZeroMfgrcGroupWorker)

func (*ZeroMfgrcGroup) Complete added in v1.9.0 

func (group *ZeroMfgrcGroup) Complete() error

func (*ZeroMfgrcGroup) Delete added in v1.9.0 

func (group *ZeroMfgrcGroup) Delete() error

func (*ZeroMfgrcGroup) Do added in v1.9.0 

func (group *ZeroMfgrcGroup) Do() error

func (*ZeroMfgrcGroup) EventListener added in v1.9.5 

func (group *ZeroMfgrcGroup) EventListener(xListener ZeroMfgrcGroupEventListener)

func (*ZeroMfgrcGroup) Executing added in v1.9.0 

func (group *ZeroMfgrcGroup) Executing() error

func (*ZeroMfgrcGroup) Export added in v1.9.0 

func (group *ZeroMfgrcGroup) Export() (map[string]interface{}, error)

func (*ZeroMfgrcGroup) Failed added in v1.9.0 

func (group *ZeroMfgrcGroup) Failed(reason string) error

func (*ZeroMfgrcGroup) LoadRowData added in v1.9.0 

func (group *ZeroMfgrcGroup) LoadRowData(rowmap map[string]interface{})

func (*ZeroMfgrcGroup) Pending added in v1.9.0 

func (group *ZeroMfgrcGroup) Pending() error

func (*ZeroMfgrcGroup) Ready added in v1.9.0 

func (group *ZeroMfgrcGroup) Ready(store ZeroMfgrcGroupStore) error

func (*ZeroMfgrcGroup) State added in v1.9.0 

func (group *ZeroMfgrcGroup) State() string

func (*ZeroMfgrcGroup) Store added in v1.9.0 

func (group *ZeroMfgrcGroup) Store(store ZeroMfgrcGroupStore)

func (*ZeroMfgrcGroup) UseStore added in v1.9.12 

func (group *ZeroMfgrcGroup) UseStore() ZeroMfgrcGroupStore

func (*ZeroMfgrcGroup) XgroupId added in v1.9.0 

func (group *ZeroMfgrcGroup) XgroupId() string

func (*ZeroMfgrcGroup) Xmonos added in v1.9.0 

func (group *ZeroMfgrcGroup) Xmonos() []MfgrcMono

func (*ZeroMfgrcGroup) Xoption added in v1.9.0 

func (group *ZeroMfgrcGroup) Xoption() string

func (*ZeroMfgrcGroup) XuniqueCode added in v1.9.0 

func (group *ZeroMfgrcGroup) XuniqueCode() string

type ZeroMfgrcGroupActuator added in v1.9.5 

type ZeroMfgrcGroupActuator struct {
	Keeper *ZeroMfgrcGroupKeeper
	// contains filtered or unexported fields
}

func (*ZeroMfgrcGroupActuator) Exec added in v1.9.5 

func (act *ZeroMfgrcGroupActuator) Exec(group MfgrcGroup) chan error

func (*ZeroMfgrcGroupActuator) Group added in v1.9.5 

func (act *ZeroMfgrcGroupActuator) Group() MfgrcGroup

func (*ZeroMfgrcGroupActuator) OnComplete added in v1.9.5 

func (act *ZeroMfgrcGroupActuator) OnComplete(MfgrcGroup) error

func (*ZeroMfgrcGroupActuator) OnExecuting added in v1.9.5 

func (_ *ZeroMfgrcGroupActuator) OnExecuting(MfgrcGroup) error

func (*ZeroMfgrcGroupActuator) OnFailed added in v1.9.5 

func (act *ZeroMfgrcGroupActuator) OnFailed(group MfgrcGroup, reason string) error

func (*ZeroMfgrcGroupActuator) OnPending added in v1.9.5 

func (_ *ZeroMfgrcGroupActuator) OnPending(MfgrcGroup) error

type ZeroMfgrcGroupEventListener added in v1.9.5 

type ZeroMfgrcGroupEventListener interface {
	OnPending(MfgrcGroup) error
	OnExecuting(MfgrcGroup) error
	OnComplete(MfgrcGroup) error
	OnFailed(MfgrcGroup, string) error
}

type ZeroMfgrcGroupKeeper added in v1.9.0 

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

func NewGroupKeeper added in v1.9.0 

func NewGroupKeeper(keeperName string, keeperOpts ZeroMfgrcGroupKeeperOpts, maxGroupQueues int) *ZeroMfgrcGroupKeeper

func (*ZeroMfgrcGroupKeeper) AddGroup added in v1.9.0 

func (keeper *ZeroMfgrcGroupKeeper) AddGroup(group MfgrcGroup) error

func (*ZeroMfgrcGroupKeeper) Check added in v1.9.0 

func (keeper *ZeroMfgrcGroupKeeper) Check(group MfgrcGroup) error

func (*ZeroMfgrcGroupKeeper) Export added in v1.9.0 

func (keeper *ZeroMfgrcGroupKeeper) Export() (map[string]interface{}, error)

func (*ZeroMfgrcGroupKeeper) RunGroupWorker added in v1.9.0 

func (keeper *ZeroMfgrcGroupKeeper) RunGroupWorker()

type ZeroMfgrcGroupKeeperOpts added in v1.9.0 

type ZeroMfgrcGroupKeeperOpts interface {
	FetchUncompleteGroups() ([]MfgrcGroup, error)
	MonoStore() ZeroMfgrcMonoStore
	GroupStore() ZeroMfgrcGroupStore
}

type ZeroMfgrcGroupStore added in v1.9.0 

type ZeroMfgrcGroupStore interface {
	UpdateGroup(MfgrcGroup) error
	DeleteGroup(MfgrcGroup) error
	AddGroupMono(MfgrcGroup, MfgrcMono) error
	MonoStore() ZeroMfgrcMonoStore
	NextSequence(string, string) (int, error)
}

type ZeroMfgrcGroupWorker added in v1.9.0 

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

func (*ZeroMfgrcGroupWorker) Export added in v1.9.0 

func (worker *ZeroMfgrcGroupWorker) Export() map[string]interface{}

func (*ZeroMfgrcGroupWorker) Start added in v1.9.0 

func (worker *ZeroMfgrcGroupWorker) Start()

func (*ZeroMfgrcGroupWorker) Stop added in v1.9.0 

func (worker *ZeroMfgrcGroupWorker) Stop()

type ZeroMfgrcKeeper added in v1.9.0 

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

func NewWorker added in v1.9.0 

func NewWorker(
	keeperName string,
	keeperOpts ZeroMfgrcKeeperOpts,
	maxQueues int,
	maxQueueLimit int,
	taskWaitSeconds int,
	taskIntervalSeconds int,
	taskRetryTimes int,
	taskRetryInterval int) *ZeroMfgrcKeeper

func (*ZeroMfgrcKeeper) AddMono added in v1.9.0 

func (keeper *ZeroMfgrcKeeper) AddMono(mono MfgrcMono) error

func (*ZeroMfgrcKeeper) AddMonosQueue added in v1.9.5 

func (keeper *ZeroMfgrcKeeper) AddMonosQueue(monos ...MfgrcMono) error

func (*ZeroMfgrcKeeper) Check added in v1.9.0 

func (keeper *ZeroMfgrcKeeper) Check(mono MfgrcMono) error

func (*ZeroMfgrcKeeper) Export added in v1.9.0 

func (keeper *ZeroMfgrcKeeper) Export() (map[string]interface{}, error)

func (*ZeroMfgrcKeeper) RevokeMono added in v1.9.0 

func (keeper *ZeroMfgrcKeeper) RevokeMono(mono MfgrcMono) error

func (*ZeroMfgrcKeeper) RunWorker added in v1.9.0 

func (keeper *ZeroMfgrcKeeper) RunWorker()

func (*ZeroMfgrcKeeper) ShutdownWorker added in v1.9.0 

func (keeper *ZeroMfgrcKeeper) ShutdownWorker()

func (*ZeroMfgrcKeeper) TaskWaitSeconds added in v1.12.25 

func (keeper *ZeroMfgrcKeeper) TaskWaitSeconds() int

type ZeroMfgrcKeeperOpts added in v1.9.0 

type ZeroMfgrcKeeperOpts interface {
	FetchUncompleteMonos() ([]MfgrcMono, error)
	DatebaseDatetime() (*time.Time, error)
	MonoStore() ZeroMfgrcMonoStore
}

type ZeroMfgrcMono 

type ZeroMfgrcMono struct {
	structs.ZeroCoreStructs

	MonoID     string `json:"monoID,omitempty"`
	UniqueCode string `json:"uniqueCode,omitempty"`
	Option     string `json:"option,omitempty"`

	Progress int `json:"progress,omitempty"`
	// contains filtered or unexported fields
}

func (*ZeroMfgrcMono) Complete added in v1.9.0 

func (mono *ZeroMfgrcMono) Complete() error

func (*ZeroMfgrcMono) Delete added in v1.9.0 

func (mono *ZeroMfgrcMono) Delete() error

func (*ZeroMfgrcMono) Do added in v1.9.0 

func (mono *ZeroMfgrcMono) Do() error

func (*ZeroMfgrcMono) EventListener added in v1.9.0 

func (mono *ZeroMfgrcMono) EventListener(eventListener ZeroMfgrcMonoEventListener)

func (*ZeroMfgrcMono) Executing added in v1.9.0 

func (mono *ZeroMfgrcMono) Executing() error

func (*ZeroMfgrcMono) Export added in v1.9.0 

func (mono *ZeroMfgrcMono) Export() (map[string]interface{}, error)

func (*ZeroMfgrcMono) Failed added in v1.9.0 

func (mono *ZeroMfgrcMono) Failed(reason string) error

func (*ZeroMfgrcMono) FromFlux added in v1.9.0 

func (mono *ZeroMfgrcMono) FromFlux() *ZeroMfgrcFlux

func (*ZeroMfgrcMono) LoadRowData added in v1.9.0 

func (mono *ZeroMfgrcMono) LoadRowData(rowmap map[string]interface{})

func (*ZeroMfgrcMono) Pending added in v1.9.0 

func (mono *ZeroMfgrcMono) Pending(flux *ZeroMfgrcFlux) error

func (*ZeroMfgrcMono) Ready added in v1.9.0 

func (mono *ZeroMfgrcMono) Ready(keeper *ZeroMfgrcKeeper, store ...ZeroMfgrcMonoStore) error

func (*ZeroMfgrcMono) Retrying added in v1.9.0 

func (mono *ZeroMfgrcMono) Retrying(reason string) error

func (*ZeroMfgrcMono) Revoke added in v1.9.0 

func (mono *ZeroMfgrcMono) Revoke() error

func (*ZeroMfgrcMono) State added in v1.9.0 

func (mono *ZeroMfgrcMono) State() string

func (*ZeroMfgrcMono) Store added in v1.9.0 

func (mono *ZeroMfgrcMono) Store(store ZeroMfgrcMonoStore)

func (*ZeroMfgrcMono) String added in v1.9.0 

func (mono *ZeroMfgrcMono) String() (string, error)

func (*ZeroMfgrcMono) Timeout added in v1.9.0 

func (mono *ZeroMfgrcMono) Timeout() error

func (*ZeroMfgrcMono) XmonoId added in v1.9.0 

func (mono *ZeroMfgrcMono) XmonoId() string

func (*ZeroMfgrcMono) Xoption added in v1.9.0 

func (mono *ZeroMfgrcMono) Xoption() string

func (*ZeroMfgrcMono) Xprogress added in v1.9.0 

func (mono *ZeroMfgrcMono) Xprogress() int

func (*ZeroMfgrcMono) XuniqueCode added in v1.9.0 

func (mono *ZeroMfgrcMono) XuniqueCode() string

type ZeroMfgrcMonoActuator added in v1.9.0 

type ZeroMfgrcMonoActuator struct {
	Keeper *ZeroMfgrcKeeper
	// contains filtered or unexported fields
}

func (*ZeroMfgrcMonoActuator) Exec added in v1.9.0 

func (act *ZeroMfgrcMonoActuator) Exec(mono MfgrcMono) chan error

func (*ZeroMfgrcMonoActuator) Mono added in v1.9.0 

func (act *ZeroMfgrcMonoActuator) Mono() MfgrcMono

func (*ZeroMfgrcMonoActuator) OnComplete added in v1.9.0 

func (act *ZeroMfgrcMonoActuator) OnComplete(MfgrcMono) error

func (*ZeroMfgrcMonoActuator) OnExecuting added in v1.9.0 

func (act *ZeroMfgrcMonoActuator) OnExecuting(MfgrcMono) error

func (*ZeroMfgrcMonoActuator) OnFailed added in v1.9.0 

func (act *ZeroMfgrcMonoActuator) OnFailed(mono MfgrcMono, reason string) error

func (*ZeroMfgrcMonoActuator) OnPending added in v1.9.0 

func (act *ZeroMfgrcMonoActuator) OnPending(MfgrcMono) error

func (*ZeroMfgrcMonoActuator) OnRetrying added in v1.9.0 

func (act *ZeroMfgrcMonoActuator) OnRetrying(MfgrcMono) error

func (*ZeroMfgrcMonoActuator) OnRevoke added in v1.9.0 

func (act *ZeroMfgrcMonoActuator) OnRevoke(mono MfgrcMono) error

type ZeroMfgrcMonoEventListener added in v1.9.0 

type ZeroMfgrcMonoEventListener interface {
	OnPending(MfgrcMono) error
	OnRevoke(MfgrcMono) error
	OnExecuting(MfgrcMono) error
	OnRetrying(MfgrcMono) error
	OnComplete(MfgrcMono) error
	OnFailed(MfgrcMono, string) error
}

type ZeroMfgrcMonoQueueActuator added in v1.9.7 

type ZeroMfgrcMonoQueueActuator struct {
	Keeper *ZeroMfgrcKeeper
	// contains filtered or unexported fields
}

func (*ZeroMfgrcMonoQueueActuator) Exec added in v1.9.7 

func (act *ZeroMfgrcMonoQueueActuator) Exec(monos ...MfgrcMono) chan error

func (*ZeroMfgrcMonoQueueActuator) Failed added in v1.9.7 

func (act *ZeroMfgrcMonoQueueActuator) Failed() int

func (*ZeroMfgrcMonoQueueActuator) OnComplete added in v1.9.7 

func (act *ZeroMfgrcMonoQueueActuator) OnComplete(mono MfgrcMono) error

func (*ZeroMfgrcMonoQueueActuator) OnExecuting added in v1.9.7 

func (act *ZeroMfgrcMonoQueueActuator) OnExecuting(MfgrcMono) error

func (*ZeroMfgrcMonoQueueActuator) OnFailed added in v1.9.7 

func (act *ZeroMfgrcMonoQueueActuator) OnFailed(mono MfgrcMono, reason string) error

func (*ZeroMfgrcMonoQueueActuator) OnPending added in v1.9.7 

func (act *ZeroMfgrcMonoQueueActuator) OnPending(MfgrcMono) error

func (*ZeroMfgrcMonoQueueActuator) OnRetrying added in v1.9.7 

func (act *ZeroMfgrcMonoQueueActuator) OnRetrying(MfgrcMono) error

func (*ZeroMfgrcMonoQueueActuator) OnRevoke added in v1.9.7 

func (act *ZeroMfgrcMonoQueueActuator) OnRevoke(mono MfgrcMono) error

func (*ZeroMfgrcMonoQueueActuator) Result added in v1.9.7 

func (act *ZeroMfgrcMonoQueueActuator) Result() map[string]string

func (*ZeroMfgrcMonoQueueActuator) Success added in v1.9.7 

func (act *ZeroMfgrcMonoQueueActuator) Success() int

type ZeroMfgrcMonoStore added in v1.9.0 

type ZeroMfgrcMonoStore interface {
	UpdateMono(MfgrcMono) error
	DeleteMono(MfgrcMono) error
}

type ZeroMfgrcWorker added in v1.9.0 

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

func (*ZeroMfgrcWorker) Export added in v1.9.0 

func (worker *ZeroMfgrcWorker) Export() map[string]interface{}

func (*ZeroMfgrcWorker) Start added in v1.9.0 

func (worker *ZeroMfgrcWorker) Start()

func (*ZeroMfgrcWorker) Stop added in v1.9.0 

func (worker *ZeroMfgrcWorker) Stop()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.