Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

agency

package

Go to main page

Versions in this module

v1

v1.28.1

Apr 11, 2023

v1.28.0

Jan 19, 2023

Changes in this version

type Client

+ SubmitIBTPBatch func(from []string, index []uint64, serviceID []string, ibtpType []pb.IBTP_Type, ...) (*pb.SubmitIBTPResponse, error)

+ SubmitReceiptBatch func(to []string, index []uint64, serviceID []string, ibtpType []pb.IBTP_Type, ...) (*pb.SubmitIBTPResponse, error)

type TxOpt

+ Changer interface{}

v1.20.0

Jul 1, 2022

Changes in this version

+ var LicenseConstructorM = make(map[string]LicenseConstructor)

+ var OffchainTransmissionContructorM = make(map[string]OffchainTransmissionConstructor)

+ var OrderConstructorM = make(map[string]OrderConstructor)

+ func RegisterLicenseConstructor(typ string, f LicenseConstructor)

+ func RegisterOffchainTransmissionConstructor(typ string, f OffchainTransmissionConstructor)

+ func RegisterOrderConstructor(typ string, f OrderConstructor)

+ type Client interface

+ GetAppchainInfo func(chainID string) (string, []byte, string, error)

+ GetCallbackMeta func() (map[string]uint64, error)

+ GetChainID func() (string, string, error)

+ GetDirectTransactionMeta func(string) (uint64, uint64, uint64, error)

+ GetDstRollbackMeta func() (map[string]uint64, error)

+ GetIBTPCh func() chan *pb.IBTP

+ GetInMeta func() (map[string]uint64, error)

+ GetOffChainData func(request *pb.GetDataRequest) (*pb.GetDataResponse, error)

+ GetOffChainDataReq func() chan *pb.GetDataRequest

+ GetOutMessage func(servicePair string, idx uint64) (*pb.IBTP, error)

+ GetOutMeta func() (map[string]uint64, error)

+ GetReceiptMessage func(servicePair string, idx uint64) (*pb.IBTP, error)

+ GetServices func() ([]string, error)

+ GetUpdateMeta func() chan *pb.UpdateMeta

+ Initialize func(configPath string, extra []byte) error

+ Name func() string

+ Start func() error

+ Stop func() error

+ SubmitIBTP func(from string, index uint64, serviceID string, ibtpType pb.IBTP_Type, ...) (*pb.SubmitIBTPResponse, error)

+ SubmitOffChainData func(response *pb.GetDataResponse) error

+ SubmitReceipt func(to string, index uint64, serviceID string, ibtpType pb.IBTP_Type, ...) (*pb.SubmitIBTPResponse, error)

+ Type func() string

+ type ConfigOption interface

+ type DHTManager interface

+ FindProviders func(id string) (string, error)

+ Provider func(string, bool) error

+ type License interface

+ Verify func(licensePath string) error

+ type LicenseConstructor func(pubKey, verifier string) License

+ func GetLicenseConstructor(typ string) (LicenseConstructor, error)

+ type OffChainTransmission interface

+ Start func() error

+ Stop func() error

+ type OffchainTransmissionConstructor func(appchainID string, peerMgr PeerManager, client Client) OffChainTransmission

+ func GetOffchainTransmissionConstructor(typ string) (OffchainTransmissionConstructor, error)

+ type OrderConstructor func(opt ...order.Option) (order.Order, error)

+ func GetOrderConstructor(typ string) (OrderConstructor, error)

+ type PeerManager interface

+ AsyncSendWithStream func(network.Stream, *pb.Message) error

+ Connect func(info *peer.AddrInfo) (string, error)

+ ConnectedPeerIDs func() []string

+ RegisterConnectHandler func(func(string)) error

+ RegisterMsgHandler func(pb.Message_Type, func(network.Stream, *pb.Message)) error

+ RegisterMultiMsgHandler func([]pb.Message_Type, func(network.Stream, *pb.Message)) error

v1.3.0

Apr 26, 2021

v1.2.0

Apr 26, 2021

Changes in this version

+ var ContractConstructorM = make(map[string]*ContractInfo)

+ var PierHAConstructorM = make(map[string]PierHAConstructor)

+ var RegisterConstructorM = make(map[string]RegistryConstructor)

+ var TxsExecutorConstructorM = make(map[string]TxsExecutorConstructor)

+ func GetRegisteredContractInfo() map[string]*ContractInfo

+ func RegisterContractConstructor(name string, addr *types.Address, f ContractConstructor)

+ func RegisterExecutorConstructor(typ string, f TxsExecutorConstructor)

+ func RegisterPierHAConstructor(typ string, f PierHAConstructor)

+ func RegisterRegistryConstructor(typ string, f RegistryConstructor)

+ type ApplyTxFunc func(int, pb.Transaction, InvalidReason, *TxOpt) *pb.Receipt

+ type Contract interface

+ type ContractConstructor func() Contract

+ type ContractInfo struct

+ Constructor ContractConstructor

+ Name string

+ func GetContractInfo(addr *types.Address) (*ContractInfo, error)

+ type HAClient interface

+ CheckMasterPier func(address string) (*pb.Response, error)

+ HeartBeat func(address string, index string) (*pb.Response, error)

+ SetMasterPier func(address string, index string, timeout int64) (*pb.Response, error)

+ type InvalidReason string

+ type PierHA interface

+ IsMain func() <-chan bool

+ Start func() error

+ Stop func() error

+ type PierHAConstructor func(client HAClient, pierID string) PierHA

+ func GetPierHAConstructor(typ string) (PierHAConstructor, error)

+ type RegisterContractFunc func() map[string]Contract

+ type Registry interface

+ type RegistryConstructor func(storage.Storage, logrus.FieldLogger) Registry

+ func GetRegistryConstructor(typ string) (RegistryConstructor, error)

+ type TxOpt struct

+ Contracts map[string]Contract

+ type TxsExecutor interface

+ AddInterchainCounter func(to string, index uint64)

+ AddNormalTx func(hash *types.Hash)

+ ApplyTransactions func(txs []pb.Transaction, invalidTxs map[int]InvalidReason) []*pb.Receipt

+ GetBoltContracts func() map[string]Contract

+ GetDescription func() string

+ GetInterchainCounter func() map[string][]uint64

+ GetNormalTxs func() []*types.Hash

+ type TxsExecutorConstructor func(ApplyTxFunc, RegisterContractFunc, logrus.FieldLogger) TxsExecutor

+ func GetExecutorConstructor(typ string) (TxsExecutorConstructor, error)