Documentation ¶
Index ¶
- type BnCoreGenServ
- type BnCoreSup
- type Follower
- func (s *Follower) HandleJobResult(process *gen.SagaProcess, id gen.SagaTransactionID, from gen.SagaJobID, ...) gen.SagaStatus
- func (s *Follower) HandleSagaInfo(process *gen.SagaProcess, message etf.Term) gen.ServerStatus
- func (s *Follower) HandleTxCancel(process *gen.SagaProcess, id gen.SagaTransactionID, reason string) gen.SagaStatus
- func (s *Follower) HandleTxDone(process *gen.SagaProcess, id gen.SagaTransactionID, result interface{}) (interface{}, gen.SagaStatus)
- func (s *Follower) HandleTxNew(process *gen.SagaProcess, id gen.SagaTransactionID, value interface{}) gen.SagaStatus
- func (s *Follower) HandleTxResult(process *gen.SagaProcess, id gen.SagaTransactionID, from gen.SagaNextID, ...) gen.SagaStatus
- func (s *Follower) InitSaga(process *gen.SagaProcess, args ...etf.Term) (gen.SagaOptions, error)
- type FollowerState
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BnCoreGenServ ¶
gen.Server implementation structure
func (*BnCoreGenServ) HandleCall ¶
func (dgs *BnCoreGenServ) HandleCall(process *gen.ServerProcess, from gen.ServerFrom, message etf.Term) (etf.Term, gen.ServerStatus)
func (*BnCoreGenServ) HandleCast ¶
func (dgs *BnCoreGenServ) HandleCast(process *gen.ServerProcess, message etf.Term) gen.ServerStatus
type BnCoreSup ¶
type BnCoreSup struct {
gen.Supervisor
}
type Follower ¶
Follower
func (*Follower) HandleJobResult ¶
func (s *Follower) HandleJobResult(process *gen.SagaProcess, id gen.SagaTransactionID, from gen.SagaJobID, result interface{}) gen.SagaStatus
func (*Follower) HandleSagaInfo ¶
func (s *Follower) HandleSagaInfo(process *gen.SagaProcess, message etf.Term) gen.ServerStatus
implement this method in order to trap TX cancelation and forward it to the Saga4
func (*Follower) HandleTxCancel ¶
func (s *Follower) HandleTxCancel(process *gen.SagaProcess, id gen.SagaTransactionID, reason string) gen.SagaStatus
func (*Follower) HandleTxDone ¶
func (s *Follower) HandleTxDone(process *gen.SagaProcess, id gen.SagaTransactionID, result interface{}) (interface{}, gen.SagaStatus)
func (*Follower) HandleTxNew ¶
func (s *Follower) HandleTxNew(process *gen.SagaProcess, id gen.SagaTransactionID, value interface{}) gen.SagaStatus
func (*Follower) HandleTxResult ¶
func (s *Follower) HandleTxResult(process *gen.SagaProcess, id gen.SagaTransactionID, from gen.SagaNextID, result interface{}) gen.SagaStatus
func (*Follower) InitSaga ¶
func (s *Follower) InitSaga(process *gen.SagaProcess, args ...etf.Term) (gen.SagaOptions, error)
type FollowerState ¶
type FollowerState struct {
// contains filtered or unexported fields
}
Source Files ¶
- blockchain.go
- blockchain_app.go
- blockchain_block.go
- blockchain_block_v1.go
- blockchain_election.go
- blockchain_event.go
- blockchain_follower.go
- blockchain_gateway_cache.go
- blockchain_hex.go
- blockchain_implicit_burn.go
- blockchain_json.go
- blockchain_lock.go
- blockchain_score_cache.go
- blockchain_sup.go
- blockchain_swarm.go
- blockchain_utils.go
- blockchain_worker.go
- bnGenServ.go
Click to show internal directories.
Click to hide internal directories.