pool

Jun 26, 2024

Changes in this version

+ const OpQueryArbitrary

type OperationSubscriber

+ func NewArbitraryOperationSubscriber(pool *Pool, tendermint *http.HTTP, log *logan.Entry) *OperationSubscriber

Apr 19, 2024

Changes in this version

+ const OpQueryCSCARootUpdate

type OperationSubscriber

+ func NewCSCARootUpdateOperationSubscriber(pool *Pool, tendermint *http.HTTP, log *logan.Entry) *OperationSubscriber

Dec 26, 2023

Changes in this version

+ const OpQueryWorldCoinIdentityTransfer

type OperationSubscriber

+ func NewWorldCoinIdentityTransferOperationSubscriber(pool *Pool, tendermint *http.HTTP, log *logan.Entry) *OperationSubscriber

Nov 24, 2023

Changes in this version

+ const OpQueryIdentityGISTTransfer

+ const OpQueryIdentityStateTransfer

type OperationSubscriber

+ func NewIdentityGISTTransferOperationSubscriber(pool *Pool, tendermint *http.HTTP, log *logan.Entry) *OperationSubscriber

+ func NewIdentityStateTransferOperationSubscriber(pool *Pool, tendermint *http.HTTP, log *logan.Entry) *OperationSubscriber

Oct 5, 2023

Changes in this version

+ const OpPoolSize

+ const OpQueryContractUpgrade

+ const OpQueryFeeManagement

+ const OpQueryIdentityAggregatedTransfer

+ const OpQueryIdentityDefaultTransfer

+ const OpQueryTransfer

+ const OpServiceName

+ var ErrOpShouldBeApproved = errors.New("operation should be approved")

+ type OperationCatchupper struct

+ func NewOperationCatchupper(pool *Pool, core *grpc.ClientConn, log *logan.Entry) *OperationCatchupper

+ func (o *OperationCatchupper) Run()

+ type OperationSubscriber struct

+ func NewContractUpgradeOperationSubscriber(pool *Pool, tendermint *http.HTTP, log *logan.Entry) *OperationSubscriber

+ func NewFeeManagementOperationSubscriber(pool *Pool, tendermint *http.HTTP, log *logan.Entry) *OperationSubscriber

+ func NewIdentityAggregatedTransferOperationSubscriber(pool *Pool, tendermint *http.HTTP, log *logan.Entry) *OperationSubscriber

+ func NewIdentityTransferOperationSubscriber(pool *Pool, tendermint *http.HTTP, log *logan.Entry) *OperationSubscriber

+ func NewTransferOperationSubscriber(pool *Pool, tendermint *http.HTTP, log *logan.Entry) *OperationSubscriber

+ func (o *OperationSubscriber) Run()

+ type Pool struct

+ func NewPool(cfg config.Config) *Pool

+ func (p *Pool) Add(id string) error

+ func (p *Pool) GetNext(n uint) ([]string, error)