types

package
v1.4.1 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2025 License: MIT Imports: 40 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EmptyTxOrigin                = "0x0000000000000000000000000000000000000000"
	MaxPoolParamsPerMsg          = 2 // Adjust this value based on your needs
	WaitForLastChunkSyncedSecond = 30
)
View Source 
const (
	// ModuleName defines the module name
	ModuleName = "restaking"

	// StoreKey defines the primary module store key
	StoreKey = ModuleName

	// RouterKey is the message route for slashing
	RouterKey = ModuleName

	// QuerierRoute defines the module's query routing key
	QuerierRoute = ModuleName

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_restaking"

	KeyOperatorShareStore          = "operator_share"
	KeyPrefixEpochSharesChange     = "epoch_shares_change"
	KeyPrefixEpochNumber           = "epoch_number"
	KeyBlocksPerEpoch              = "blocks_per_epoch"
	KeyPrefixOutboundState         = "outbound_state"
	KeyEpochOperatorSharesSyncTxs  = "epoch_operator_shares_sync_txs"
	KeyEpochOperatorSharesSnapshot = "epoch_operator_shares_snapshot"
	KeyOperator                    = "operator"

	GroupKey = "group_data"
)
View Source 
const SystemTxTypeSyncDelegationShares uint8 = 1

System tx type occupies the first byte (8 bits)

Variables

View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var (
	ErrInvalidLengthDelegation        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDelegation          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDelegation = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthEpochOutboundState        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEpochOutboundState          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEpochOutboundState = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthEpochs        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEpochs          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEpochs = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrABIPack                = cosmoserrors.Register(ModuleName, 1101, "abi pack error")
	ErrABIGet                 = cosmoserrors.Register(ModuleName, 1102, "abi get error")
	ErrABIUnpack              = cosmoserrors.Register(ModuleName, 1104, "abi unpack error")
	ErrContractNotFound       = cosmoserrors.Register(ModuleName, 1107, "contract not found")
	ErrContractCall           = cosmoserrors.Register(ModuleName, 1109, "contract call error")
	ErrSystemContractNotFound = cosmoserrors.Register(ModuleName, 1110, "system contract not found")
	ErrInvalidAddress         = cosmoserrors.Register(ModuleName, 1111, "invalid address")
	ErrStateVariableNotFound  = cosmoserrors.Register(ModuleName, 1112, "state variable not found")
	ErrEmitEvent              = cosmoserrors.Register(ModuleName, 1114, "emit event error")
	ErrInvalidDecimals        = cosmoserrors.Register(ModuleName, 1115, "invalid decimals")
	ErrInvalidGasLimit        = cosmoserrors.Register(ModuleName, 1118, "invalid gas limit")
	ErrSetBytecode            = cosmoserrors.Register(ModuleName, 1119, "set bytecode error")
	ErrInvalidContract        = cosmoserrors.Register(ModuleName, 1120, "invalid contract")
	ErrCallNonContract        = cosmoserrors.Register(ModuleName, 1124, "can't call a non-contract address")
	ErrNilGasPrice            = cosmoserrors.Register(ModuleName, 1127, "nil gas price")
	ErrCannotFindTSSKeys      = cosmoserrors.Register(ModuleName, 1122, "cannot find TSS keys")
	ErrInvalidData            = cosmoserrors.Register(ModuleName, 1123, "invalid data")
)

x/pevm module sentinel errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthGroup        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGroup          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGroup = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ModuleAddress = authtypes.NewModuleAddress(ModuleName)
	//ModuleAddressEVM common.EVMAddress
	ModuleAddressEVM = common.BytesToAddress(ModuleAddress.Bytes())
)
View Source 
var (
	ErrInvalidLengthOperator        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowOperator          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupOperator = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Msg_serviceDesc = _Msg_serviceDesc
View Source 
var OutboundStatus_name = map[int32]string{
	0: "OUTBOUND_STATUS_INITIALIZING",
	1: "OUTBOUND_STATUS_NORMAL",
	2: "OUTBOUND_STATUS_SYNCING",
}
View Source 
var OutboundStatus_value = map[string]int32{
	"OUTBOUND_STATUS_INITIALIZING": 0,
	"OUTBOUND_STATUS_NORMAL":       1,
	"OUTBOUND_STATUS_SYNCING":      2,
}
View Source 
var Query_serviceDesc = _Query_serviceDesc

Functions

func GroupDataKey 

func GroupDataKey(registryRouter common.Address) []byte

func GroupOperatorKey 

func GroupOperatorKey(registryRouter common.Address) []byte

func GroupSyncKey 

func GroupSyncKey(txHash string) []byte

func KeyPrefix 

func KeyPrefix(p string) []byte

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func RegistryRouterKey 

func RegistryRouterKey() []byte

func StakeRegistryRouterKey 

func StakeRegistryRouterKey(stakeRegistryRouter common.Address) []byte

func SupportedChainKey 

func SupportedChainKey(registryRouter common.Address) []byte

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(ctx context.Context, addr sdk.AccAddress) sdk.AccountI
	GetSequence(ctx context.Context, addr sdk.AccAddress) (uint64, error)
	GetModuleAccount(ctx context.Context, name string) sdk.ModuleAccountI
	HasAccount(ctx context.Context, addr sdk.AccAddress) bool
	NewAccountWithAddress(ctx context.Context, addr sdk.AccAddress) sdk.AccountI
	SetAccount(ctx context.Context, acc sdk.AccountI)
}

AccountKeeper defines the expected account keeper used for simulations (noalias)

type AuthorityKeeper 

type AuthorityKeeper interface {
	IsAuthorized(ctx sdk.Context, address string, policyType authoritytypes.PolicyType) bool
}

type BankKeeper 

type BankKeeper interface {
	SendCoinsFromModuleToAccount(ctx context.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
	MintCoins(ctx context.Context, moduleName string, amt sdk.Coins) error
}

type ChangedOperatorSharesSnapshot 

type ChangedOperatorSharesSnapshot struct {
	EpochNumber    uint64            `protobuf:"varint,1,opt,name=epoch_number,json=epochNumber,proto3" json:"epoch_number,omitempty"`
	OperatorShares []*OperatorShares `protobuf:"bytes,2,rep,name=operator_shares,json=operatorShares,proto3" json:"operator_shares,omitempty"`
}

ChangedOperatorSharesSnapshot is the snapshot of changed operator shares in an epoch

func (*ChangedOperatorSharesSnapshot) Descriptor 

func (*ChangedOperatorSharesSnapshot) Descriptor() ([]byte, []int)

func (*ChangedOperatorSharesSnapshot) GetEpochNumber 

func (m *ChangedOperatorSharesSnapshot) GetEpochNumber() uint64

func (*ChangedOperatorSharesSnapshot) GetOperatorShares 

func (m *ChangedOperatorSharesSnapshot) GetOperatorShares() []*OperatorShares

func (*ChangedOperatorSharesSnapshot) Marshal 

func (m *ChangedOperatorSharesSnapshot) Marshal() (dAtA []byte, err error)

func (*ChangedOperatorSharesSnapshot) MarshalTo 

func (m *ChangedOperatorSharesSnapshot) MarshalTo(dAtA []byte) (int, error)

func (*ChangedOperatorSharesSnapshot) MarshalToSizedBuffer 

func (m *ChangedOperatorSharesSnapshot) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ChangedOperatorSharesSnapshot) ProtoMessage 

func (*ChangedOperatorSharesSnapshot) ProtoMessage()

func (*ChangedOperatorSharesSnapshot) Reset 

func (m *ChangedOperatorSharesSnapshot) Reset()

func (*ChangedOperatorSharesSnapshot) Size 

func (m *ChangedOperatorSharesSnapshot) Size() (n int)

func (*ChangedOperatorSharesSnapshot) String 

func (m *ChangedOperatorSharesSnapshot) String() string

func (*ChangedOperatorSharesSnapshot) Unmarshal 

func (m *ChangedOperatorSharesSnapshot) Unmarshal(dAtA []byte) error

func (*ChangedOperatorSharesSnapshot) XXX_DiscardUnknown 

func (m *ChangedOperatorSharesSnapshot) XXX_DiscardUnknown()

func (*ChangedOperatorSharesSnapshot) XXX_Marshal 

func (m *ChangedOperatorSharesSnapshot) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ChangedOperatorSharesSnapshot) XXX_Merge 

func (m *ChangedOperatorSharesSnapshot) XXX_Merge(src proto.Message)

func (*ChangedOperatorSharesSnapshot) XXX_Size 

func (m *ChangedOperatorSharesSnapshot) XXX_Size() int

func (*ChangedOperatorSharesSnapshot) XXX_Unmarshal 

func (m *ChangedOperatorSharesSnapshot) XXX_Unmarshal(b []byte) error

type DVSInfo 

type DVSInfo struct {
	ChainId          uint64         `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	ServiceManager   string         `protobuf:"bytes,2,opt,name=service_manager,json=serviceManager,proto3" json:"service_manager,omitempty"`
	EjectionManager  string         `protobuf:"bytes,3,opt,name=ejection_manager,json=ejectionManager,proto3" json:"ejection_manager,omitempty"`
	CentralScheduler string         `protobuf:"bytes,4,opt,name=central_scheduler,json=centralScheduler,proto3" json:"central_scheduler,omitempty"`
	StakeManager     string         `protobuf:"bytes,5,opt,name=stake_manager,json=stakeManager,proto3" json:"stake_manager,omitempty"`
	BlsApkRegistry   string         `protobuf:"bytes,6,opt,name=bls_apk_registry,json=blsApkRegistry,proto3" json:"bls_apk_registry,omitempty"`
	IndexRegistry    string         `protobuf:"bytes,7,opt,name=index_registry,json=indexRegistry,proto3" json:"index_registry,omitempty"`
	OutboundState    OutboundStatus `` /* 131-byte string literal not displayed */
}

DVSInfo is the information of a DVS

func (*DVSInfo) Descriptor 

func (*DVSInfo) Descriptor() ([]byte, []int)

func (*DVSInfo) GetBlsApkRegistry 

func (m *DVSInfo) GetBlsApkRegistry() string

func (*DVSInfo) GetCentralScheduler 

func (m *DVSInfo) GetCentralScheduler() string

func (*DVSInfo) GetChainId 

func (m *DVSInfo) GetChainId() uint64

func (*DVSInfo) GetEjectionManager 

func (m *DVSInfo) GetEjectionManager() string

func (*DVSInfo) GetIndexRegistry 

func (m *DVSInfo) GetIndexRegistry() string

func (*DVSInfo) GetOutboundState 

func (m *DVSInfo) GetOutboundState() OutboundStatus

func (*DVSInfo) GetServiceManager 

func (m *DVSInfo) GetServiceManager() string

func (*DVSInfo) GetStakeManager 

func (m *DVSInfo) GetStakeManager() string

func (*DVSInfo) Marshal 

func (m *DVSInfo) Marshal() (dAtA []byte, err error)

func (*DVSInfo) MarshalTo 

func (m *DVSInfo) MarshalTo(dAtA []byte) (int, error)

func (*DVSInfo) MarshalToSizedBuffer 

func (m *DVSInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DVSInfo) ProtoMessage 

func (*DVSInfo) ProtoMessage()

func (*DVSInfo) Reset 

func (m *DVSInfo) Reset()

func (*DVSInfo) Size 

func (m *DVSInfo) Size() (n int)

func (*DVSInfo) String 

func (m *DVSInfo) String() string

func (*DVSInfo) Unmarshal 

func (m *DVSInfo) Unmarshal(dAtA []byte) error

func (*DVSInfo) XXX_DiscardUnknown 

func (m *DVSInfo) XXX_DiscardUnknown()

func (*DVSInfo) XXX_Marshal 

func (m *DVSInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DVSInfo) XXX_Merge 

func (m *DVSInfo) XXX_Merge(src proto.Message)

func (*DVSInfo) XXX_Size 

func (m *DVSInfo) XXX_Size() int

func (*DVSInfo) XXX_Unmarshal 

func (m *DVSInfo) XXX_Unmarshal(b []byte) error

type DVSInfoList 

type DVSInfoList struct {
	DvsInfos []*DVSInfo `protobuf:"bytes,1,rep,name=dvs_infos,json=dvsInfos,proto3" json:"dvs_infos,omitempty"`
}

DVSInfoList is a list of DVSInfo

func (*DVSInfoList) Descriptor 

func (*DVSInfoList) Descriptor() ([]byte, []int)

func (*DVSInfoList) GetDvsInfos 

func (m *DVSInfoList) GetDvsInfos() []*DVSInfo

func (*DVSInfoList) Marshal 

func (m *DVSInfoList) Marshal() (dAtA []byte, err error)

func (*DVSInfoList) MarshalTo 

func (m *DVSInfoList) MarshalTo(dAtA []byte) (int, error)

func (*DVSInfoList) MarshalToSizedBuffer 

func (m *DVSInfoList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DVSInfoList) ProtoMessage 

func (*DVSInfoList) ProtoMessage()

func (*DVSInfoList) Reset 

func (m *DVSInfoList) Reset()

func (*DVSInfoList) Size 

func (m *DVSInfoList) Size() (n int)

func (*DVSInfoList) String 

func (m *DVSInfoList) String() string

func (*DVSInfoList) Unmarshal 

func (m *DVSInfoList) Unmarshal(dAtA []byte) error

func (*DVSInfoList) XXX_DiscardUnknown 

func (m *DVSInfoList) XXX_DiscardUnknown()

func (*DVSInfoList) XXX_Marshal 

func (m *DVSInfoList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DVSInfoList) XXX_Merge 

func (m *DVSInfoList) XXX_Merge(src proto.Message)

func (*DVSInfoList) XXX_Size 

func (m *DVSInfoList) XXX_Size() int

func (*DVSInfoList) XXX_Unmarshal 

func (m *DVSInfoList) XXX_Unmarshal(b []byte) error

type EVMKeeper 

type EVMKeeper interface {
	ChainID() *big.Int
	GetBlockBloomTransient(ctx sdk.Context) *big.Int
	GetLogSizeTransient(ctx sdk.Context) uint64
	WithChainID(ctx sdk.Context)
	SetBlockBloomTransient(ctx sdk.Context, bloom *big.Int)
	SetLogSizeTransient(ctx sdk.Context, logSize uint64)
	EstimateGas(c context.Context, req *evmtypes.EthCallRequest) (*evmtypes.EstimateGasResponse, error)
	ApplyMessage(
		ctx sdk.Context,
		msg core.Message,
		tracer vm.EVMLogger,
		commit bool,
	) (*evmtypes.MsgEthereumTxResponse, error)
	GetAccount(ctx sdk.Context, addr ethcommon.Address) *statedb.Account
	GetCode(ctx sdk.Context, codeHash ethcommon.Hash) []byte
	SetAccount(ctx sdk.Context, addr ethcommon.Address, account statedb.Account) error
}

type EpochNumber 

type EpochNumber struct {
	EpochNumber uint64 `protobuf:"varint,1,opt,name=epoch_number,json=epochNumber,proto3" json:"epoch_number,omitempty"`
}

EpochNumber is the epoch number

func (*EpochNumber) Descriptor 

func (*EpochNumber) Descriptor() ([]byte, []int)

func (*EpochNumber) GetEpochNumber 

func (m *EpochNumber) GetEpochNumber() uint64

func (*EpochNumber) Marshal 

func (m *EpochNumber) Marshal() (dAtA []byte, err error)

func (*EpochNumber) MarshalTo 

func (m *EpochNumber) MarshalTo(dAtA []byte) (int, error)

func (*EpochNumber) MarshalToSizedBuffer 

func (m *EpochNumber) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EpochNumber) ProtoMessage 

func (*EpochNumber) ProtoMessage()

func (*EpochNumber) Reset 

func (m *EpochNumber) Reset()

func (*EpochNumber) Size 

func (m *EpochNumber) Size() (n int)

func (*EpochNumber) String 

func (m *EpochNumber) String() string

func (*EpochNumber) Unmarshal 

func (m *EpochNumber) Unmarshal(dAtA []byte) error

func (*EpochNumber) XXX_DiscardUnknown 

func (m *EpochNumber) XXX_DiscardUnknown()

func (*EpochNumber) XXX_Marshal 

func (m *EpochNumber) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EpochNumber) XXX_Merge 

func (m *EpochNumber) XXX_Merge(src proto.Message)

func (*EpochNumber) XXX_Size 

func (m *EpochNumber) XXX_Size() int

func (*EpochNumber) XXX_Unmarshal 

func (m *EpochNumber) XXX_Unmarshal(b []byte) error

type EpochOperatorSharesSyncTxs 

type EpochOperatorSharesSyncTxs struct {
	PendingXmsgIndexes []string `protobuf:"bytes,1,rep,name=pending_xmsg_indexes,json=pendingXmsgIndexes,proto3" json:"pending_xmsg_indexes,omitempty"`
}

EpochOperatorSharesSyncTxs represents a collection of outbound transactions that synchronize operator shares across chains during an epoch update. These transactions contain the pending cross-chain message indexes for operator shares synchronization.

func (*EpochOperatorSharesSyncTxs) Descriptor 

func (*EpochOperatorSharesSyncTxs) Descriptor() ([]byte, []int)

func (*EpochOperatorSharesSyncTxs) GetPendingXmsgIndexes 

func (m *EpochOperatorSharesSyncTxs) GetPendingXmsgIndexes() []string

func (*EpochOperatorSharesSyncTxs) Marshal 

func (m *EpochOperatorSharesSyncTxs) Marshal() (dAtA []byte, err error)

func (*EpochOperatorSharesSyncTxs) MarshalTo 

func (m *EpochOperatorSharesSyncTxs) MarshalTo(dAtA []byte) (int, error)

func (*EpochOperatorSharesSyncTxs) MarshalToSizedBuffer 

func (m *EpochOperatorSharesSyncTxs) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EpochOperatorSharesSyncTxs) ProtoMessage 

func (*EpochOperatorSharesSyncTxs) ProtoMessage()

func (*EpochOperatorSharesSyncTxs) Reset 

func (m *EpochOperatorSharesSyncTxs) Reset()

func (*EpochOperatorSharesSyncTxs) Size 

func (m *EpochOperatorSharesSyncTxs) Size() (n int)

func (*EpochOperatorSharesSyncTxs) String 

func (m *EpochOperatorSharesSyncTxs) String() string

func (*EpochOperatorSharesSyncTxs) Unmarshal 

func (m *EpochOperatorSharesSyncTxs) Unmarshal(dAtA []byte) error

func (*EpochOperatorSharesSyncTxs) XXX_DiscardUnknown 

func (m *EpochOperatorSharesSyncTxs) XXX_DiscardUnknown()

func (*EpochOperatorSharesSyncTxs) XXX_Marshal 

func (m *EpochOperatorSharesSyncTxs) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EpochOperatorSharesSyncTxs) XXX_Merge 

func (m *EpochOperatorSharesSyncTxs) XXX_Merge(src proto.Message)

func (*EpochOperatorSharesSyncTxs) XXX_Size 

func (m *EpochOperatorSharesSyncTxs) XXX_Size() int

func (*EpochOperatorSharesSyncTxs) XXX_Unmarshal 

func (m *EpochOperatorSharesSyncTxs) XXX_Unmarshal(b []byte) error

type EpochOutboundState 

type EpochOutboundState struct {
	ChainId        uint64         `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	OutboundStatus OutboundStatus `` /* 134-byte string literal not displayed */
	EpochNumber    uint64         `protobuf:"varint,3,opt,name=epoch_number,json=epochNumber,proto3" json:"epoch_number,omitempty"`
}

EpochOutboundState represents the outbound state of a chain

func (*EpochOutboundState) Descriptor 

func (*EpochOutboundState) Descriptor() ([]byte, []int)

func (*EpochOutboundState) GetChainId 

func (m *EpochOutboundState) GetChainId() uint64

func (*EpochOutboundState) GetEpochNumber 

func (m *EpochOutboundState) GetEpochNumber() uint64

func (*EpochOutboundState) GetOutboundStatus 

func (m *EpochOutboundState) GetOutboundStatus() OutboundStatus

func (*EpochOutboundState) Marshal 

func (m *EpochOutboundState) Marshal() (dAtA []byte, err error)

func (*EpochOutboundState) MarshalTo 

func (m *EpochOutboundState) MarshalTo(dAtA []byte) (int, error)

func (*EpochOutboundState) MarshalToSizedBuffer 

func (m *EpochOutboundState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EpochOutboundState) ProtoMessage 

func (*EpochOutboundState) ProtoMessage()

func (*EpochOutboundState) Reset 

func (m *EpochOutboundState) Reset()

func (*EpochOutboundState) Size 

func (m *EpochOutboundState) Size() (n int)

func (*EpochOutboundState) String 

func (m *EpochOutboundState) String() string

func (*EpochOutboundState) Unmarshal 

func (m *EpochOutboundState) Unmarshal(dAtA []byte) error

func (*EpochOutboundState) XXX_DiscardUnknown 

func (m *EpochOutboundState) XXX_DiscardUnknown()

func (*EpochOutboundState) XXX_Marshal 

func (m *EpochOutboundState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EpochOutboundState) XXX_Merge 

func (m *EpochOutboundState) XXX_Merge(src proto.Message)

func (*EpochOutboundState) XXX_Size 

func (m *EpochOutboundState) XXX_Size() int

func (*EpochOutboundState) XXX_Unmarshal 

func (m *EpochOutboundState) XXX_Unmarshal(b []byte) error

type EventHandler 

type EventHandler interface {
	// HandleEvent handles the event
	HandleEvent(ctx sdk.Context, epochNum uint64, emittingContractAddr ethcommon.Address, logs []*ethtypes.Log, txOrigin string) ([]*xmsgtypes.CrossChainFee, error)
	// GetContractAddress returns the contract address filter for the event handler
	GetContractAddress(ctx sdk.Context) (ethcommon.Address, error)
	// ParseEvent parses the event from the log
	ParseEvent(contractAddr ethcommon.Address, log *ethtypes.Log) (interface{}, error)
}

// EventHandler is an interface for handling pell evm events. internal handlers are

type G1Point 

type G1Point struct {
	X uint64 `protobuf:"varint,1,opt,name=x,proto3" json:"x,omitempty"`
	Y uint64 `protobuf:"varint,2,opt,name=y,proto3" json:"y,omitempty"`
}

G1Point represents a point on the BN254 curve

func (*G1Point) Descriptor 

func (*G1Point) Descriptor() ([]byte, []int)

func (*G1Point) GetX 

func (m *G1Point) GetX() uint64

func (*G1Point) GetY 

func (m *G1Point) GetY() uint64

func (*G1Point) Marshal 

func (m *G1Point) Marshal() (dAtA []byte, err error)

func (*G1Point) MarshalTo 

func (m *G1Point) MarshalTo(dAtA []byte) (int, error)

func (*G1Point) MarshalToSizedBuffer 

func (m *G1Point) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*G1Point) ProtoMessage 

func (*G1Point) ProtoMessage()

func (*G1Point) Reset 

func (m *G1Point) Reset()

func (*G1Point) Size 

func (m *G1Point) Size() (n int)

func (*G1Point) String 

func (m *G1Point) String() string

func (*G1Point) Unmarshal 

func (m *G1Point) Unmarshal(dAtA []byte) error

func (*G1Point) XXX_DiscardUnknown 

func (m *G1Point) XXX_DiscardUnknown()

func (*G1Point) XXX_Marshal 

func (m *G1Point) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*G1Point) XXX_Merge 

func (m *G1Point) XXX_Merge(src proto.Message)

func (*G1Point) XXX_Size 

func (m *G1Point) XXX_Size() int

func (*G1Point) XXX_Unmarshal 

func (m *G1Point) XXX_Unmarshal(b []byte) error

type G1PointV2 

type G1PointV2 struct {
	X cosmossdk_io_math.Int `protobuf:"bytes,1,opt,name=x,proto3,customtype=cosmossdk.io/math.Int" json:"x"`
	Y cosmossdk_io_math.Int `protobuf:"bytes,2,opt,name=y,proto3,customtype=cosmossdk.io/math.Int" json:"y"`
}

G1Point represents a point on the BN254 curve

func (*G1PointV2) Descriptor 

func (*G1PointV2) Descriptor() ([]byte, []int)

func (*G1PointV2) Marshal 

func (m *G1PointV2) Marshal() (dAtA []byte, err error)

func (*G1PointV2) MarshalTo 

func (m *G1PointV2) MarshalTo(dAtA []byte) (int, error)

func (*G1PointV2) MarshalToSizedBuffer 

func (m *G1PointV2) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*G1PointV2) ProtoMessage 

func (*G1PointV2) ProtoMessage()

func (*G1PointV2) Reset 

func (m *G1PointV2) Reset()

func (*G1PointV2) Size 

func (m *G1PointV2) Size() (n int)

func (*G1PointV2) String 

func (m *G1PointV2) String() string

func (*G1PointV2) Unmarshal 

func (m *G1PointV2) Unmarshal(dAtA []byte) error

func (*G1PointV2) XXX_DiscardUnknown 

func (m *G1PointV2) XXX_DiscardUnknown()

func (*G1PointV2) XXX_Marshal 

func (m *G1PointV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*G1PointV2) XXX_Merge 

func (m *G1PointV2) XXX_Merge(src proto.Message)

func (*G1PointV2) XXX_Size 

func (m *G1PointV2) XXX_Size() int

func (*G1PointV2) XXX_Unmarshal 

func (m *G1PointV2) XXX_Unmarshal(b []byte) error

type G2Point 

type G2Point struct {
	X []uint64 `protobuf:"varint,1,rep,packed,name=x,proto3" json:"x,omitempty"`
	Y []uint64 `protobuf:"varint,2,rep,packed,name=y,proto3" json:"y,omitempty"`
}

G2Point represents a point on the BN254 curve, with field elements encoded as arrays

func (*G2Point) Descriptor 

func (*G2Point) Descriptor() ([]byte, []int)

func (*G2Point) GetX 

func (m *G2Point) GetX() []uint64

func (*G2Point) GetY 

func (m *G2Point) GetY() []uint64

func (*G2Point) Marshal 

func (m *G2Point) Marshal() (dAtA []byte, err error)

func (*G2Point) MarshalTo 

func (m *G2Point) MarshalTo(dAtA []byte) (int, error)

func (*G2Point) MarshalToSizedBuffer 

func (m *G2Point) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*G2Point) ProtoMessage 

func (*G2Point) ProtoMessage()

func (*G2Point) Reset 

func (m *G2Point) Reset()

func (*G2Point) Size 

func (m *G2Point) Size() (n int)

func (*G2Point) String 

func (m *G2Point) String() string

func (*G2Point) Unmarshal 

func (m *G2Point) Unmarshal(dAtA []byte) error

func (*G2Point) XXX_DiscardUnknown 

func (m *G2Point) XXX_DiscardUnknown()

func (*G2Point) XXX_Marshal 

func (m *G2Point) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*G2Point) XXX_Merge 

func (m *G2Point) XXX_Merge(src proto.Message)

func (*G2Point) XXX_Size 

func (m *G2Point) XXX_Size() int

func (*G2Point) XXX_Unmarshal 

func (m *G2Point) XXX_Unmarshal(b []byte) error

type G2PointV2 

type G2PointV2 struct {
	X []cosmossdk_io_math.Int `protobuf:"bytes,1,rep,name=x,proto3,customtype=cosmossdk.io/math.Int" json:"x"`
	Y []cosmossdk_io_math.Int `protobuf:"bytes,2,rep,name=y,proto3,customtype=cosmossdk.io/math.Int" json:"y"`
}

G2Point represents a point on the BN254 curve, with field elements encoded as arrays

func (*G2PointV2) Descriptor 

func (*G2PointV2) Descriptor() ([]byte, []int)

func (*G2PointV2) Marshal 

func (m *G2PointV2) Marshal() (dAtA []byte, err error)

func (*G2PointV2) MarshalTo 

func (m *G2PointV2) MarshalTo(dAtA []byte) (int, error)

func (*G2PointV2) MarshalToSizedBuffer 

func (m *G2PointV2) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*G2PointV2) ProtoMessage 

func (*G2PointV2) ProtoMessage()

func (*G2PointV2) Reset 

func (m *G2PointV2) Reset()

func (*G2PointV2) Size 

func (m *G2PointV2) Size() (n int)

func (*G2PointV2) String 

func (m *G2PointV2) String() string

func (*G2PointV2) Unmarshal 

func (m *G2PointV2) Unmarshal(dAtA []byte) error

func (*G2PointV2) XXX_DiscardUnknown 

func (m *G2PointV2) XXX_DiscardUnknown()

func (*G2PointV2) XXX_Marshal 

func (m *G2PointV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*G2PointV2) XXX_Merge 

func (m *G2PointV2) XXX_Merge(src proto.Message)

func (*G2PointV2) XXX_Size 

func (m *G2PointV2) XXX_Size() int

func (*G2PointV2) XXX_Unmarshal 

func (m *G2PointV2) XXX_Unmarshal(b []byte) error

type GenesisState 

type GenesisState struct {
	OperatorShare      []OperatorShares     `protobuf:"bytes,1,rep,name=operator_share,json=operatorShare,proto3" json:"operator_share"`
	RegistryRouterData []RegistryRouterData `protobuf:"bytes,2,rep,name=registry_router_data,json=registryRouterData,proto3" json:"registry_router_data"`
}

GenesisState defines the pevm module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default pevm genesis state

func GetGenesisStateFromAppState 

func GetGenesisStateFromAppState(marshaler codec.JSONCodec, appState map[string]json.RawMessage) GenesisState

func (*GenesisState) Descriptor 

func (*GenesisState) Descriptor() ([]byte, []int)

func (*GenesisState) GetOperatorShare 

func (m *GenesisState) GetOperatorShare() []OperatorShares

func (*GenesisState) GetRegistryRouterData 

func (m *GenesisState) GetRegistryRouterData() []RegistryRouterData

func (*GenesisState) Marshal 

func (m *GenesisState) Marshal() (dAtA []byte, err error)

func (*GenesisState) MarshalTo 

func (m *GenesisState) MarshalTo(dAtA []byte) (int, error)

func (*GenesisState) MarshalToSizedBuffer 

func (m *GenesisState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

func (m *GenesisState) Size() (n int)

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

func (m *GenesisState) Unmarshal(dAtA []byte) error

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any failure.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

func (m *GenesisState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisState) XXX_Merge 

func (m *GenesisState) XXX_Merge(src proto.Message)

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

func (m *GenesisState) XXX_Unmarshal(b []byte) error

type GenesisStateLegacy 

type GenesisStateLegacy struct {
	Params        Params           `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	OperatorShare []OperatorShares `protobuf:"bytes,2,rep,name=operator_share,json=operatorShare,proto3" json:"operator_share"`
}

Genesis state legacy

func GetGenesisStateFromAppStateLegacy 

func GetGenesisStateFromAppStateLegacy(marshaler codec.JSONCodec, appState map[string]json.RawMessage) GenesisStateLegacy

func (*GenesisStateLegacy) Descriptor 

func (*GenesisStateLegacy) Descriptor() ([]byte, []int)

func (*GenesisStateLegacy) GetOperatorShare 

func (m *GenesisStateLegacy) GetOperatorShare() []OperatorShares

func (*GenesisStateLegacy) GetParams 

func (m *GenesisStateLegacy) GetParams() Params

func (*GenesisStateLegacy) Marshal 

func (m *GenesisStateLegacy) Marshal() (dAtA []byte, err error)

func (*GenesisStateLegacy) MarshalTo 

func (m *GenesisStateLegacy) MarshalTo(dAtA []byte) (int, error)

func (*GenesisStateLegacy) MarshalToSizedBuffer 

func (m *GenesisStateLegacy) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GenesisStateLegacy) ProtoMessage 

func (*GenesisStateLegacy) ProtoMessage()

func (*GenesisStateLegacy) Reset 

func (m *GenesisStateLegacy) Reset()

func (*GenesisStateLegacy) Size 

func (m *GenesisStateLegacy) Size() (n int)

func (*GenesisStateLegacy) String 

func (m *GenesisStateLegacy) String() string

func (*GenesisStateLegacy) Unmarshal 

func (m *GenesisStateLegacy) Unmarshal(dAtA []byte) error

func (*GenesisStateLegacy) XXX_DiscardUnknown 

func (m *GenesisStateLegacy) XXX_DiscardUnknown()

func (*GenesisStateLegacy) XXX_Marshal 

func (m *GenesisStateLegacy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GenesisStateLegacy) XXX_Merge 

func (m *GenesisStateLegacy) XXX_Merge(src proto.Message)

func (*GenesisStateLegacy) XXX_Size 

func (m *GenesisStateLegacy) XXX_Size() int

func (*GenesisStateLegacy) XXX_Unmarshal 

func (m *GenesisStateLegacy) XXX_Unmarshal(b []byte) error

type Group 

type Group struct {
	GroupNumber        uint64              `protobuf:"varint,1,opt,name=group_number,json=groupNumber,proto3" json:"group_number,omitempty"`
	OperatorSetParam   *OperatorSetParam   `protobuf:"bytes,2,opt,name=operator_set_param,json=operatorSetParam,proto3" json:"operator_set_param,omitempty"`
	MinimumStake       uint64              `protobuf:"varint,3,opt,name=minimum_stake,json=minimumStake,proto3" json:"minimum_stake,omitempty"`
	PoolParams         []*PoolParams       `protobuf:"bytes,4,rep,name=pool_params,json=poolParams,proto3" json:"pool_params,omitempty"`
	GroupEjectionParam *GroupEjectionParam `protobuf:"bytes,5,opt,name=group_ejection_param,json=groupEjectionParam,proto3" json:"group_ejection_param,omitempty"`
}

Group represents the group configuration

func (*Group) Descriptor 

func (*Group) Descriptor() ([]byte, []int)

func (*Group) GetGroupEjectionParam 

func (m *Group) GetGroupEjectionParam() *GroupEjectionParam

func (*Group) GetGroupNumber 

func (m *Group) GetGroupNumber() uint64

func (*Group) GetMinimumStake 

func (m *Group) GetMinimumStake() uint64

func (*Group) GetOperatorSetParam 

func (m *Group) GetOperatorSetParam() *OperatorSetParam

func (*Group) GetPoolParams 

func (m *Group) GetPoolParams() []*PoolParams

func (*Group) Marshal 

func (m *Group) Marshal() (dAtA []byte, err error)

func (*Group) MarshalTo 

func (m *Group) MarshalTo(dAtA []byte) (int, error)

func (*Group) MarshalToSizedBuffer 

func (m *Group) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Group) ProtoMessage 

func (*Group) ProtoMessage()

func (*Group) Reset 

func (m *Group) Reset()

func (*Group) Size 

func (m *Group) Size() (n int)

func (*Group) String 

func (m *Group) String() string

func (*Group) Unmarshal 

func (m *Group) Unmarshal(dAtA []byte) error

func (*Group) XXX_DiscardUnknown 

func (m *Group) XXX_DiscardUnknown()

func (*Group) XXX_Marshal 

func (m *Group) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Group) XXX_Merge 

func (m *Group) XXX_Merge(src proto.Message)

func (*Group) XXX_Size 

func (m *Group) XXX_Size() int

func (*Group) XXX_Unmarshal 

func (m *Group) XXX_Unmarshal(b []byte) error

type GroupEjectionParam 

type GroupEjectionParam struct {
	RateLimitWindow       uint32 `protobuf:"varint,1,opt,name=rate_limit_window,json=rateLimitWindow,proto3" json:"rate_limit_window,omitempty"`
	EjectableStakePercent uint32 `` /* 127-byte string literal not displayed */
}

GroupEjectionParam defines the parameters for group ejection

func (*GroupEjectionParam) Descriptor 

func (*GroupEjectionParam) Descriptor() ([]byte, []int)

func (*GroupEjectionParam) GetEjectableStakePercent 

func (m *GroupEjectionParam) GetEjectableStakePercent() uint32

func (*GroupEjectionParam) GetRateLimitWindow 

func (m *GroupEjectionParam) GetRateLimitWindow() uint32

func (*GroupEjectionParam) Marshal 

func (m *GroupEjectionParam) Marshal() (dAtA []byte, err error)

func (*GroupEjectionParam) MarshalTo 

func (m *GroupEjectionParam) MarshalTo(dAtA []byte) (int, error)

func (*GroupEjectionParam) MarshalToSizedBuffer 

func (m *GroupEjectionParam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GroupEjectionParam) ProtoMessage 

func (*GroupEjectionParam) ProtoMessage()

func (*GroupEjectionParam) Reset 

func (m *GroupEjectionParam) Reset()

func (*GroupEjectionParam) Size 

func (m *GroupEjectionParam) Size() (n int)

func (*GroupEjectionParam) String 

func (m *GroupEjectionParam) String() string

func (*GroupEjectionParam) Unmarshal 

func (m *GroupEjectionParam) Unmarshal(dAtA []byte) error

func (*GroupEjectionParam) XXX_DiscardUnknown 

func (m *GroupEjectionParam) XXX_DiscardUnknown()

func (*GroupEjectionParam) XXX_Marshal 

func (m *GroupEjectionParam) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupEjectionParam) XXX_Merge 

func (m *GroupEjectionParam) XXX_Merge(src proto.Message)

func (*GroupEjectionParam) XXX_Size 

func (m *GroupEjectionParam) XXX_Size() int

func (*GroupEjectionParam) XXX_Unmarshal 

func (m *GroupEjectionParam) XXX_Unmarshal(b []byte) error

type GroupList 

type GroupList struct {
	Groups []*Group `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
}

GroupList is a list of groups

func (*GroupList) Descriptor 

func (*GroupList) Descriptor() ([]byte, []int)

func (*GroupList) GetGroups 

func (m *GroupList) GetGroups() []*Group

func (*GroupList) Marshal 

func (m *GroupList) Marshal() (dAtA []byte, err error)

func (*GroupList) MarshalTo 

func (m *GroupList) MarshalTo(dAtA []byte) (int, error)

func (*GroupList) MarshalToSizedBuffer 

func (m *GroupList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GroupList) ProtoMessage 

func (*GroupList) ProtoMessage()

func (*GroupList) Reset 

func (m *GroupList) Reset()

func (*GroupList) Size 

func (m *GroupList) Size() (n int)

func (*GroupList) String 

func (m *GroupList) String() string

func (*GroupList) Unmarshal 

func (m *GroupList) Unmarshal(dAtA []byte) error

func (*GroupList) XXX_DiscardUnknown 

func (m *GroupList) XXX_DiscardUnknown()

func (*GroupList) XXX_Marshal 

func (m *GroupList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupList) XXX_Merge 

func (m *GroupList) XXX_Merge(src proto.Message)

func (*GroupList) XXX_Size 

func (m *GroupList) XXX_Size() int

func (*GroupList) XXX_Unmarshal 

func (m *GroupList) XXX_Unmarshal(b []byte) error

type GroupOperatorRegistration 

type GroupOperatorRegistration struct {
	Operator     string                    `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	OperatorId   []byte                    `protobuf:"bytes,2,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
	GroupNumbers []byte                    `protobuf:"bytes,3,opt,name=group_numbers,json=groupNumbers,proto3" json:"group_numbers,omitempty"`
	Socket       string                    `protobuf:"bytes,4,opt,name=socket,proto3" json:"socket,omitempty"`
	PubkeyParams *PubkeyRegistrationParams `protobuf:"bytes,5,opt,name=pubkey_params,json=pubkeyParams,proto3" json:"pubkey_params,omitempty"`
}

OperatorRegisteredInfo represents the information of an operator registration

func (*GroupOperatorRegistration) Descriptor 

func (*GroupOperatorRegistration) Descriptor() ([]byte, []int)

func (*GroupOperatorRegistration) GetGroupNumbers 

func (m *GroupOperatorRegistration) GetGroupNumbers() []byte

func (*GroupOperatorRegistration) GetOperator 

func (m *GroupOperatorRegistration) GetOperator() string

func (*GroupOperatorRegistration) GetOperatorId 

func (m *GroupOperatorRegistration) GetOperatorId() []byte

func (*GroupOperatorRegistration) GetPubkeyParams 

func (m *GroupOperatorRegistration) GetPubkeyParams() *PubkeyRegistrationParams

func (*GroupOperatorRegistration) GetSocket 

func (m *GroupOperatorRegistration) GetSocket() string

func (*GroupOperatorRegistration) Marshal 

func (m *GroupOperatorRegistration) Marshal() (dAtA []byte, err error)

func (*GroupOperatorRegistration) MarshalTo 

func (m *GroupOperatorRegistration) MarshalTo(dAtA []byte) (int, error)

func (*GroupOperatorRegistration) MarshalToSizedBuffer 

func (m *GroupOperatorRegistration) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GroupOperatorRegistration) ProtoMessage 

func (*GroupOperatorRegistration) ProtoMessage()

func (*GroupOperatorRegistration) Reset 

func (m *GroupOperatorRegistration) Reset()

func (*GroupOperatorRegistration) Size 

func (m *GroupOperatorRegistration) Size() (n int)

func (*GroupOperatorRegistration) String 

func (m *GroupOperatorRegistration) String() string

func (*GroupOperatorRegistration) Unmarshal 

func (m *GroupOperatorRegistration) Unmarshal(dAtA []byte) error

func (*GroupOperatorRegistration) XXX_DiscardUnknown 

func (m *GroupOperatorRegistration) XXX_DiscardUnknown()

func (*GroupOperatorRegistration) XXX_Marshal 

func (m *GroupOperatorRegistration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupOperatorRegistration) XXX_Merge 

func (m *GroupOperatorRegistration) XXX_Merge(src proto.Message)

func (*GroupOperatorRegistration) XXX_Size 

func (m *GroupOperatorRegistration) XXX_Size() int

func (*GroupOperatorRegistration) XXX_Unmarshal 

func (m *GroupOperatorRegistration) XXX_Unmarshal(b []byte) error

type GroupOperatorRegistrationList 

type GroupOperatorRegistrationList struct {
	OperatorRegisteredInfos []*GroupOperatorRegistration `` /* 132-byte string literal not displayed */
}

GroupOperatorRegistrationList is a list of quorum operator registration

func (*GroupOperatorRegistrationList) Descriptor 

func (*GroupOperatorRegistrationList) Descriptor() ([]byte, []int)

func (*GroupOperatorRegistrationList) GetOperatorRegisteredInfos 

func (m *GroupOperatorRegistrationList) GetOperatorRegisteredInfos() []*GroupOperatorRegistration

func (*GroupOperatorRegistrationList) Marshal 

func (m *GroupOperatorRegistrationList) Marshal() (dAtA []byte, err error)

func (*GroupOperatorRegistrationList) MarshalTo 

func (m *GroupOperatorRegistrationList) MarshalTo(dAtA []byte) (int, error)

func (*GroupOperatorRegistrationList) MarshalToSizedBuffer 

func (m *GroupOperatorRegistrationList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GroupOperatorRegistrationList) ProtoMessage 

func (*GroupOperatorRegistrationList) ProtoMessage()

func (*GroupOperatorRegistrationList) Reset 

func (m *GroupOperatorRegistrationList) Reset()

func (*GroupOperatorRegistrationList) Size 

func (m *GroupOperatorRegistrationList) Size() (n int)

func (*GroupOperatorRegistrationList) String 

func (m *GroupOperatorRegistrationList) String() string

func (*GroupOperatorRegistrationList) Unmarshal 

func (m *GroupOperatorRegistrationList) Unmarshal(dAtA []byte) error

func (*GroupOperatorRegistrationList) XXX_DiscardUnknown 

func (m *GroupOperatorRegistrationList) XXX_DiscardUnknown()

func (*GroupOperatorRegistrationList) XXX_Marshal 

func (m *GroupOperatorRegistrationList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupOperatorRegistrationList) XXX_Merge 

func (m *GroupOperatorRegistrationList) XXX_Merge(src proto.Message)

func (*GroupOperatorRegistrationList) XXX_Size 

func (m *GroupOperatorRegistrationList) XXX_Size() int

func (*GroupOperatorRegistrationList) XXX_Unmarshal 

func (m *GroupOperatorRegistrationList) XXX_Unmarshal(b []byte) error

type GroupOperatorRegistrationListV2 

type GroupOperatorRegistrationListV2 struct {
	OperatorRegisteredInfos []*GroupOperatorRegistrationV2 `` /* 132-byte string literal not displayed */
}

GroupOperatorRegistrationListV2 is a list of quorum operator registration

func (*GroupOperatorRegistrationListV2) Descriptor 

func (*GroupOperatorRegistrationListV2) Descriptor() ([]byte, []int)

func (*GroupOperatorRegistrationListV2) GetOperatorRegisteredInfos 

func (m *GroupOperatorRegistrationListV2) GetOperatorRegisteredInfos() []*GroupOperatorRegistrationV2

func (*GroupOperatorRegistrationListV2) Marshal 

func (m *GroupOperatorRegistrationListV2) Marshal() (dAtA []byte, err error)

func (*GroupOperatorRegistrationListV2) MarshalTo 

func (m *GroupOperatorRegistrationListV2) MarshalTo(dAtA []byte) (int, error)

func (*GroupOperatorRegistrationListV2) MarshalToSizedBuffer 

func (m *GroupOperatorRegistrationListV2) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GroupOperatorRegistrationListV2) ProtoMessage 

func (*GroupOperatorRegistrationListV2) ProtoMessage()

func (*GroupOperatorRegistrationListV2) Reset 

func (m *GroupOperatorRegistrationListV2) Reset()

func (*GroupOperatorRegistrationListV2) Size 

func (m *GroupOperatorRegistrationListV2) Size() (n int)

func (*GroupOperatorRegistrationListV2) String 

func (m *GroupOperatorRegistrationListV2) String() string

func (*GroupOperatorRegistrationListV2) Unmarshal 

func (m *GroupOperatorRegistrationListV2) Unmarshal(dAtA []byte) error

func (*GroupOperatorRegistrationListV2) XXX_DiscardUnknown 

func (m *GroupOperatorRegistrationListV2) XXX_DiscardUnknown()

func (*GroupOperatorRegistrationListV2) XXX_Marshal 

func (m *GroupOperatorRegistrationListV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupOperatorRegistrationListV2) XXX_Merge 

func (m *GroupOperatorRegistrationListV2) XXX_Merge(src proto.Message)

func (*GroupOperatorRegistrationListV2) XXX_Size 

func (m *GroupOperatorRegistrationListV2) XXX_Size() int

func (*GroupOperatorRegistrationListV2) XXX_Unmarshal 

func (m *GroupOperatorRegistrationListV2) XXX_Unmarshal(b []byte) error

type GroupOperatorRegistrationV2 

type GroupOperatorRegistrationV2 struct {
	Operator     string                      `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	OperatorId   []byte                      `protobuf:"bytes,2,opt,name=operator_id,json=operatorId,proto3" json:"operator_id,omitempty"`
	GroupNumbers []byte                      `protobuf:"bytes,3,opt,name=group_numbers,json=groupNumbers,proto3" json:"group_numbers,omitempty"`
	Socket       string                      `protobuf:"bytes,4,opt,name=socket,proto3" json:"socket,omitempty"`
	PubkeyParams *PubkeyRegistrationParamsV2 `protobuf:"bytes,5,opt,name=pubkey_params,json=pubkeyParams,proto3" json:"pubkey_params,omitempty"`
}

OperatorRegisteredInfoV2 represents the information of an operator registration

func (*GroupOperatorRegistrationV2) Descriptor 

func (*GroupOperatorRegistrationV2) Descriptor() ([]byte, []int)

func (*GroupOperatorRegistrationV2) GetGroupNumbers 

func (m *GroupOperatorRegistrationV2) GetGroupNumbers() []byte

func (*GroupOperatorRegistrationV2) GetOperator 

func (m *GroupOperatorRegistrationV2) GetOperator() string

func (*GroupOperatorRegistrationV2) GetOperatorId 

func (m *GroupOperatorRegistrationV2) GetOperatorId() []byte

func (*GroupOperatorRegistrationV2) GetPubkeyParams 

func (m *GroupOperatorRegistrationV2) GetPubkeyParams() *PubkeyRegistrationParamsV2

func (*GroupOperatorRegistrationV2) GetSocket 

func (m *GroupOperatorRegistrationV2) GetSocket() string

func (*GroupOperatorRegistrationV2) Marshal 

func (m *GroupOperatorRegistrationV2) Marshal() (dAtA []byte, err error)

func (*GroupOperatorRegistrationV2) MarshalTo 

func (m *GroupOperatorRegistrationV2) MarshalTo(dAtA []byte) (int, error)

func (*GroupOperatorRegistrationV2) MarshalToSizedBuffer 

func (m *GroupOperatorRegistrationV2) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GroupOperatorRegistrationV2) ProtoMessage 

func (*GroupOperatorRegistrationV2) ProtoMessage()

func (*GroupOperatorRegistrationV2) Reset 

func (m *GroupOperatorRegistrationV2) Reset()

func (*GroupOperatorRegistrationV2) Size 

func (m *GroupOperatorRegistrationV2) Size() (n int)

func (*GroupOperatorRegistrationV2) String 

func (m *GroupOperatorRegistrationV2) String() string

func (*GroupOperatorRegistrationV2) Unmarshal 

func (m *GroupOperatorRegistrationV2) Unmarshal(dAtA []byte) error

func (*GroupOperatorRegistrationV2) XXX_DiscardUnknown 

func (m *GroupOperatorRegistrationV2) XXX_DiscardUnknown()

func (*GroupOperatorRegistrationV2) XXX_Marshal 

func (m *GroupOperatorRegistrationV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupOperatorRegistrationV2) XXX_Merge 

func (m *GroupOperatorRegistrationV2) XXX_Merge(src proto.Message)

func (*GroupOperatorRegistrationV2) XXX_Size 

func (m *GroupOperatorRegistrationV2) XXX_Size() int

func (*GroupOperatorRegistrationV2) XXX_Unmarshal 

func (m *GroupOperatorRegistrationV2) XXX_Unmarshal(b []byte) error

type GroupSyncList 

type GroupSyncList struct {
	XmsgIndex []string `protobuf:"bytes,1,rep,name=xmsg_index,json=xmsgIndex,proto3" json:"xmsg_index,omitempty"`
}

GroupSyncList is a list of quorum sync xmsg index

func (*GroupSyncList) Descriptor 

func (*GroupSyncList) Descriptor() ([]byte, []int)

func (*GroupSyncList) GetXmsgIndex 

func (m *GroupSyncList) GetXmsgIndex() []string

func (*GroupSyncList) Marshal 

func (m *GroupSyncList) Marshal() (dAtA []byte, err error)

func (*GroupSyncList) MarshalTo 

func (m *GroupSyncList) MarshalTo(dAtA []byte) (int, error)

func (*GroupSyncList) MarshalToSizedBuffer 

func (m *GroupSyncList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GroupSyncList) ProtoMessage 

func (*GroupSyncList) ProtoMessage()

func (*GroupSyncList) Reset 

func (m *GroupSyncList) Reset()

func (*GroupSyncList) Size 

func (m *GroupSyncList) Size() (n int)

func (*GroupSyncList) String 

func (m *GroupSyncList) String() string

func (*GroupSyncList) Unmarshal 

func (m *GroupSyncList) Unmarshal(dAtA []byte) error

func (*GroupSyncList) XXX_DiscardUnknown 

func (m *GroupSyncList) XXX_DiscardUnknown()

func (*GroupSyncList) XXX_Marshal 

func (m *GroupSyncList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GroupSyncList) XXX_Merge 

func (m *GroupSyncList) XXX_Merge(src proto.Message)

func (*GroupSyncList) XXX_Size 

func (m *GroupSyncList) XXX_Size() int

func (*GroupSyncList) XXX_Unmarshal 

func (m *GroupSyncList) XXX_Unmarshal(b []byte) error

type MiddlewareEventSubscriber 

type MiddlewareEventSubscriber interface {
	// ProcessLogs parse event and builds the pell sent event from the middleware event
	ProcessLogs(ctx sdk.Context, _ uint64, toAddress ethcommon.Address, log *ethtypes.Log, txOrigin string) (*sdkmath.Int, error)
}

MiddlewareEventSubscriber is an interface for handling middleware events

type MsgClient 

type MsgClient interface {
	// upsert outbound state
	UpsertOutboundState(ctx context.Context, in *MsgUpsertOutboundState, opts ...grpc.CallOption) (*MsgUpsertOutboundStateResponse, error)
	// update blocks per epoch
	UpdateBlocksPerEpoch(ctx context.Context, in *MsgUpdateBlocksPerEpoch, opts ...grpc.CallOption) (*MsgUpdateBlocksPerEpochResponse, error)
}

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgServer 

type MsgServer interface {
	// upsert outbound state
	UpsertOutboundState(context.Context, *MsgUpsertOutboundState) (*MsgUpsertOutboundStateResponse, error)
	// update blocks per epoch
	UpdateBlocksPerEpoch(context.Context, *MsgUpdateBlocksPerEpoch) (*MsgUpdateBlocksPerEpochResponse, error)
}

MsgServer is the server API for Msg service.

type MsgUpdateBlocksPerEpoch 

type MsgUpdateBlocksPerEpoch struct {
	Signer         string `protobuf:"bytes,1,opt,name=signer,proto3" json:"signer,omitempty"`
	BlocksPerEpoch uint64 `protobuf:"varint,2,opt,name=blocks_per_epoch,json=blocksPerEpoch,proto3" json:"blocks_per_epoch,omitempty"`
}

update blocks per epoch

func (*MsgUpdateBlocksPerEpoch) Descriptor 

func (*MsgUpdateBlocksPerEpoch) Descriptor() ([]byte, []int)

func (*MsgUpdateBlocksPerEpoch) GetBlocksPerEpoch 

func (m *MsgUpdateBlocksPerEpoch) GetBlocksPerEpoch() uint64

func (*MsgUpdateBlocksPerEpoch) GetSigner 

func (m *MsgUpdateBlocksPerEpoch) GetSigner() string

func (*MsgUpdateBlocksPerEpoch) Marshal 

func (m *MsgUpdateBlocksPerEpoch) Marshal() (dAtA []byte, err error)

func (*MsgUpdateBlocksPerEpoch) MarshalTo 

func (m *MsgUpdateBlocksPerEpoch) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateBlocksPerEpoch) MarshalToSizedBuffer 

func (m *MsgUpdateBlocksPerEpoch) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateBlocksPerEpoch) ProtoMessage 

func (*MsgUpdateBlocksPerEpoch) ProtoMessage()

func (*MsgUpdateBlocksPerEpoch) Reset 

func (m *MsgUpdateBlocksPerEpoch) Reset()

func (*MsgUpdateBlocksPerEpoch) Size 

func (m *MsgUpdateBlocksPerEpoch) Size() (n int)

func (*MsgUpdateBlocksPerEpoch) String 

func (m *MsgUpdateBlocksPerEpoch) String() string

func (*MsgUpdateBlocksPerEpoch) Unmarshal 

func (m *MsgUpdateBlocksPerEpoch) Unmarshal(dAtA []byte) error

func (*MsgUpdateBlocksPerEpoch) XXX_DiscardUnknown 

func (m *MsgUpdateBlocksPerEpoch) XXX_DiscardUnknown()

func (*MsgUpdateBlocksPerEpoch) XXX_Marshal 

func (m *MsgUpdateBlocksPerEpoch) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateBlocksPerEpoch) XXX_Merge 

func (m *MsgUpdateBlocksPerEpoch) XXX_Merge(src proto.Message)

func (*MsgUpdateBlocksPerEpoch) XXX_Size 

func (m *MsgUpdateBlocksPerEpoch) XXX_Size() int

func (*MsgUpdateBlocksPerEpoch) XXX_Unmarshal 

func (m *MsgUpdateBlocksPerEpoch) XXX_Unmarshal(b []byte) error

type MsgUpdateBlocksPerEpochResponse 

type MsgUpdateBlocksPerEpochResponse struct {
}

update blocks per epoch response

func (*MsgUpdateBlocksPerEpochResponse) Descriptor 

func (*MsgUpdateBlocksPerEpochResponse) Descriptor() ([]byte, []int)

func (*MsgUpdateBlocksPerEpochResponse) Marshal 

func (m *MsgUpdateBlocksPerEpochResponse) Marshal() (dAtA []byte, err error)

func (*MsgUpdateBlocksPerEpochResponse) MarshalTo 

func (m *MsgUpdateBlocksPerEpochResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpdateBlocksPerEpochResponse) MarshalToSizedBuffer 

func (m *MsgUpdateBlocksPerEpochResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpdateBlocksPerEpochResponse) ProtoMessage 

func (*MsgUpdateBlocksPerEpochResponse) ProtoMessage()

func (*MsgUpdateBlocksPerEpochResponse) Reset 

func (m *MsgUpdateBlocksPerEpochResponse) Reset()

func (*MsgUpdateBlocksPerEpochResponse) Size 

func (m *MsgUpdateBlocksPerEpochResponse) Size() (n int)

func (*MsgUpdateBlocksPerEpochResponse) String 

func (m *MsgUpdateBlocksPerEpochResponse) String() string

func (*MsgUpdateBlocksPerEpochResponse) Unmarshal 

func (m *MsgUpdateBlocksPerEpochResponse) Unmarshal(dAtA []byte) error

func (*MsgUpdateBlocksPerEpochResponse) XXX_DiscardUnknown 

func (m *MsgUpdateBlocksPerEpochResponse) XXX_DiscardUnknown()

func (*MsgUpdateBlocksPerEpochResponse) XXX_Marshal 

func (m *MsgUpdateBlocksPerEpochResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpdateBlocksPerEpochResponse) XXX_Merge 

func (m *MsgUpdateBlocksPerEpochResponse) XXX_Merge(src proto.Message)

func (*MsgUpdateBlocksPerEpochResponse) XXX_Size 

func (m *MsgUpdateBlocksPerEpochResponse) XXX_Size() int

func (*MsgUpdateBlocksPerEpochResponse) XXX_Unmarshal 

func (m *MsgUpdateBlocksPerEpochResponse) XXX_Unmarshal(b []byte) error

type MsgUpsertOutboundState 

type MsgUpsertOutboundState struct {
	Signer        string              `protobuf:"bytes,1,opt,name=signer,proto3" json:"signer,omitempty"`
	OutboundState *EpochOutboundState `protobuf:"bytes,2,opt,name=outbound_state,json=outboundState,proto3" json:"outbound_state,omitempty"`
}

upsert outbound state

func (*MsgUpsertOutboundState) Descriptor 

func (*MsgUpsertOutboundState) Descriptor() ([]byte, []int)

func (*MsgUpsertOutboundState) GetOutboundState 

func (m *MsgUpsertOutboundState) GetOutboundState() *EpochOutboundState

func (*MsgUpsertOutboundState) GetSigner 

func (m *MsgUpsertOutboundState) GetSigner() string

func (*MsgUpsertOutboundState) Marshal 

func (m *MsgUpsertOutboundState) Marshal() (dAtA []byte, err error)

func (*MsgUpsertOutboundState) MarshalTo 

func (m *MsgUpsertOutboundState) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpsertOutboundState) MarshalToSizedBuffer 

func (m *MsgUpsertOutboundState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpsertOutboundState) ProtoMessage 

func (*MsgUpsertOutboundState) ProtoMessage()

func (*MsgUpsertOutboundState) Reset 

func (m *MsgUpsertOutboundState) Reset()

func (*MsgUpsertOutboundState) Size 

func (m *MsgUpsertOutboundState) Size() (n int)

func (*MsgUpsertOutboundState) String 

func (m *MsgUpsertOutboundState) String() string

func (*MsgUpsertOutboundState) Unmarshal 

func (m *MsgUpsertOutboundState) Unmarshal(dAtA []byte) error

func (*MsgUpsertOutboundState) XXX_DiscardUnknown 

func (m *MsgUpsertOutboundState) XXX_DiscardUnknown()

func (*MsgUpsertOutboundState) XXX_Marshal 

func (m *MsgUpsertOutboundState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpsertOutboundState) XXX_Merge 

func (m *MsgUpsertOutboundState) XXX_Merge(src proto.Message)

func (*MsgUpsertOutboundState) XXX_Size 

func (m *MsgUpsertOutboundState) XXX_Size() int

func (*MsgUpsertOutboundState) XXX_Unmarshal 

func (m *MsgUpsertOutboundState) XXX_Unmarshal(b []byte) error

type MsgUpsertOutboundStateResponse 

type MsgUpsertOutboundStateResponse struct {
}

upsert outbound state response

func (*MsgUpsertOutboundStateResponse) Descriptor 

func (*MsgUpsertOutboundStateResponse) Descriptor() ([]byte, []int)

func (*MsgUpsertOutboundStateResponse) Marshal 

func (m *MsgUpsertOutboundStateResponse) Marshal() (dAtA []byte, err error)

func (*MsgUpsertOutboundStateResponse) MarshalTo 

func (m *MsgUpsertOutboundStateResponse) MarshalTo(dAtA []byte) (int, error)

func (*MsgUpsertOutboundStateResponse) MarshalToSizedBuffer 

func (m *MsgUpsertOutboundStateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MsgUpsertOutboundStateResponse) ProtoMessage 

func (*MsgUpsertOutboundStateResponse) ProtoMessage()

func (*MsgUpsertOutboundStateResponse) Reset 

func (m *MsgUpsertOutboundStateResponse) Reset()

func (*MsgUpsertOutboundStateResponse) Size 

func (m *MsgUpsertOutboundStateResponse) Size() (n int)

func (*MsgUpsertOutboundStateResponse) String 

func (m *MsgUpsertOutboundStateResponse) String() string

func (*MsgUpsertOutboundStateResponse) Unmarshal 

func (m *MsgUpsertOutboundStateResponse) Unmarshal(dAtA []byte) error

func (*MsgUpsertOutboundStateResponse) XXX_DiscardUnknown 

func (m *MsgUpsertOutboundStateResponse) XXX_DiscardUnknown()

func (*MsgUpsertOutboundStateResponse) XXX_Marshal 

func (m *MsgUpsertOutboundStateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MsgUpsertOutboundStateResponse) XXX_Merge 

func (m *MsgUpsertOutboundStateResponse) XXX_Merge(src proto.Message)

func (*MsgUpsertOutboundStateResponse) XXX_Size 

func (m *MsgUpsertOutboundStateResponse) XXX_Size() int

func (*MsgUpsertOutboundStateResponse) XXX_Unmarshal 

func (m *MsgUpsertOutboundStateResponse) XXX_Unmarshal(b []byte) error

type Operator 

type Operator struct {
	// operator address
	Operator string `protobuf:"bytes,1,opt,name=operator,proto3" json:"operator,omitempty"`
	// delegation approver address
	DelegationApprover string `protobuf:"bytes,2,opt,name=delegation_approver,json=delegationApprover,proto3" json:"delegation_approver,omitempty"`
	// staker opt out window
	StakerOptOutWindow uint32 `protobuf:"varint,3,opt,name=staker_opt_out_window,json=stakerOptOutWindow,proto3" json:"staker_opt_out_window,omitempty"`
}

Operator is the delegation operator information

func (*Operator) Descriptor 

func (*Operator) Descriptor() ([]byte, []int)

func (*Operator) GetDelegationApprover 

func (m *Operator) GetDelegationApprover() string

func (*Operator) GetOperator 

func (m *Operator) GetOperator() string

func (*Operator) GetStakerOptOutWindow 

func (m *Operator) GetStakerOptOutWindow() uint32

func (*Operator) Marshal 

func (m *Operator) Marshal() (dAtA []byte, err error)

func (*Operator) MarshalTo 

func (m *Operator) MarshalTo(dAtA []byte) (int, error)

func (*Operator) MarshalToSizedBuffer 

func (m *Operator) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Operator) ProtoMessage 

func (*Operator) ProtoMessage()

func (*Operator) Reset 

func (m *Operator) Reset()

func (*Operator) Size 

func (m *Operator) Size() (n int)

func (*Operator) String 

func (m *Operator) String() string

func (*Operator) Unmarshal 

func (m *Operator) Unmarshal(dAtA []byte) error

func (*Operator) XXX_DiscardUnknown 

func (m *Operator) XXX_DiscardUnknown()

func (*Operator) XXX_Marshal 

func (m *Operator) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Operator) XXX_Merge 

func (m *Operator) XXX_Merge(src proto.Message)

func (*Operator) XXX_Size 

func (m *Operator) XXX_Size() int

func (*Operator) XXX_Unmarshal 

func (m *Operator) XXX_Unmarshal(b []byte) error

type OperatorSetParam 

type OperatorSetParam struct {
	MaxOperatorCount        uint32 `protobuf:"varint,1,opt,name=max_operator_count,json=maxOperatorCount,proto3" json:"max_operator_count,omitempty"`
	KickBipsOfOperatorStake uint32 `` /* 137-byte string literal not displayed */
	KickBipsOfTotalStake    uint32 `` /* 128-byte string literal not displayed */
}

OperatorSetParam defines the parameters for the operator set

func (*OperatorSetParam) Descriptor 

func (*OperatorSetParam) Descriptor() ([]byte, []int)

func (*OperatorSetParam) GetKickBipsOfOperatorStake 

func (m *OperatorSetParam) GetKickBipsOfOperatorStake() uint32

func (*OperatorSetParam) GetKickBipsOfTotalStake 

func (m *OperatorSetParam) GetKickBipsOfTotalStake() uint32

func (*OperatorSetParam) GetMaxOperatorCount 

func (m *OperatorSetParam) GetMaxOperatorCount() uint32

func (*OperatorSetParam) Marshal 

func (m *OperatorSetParam) Marshal() (dAtA []byte, err error)

func (*OperatorSetParam) MarshalTo 

func (m *OperatorSetParam) MarshalTo(dAtA []byte) (int, error)

func (*OperatorSetParam) MarshalToSizedBuffer 

func (m *OperatorSetParam) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperatorSetParam) ProtoMessage 

func (*OperatorSetParam) ProtoMessage()

func (*OperatorSetParam) Reset 

func (m *OperatorSetParam) Reset()

func (*OperatorSetParam) Size 

func (m *OperatorSetParam) Size() (n int)

func (*OperatorSetParam) String 

func (m *OperatorSetParam) String() string

func (*OperatorSetParam) Unmarshal 

func (m *OperatorSetParam) Unmarshal(dAtA []byte) error

func (*OperatorSetParam) XXX_DiscardUnknown 

func (m *OperatorSetParam) XXX_DiscardUnknown()

func (*OperatorSetParam) XXX_Marshal 

func (m *OperatorSetParam) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperatorSetParam) XXX_Merge 

func (m *OperatorSetParam) XXX_Merge(src proto.Message)

func (*OperatorSetParam) XXX_Size 

func (m *OperatorSetParam) XXX_Size() int

func (*OperatorSetParam) XXX_Unmarshal 

func (m *OperatorSetParam) XXX_Unmarshal(b []byte) error

type OperatorShares 

type OperatorShares struct {
	ChainId  uint64                `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	Operator string                `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	Strategy string                `protobuf:"bytes,3,opt,name=strategy,proto3" json:"strategy,omitempty"`
	Shares   cosmossdk_io_math.Int `protobuf:"bytes,4,opt,name=shares,proto3,customtype=cosmossdk.io/math.Int" json:"shares"`
}

OperatorShares stores the delegation shares owned by a operator

func (*OperatorShares) Descriptor 

func (*OperatorShares) Descriptor() ([]byte, []int)

func (*OperatorShares) GetChainId 

func (m *OperatorShares) GetChainId() uint64

func (*OperatorShares) GetOperator 

func (m *OperatorShares) GetOperator() string

func (*OperatorShares) GetStrategy 

func (m *OperatorShares) GetStrategy() string

func (*OperatorShares) Marshal 

func (m *OperatorShares) Marshal() (dAtA []byte, err error)

func (*OperatorShares) MarshalTo 

func (m *OperatorShares) MarshalTo(dAtA []byte) (int, error)

func (*OperatorShares) MarshalToSizedBuffer 

func (m *OperatorShares) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OperatorShares) ProtoMessage 

func (*OperatorShares) ProtoMessage()

func (*OperatorShares) Reset 

func (m *OperatorShares) Reset()

func (*OperatorShares) Size 

func (m *OperatorShares) Size() (n int)

func (*OperatorShares) String 

func (m *OperatorShares) String() string

func (*OperatorShares) Unmarshal 

func (m *OperatorShares) Unmarshal(dAtA []byte) error

func (*OperatorShares) XXX_DiscardUnknown 

func (m *OperatorShares) XXX_DiscardUnknown()

func (*OperatorShares) XXX_Marshal 

func (m *OperatorShares) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OperatorShares) XXX_Merge 

func (m *OperatorShares) XXX_Merge(src proto.Message)

func (*OperatorShares) XXX_Size 

func (m *OperatorShares) XXX_Size() int

func (*OperatorShares) XXX_Unmarshal 

func (m *OperatorShares) XXX_Unmarshal(b []byte) error

type OutboundStatus 

type OutboundStatus int32

OutboundStatus is the status of outbound 

const (
	// outbound is initializing
	OutboundStatus_OUTBOUND_STATUS_INITIALIZING OutboundStatus = 0
	// outbound is normal
	OutboundStatus_OUTBOUND_STATUS_NORMAL OutboundStatus = 1
	// outbound is syncing
	OutboundStatus_OUTBOUND_STATUS_SYNCING OutboundStatus = 2
)

func (OutboundStatus) EnumDescriptor 

func (OutboundStatus) EnumDescriptor() ([]byte, []int)

func (OutboundStatus) String 

func (x OutboundStatus) String() string

type Params 

type Params struct {
}

null params

func (*Params) Descriptor 

func (*Params) Descriptor() ([]byte, []int)

func (*Params) Marshal 

func (m *Params) Marshal() (dAtA []byte, err error)

func (*Params) MarshalTo 

func (m *Params) MarshalTo(dAtA []byte) (int, error)

func (*Params) MarshalToSizedBuffer 

func (m *Params) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

func (m *Params) Size() (n int)

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

func (m *Params) Unmarshal(dAtA []byte) error

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

func (m *Params) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Params) XXX_Merge 

func (m *Params) XXX_Merge(src proto.Message)

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

func (m *Params) XXX_Unmarshal(b []byte) error

type PevmKeeper 

type PevmKeeper interface {
	GetPellDelegationManagerProxyContractAddress(ctx sdk.Context) (ethcommon.Address, error)
	CallUpdateDestinationAddressOnPellGateway(
		ctx context.Context,
		chainId int64,
		destinationAddress string,
	) error
	CallUpdateSourceAddressOnPellGateway(
		ctx context.Context,
		chainId int64,
		sourceAddress string,
	) error
	CallUpdateDestinationAddressOnGasSwapPEVM(
		ctx context.Context,
		chainId int64,
		destinationAddress string,
	) error
}

type PoolParams 

type PoolParams struct {
	ChainId    uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	Pool       string `protobuf:"bytes,2,opt,name=pool,proto3" json:"pool,omitempty"`
	Multiplier uint64 `protobuf:"varint,3,opt,name=multiplier,proto3" json:"multiplier,omitempty"`
}

PoolParams defines the pool parameters

func (*PoolParams) Descriptor 

func (*PoolParams) Descriptor() ([]byte, []int)

func (*PoolParams) GetChainId 

func (m *PoolParams) GetChainId() uint64

func (*PoolParams) GetMultiplier 

func (m *PoolParams) GetMultiplier() uint64

func (*PoolParams) GetPool 

func (m *PoolParams) GetPool() string

func (*PoolParams) Marshal 

func (m *PoolParams) Marshal() (dAtA []byte, err error)

func (*PoolParams) MarshalTo 

func (m *PoolParams) MarshalTo(dAtA []byte) (int, error)

func (*PoolParams) MarshalToSizedBuffer 

func (m *PoolParams) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PoolParams) ProtoMessage 

func (*PoolParams) ProtoMessage()

func (*PoolParams) Reset 

func (m *PoolParams) Reset()

func (*PoolParams) Size 

func (m *PoolParams) Size() (n int)

func (*PoolParams) String 

func (m *PoolParams) String() string

func (*PoolParams) Unmarshal 

func (m *PoolParams) Unmarshal(dAtA []byte) error

func (*PoolParams) XXX_DiscardUnknown 

func (m *PoolParams) XXX_DiscardUnknown()

func (*PoolParams) XXX_Marshal 

func (m *PoolParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PoolParams) XXX_Merge 

func (m *PoolParams) XXX_Merge(src proto.Message)

func (*PoolParams) XXX_Size 

func (m *PoolParams) XXX_Size() int

func (*PoolParams) XXX_Unmarshal 

func (m *PoolParams) XXX_Unmarshal(b []byte) error

type PubkeyRegistrationParams 

type PubkeyRegistrationParams struct {
	PubkeyG1 *G1Point `protobuf:"bytes,1,opt,name=pubkey_g1,json=pubkeyG1,proto3" json:"pubkey_g1,omitempty"`
	PubkeyG2 *G2Point `protobuf:"bytes,2,opt,name=pubkey_g2,json=pubkeyG2,proto3" json:"pubkey_g2,omitempty"`
}

PubkeyRegistrationParams holds public key registration details

func (*PubkeyRegistrationParams) Descriptor 

func (*PubkeyRegistrationParams) Descriptor() ([]byte, []int)

func (*PubkeyRegistrationParams) GetPubkeyG1 

func (m *PubkeyRegistrationParams) GetPubkeyG1() *G1Point

func (*PubkeyRegistrationParams) GetPubkeyG2 

func (m *PubkeyRegistrationParams) GetPubkeyG2() *G2Point

func (*PubkeyRegistrationParams) Marshal 

func (m *PubkeyRegistrationParams) Marshal() (dAtA []byte, err error)

func (*PubkeyRegistrationParams) MarshalTo 

func (m *PubkeyRegistrationParams) MarshalTo(dAtA []byte) (int, error)

func (*PubkeyRegistrationParams) MarshalToSizedBuffer 

func (m *PubkeyRegistrationParams) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PubkeyRegistrationParams) ProtoMessage 

func (*PubkeyRegistrationParams) ProtoMessage()

func (*PubkeyRegistrationParams) Reset 

func (m *PubkeyRegistrationParams) Reset()

func (*PubkeyRegistrationParams) Size 

func (m *PubkeyRegistrationParams) Size() (n int)

func (*PubkeyRegistrationParams) String 

func (m *PubkeyRegistrationParams) String() string

func (*PubkeyRegistrationParams) Unmarshal 

func (m *PubkeyRegistrationParams) Unmarshal(dAtA []byte) error

func (*PubkeyRegistrationParams) XXX_DiscardUnknown 

func (m *PubkeyRegistrationParams) XXX_DiscardUnknown()

func (*PubkeyRegistrationParams) XXX_Marshal 

func (m *PubkeyRegistrationParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubkeyRegistrationParams) XXX_Merge 

func (m *PubkeyRegistrationParams) XXX_Merge(src proto.Message)

func (*PubkeyRegistrationParams) XXX_Size 

func (m *PubkeyRegistrationParams) XXX_Size() int

func (*PubkeyRegistrationParams) XXX_Unmarshal 

func (m *PubkeyRegistrationParams) XXX_Unmarshal(b []byte) error

type PubkeyRegistrationParamsV2 

type PubkeyRegistrationParamsV2 struct {
	PubkeyG1 *G1PointV2 `protobuf:"bytes,3,opt,name=pubkey_g1,json=pubkeyG1,proto3" json:"pubkey_g1,omitempty"`
	PubkeyG2 *G2PointV2 `protobuf:"bytes,4,opt,name=pubkey_g2,json=pubkeyG2,proto3" json:"pubkey_g2,omitempty"`
}

PubkeyRegistrationParamsV2 holds public key registration details

func (*PubkeyRegistrationParamsV2) Descriptor 

func (*PubkeyRegistrationParamsV2) Descriptor() ([]byte, []int)

func (*PubkeyRegistrationParamsV2) GetPubkeyG1 

func (m *PubkeyRegistrationParamsV2) GetPubkeyG1() *G1PointV2

func (*PubkeyRegistrationParamsV2) GetPubkeyG2 

func (m *PubkeyRegistrationParamsV2) GetPubkeyG2() *G2PointV2

func (*PubkeyRegistrationParamsV2) Marshal 

func (m *PubkeyRegistrationParamsV2) Marshal() (dAtA []byte, err error)

func (*PubkeyRegistrationParamsV2) MarshalTo 

func (m *PubkeyRegistrationParamsV2) MarshalTo(dAtA []byte) (int, error)

func (*PubkeyRegistrationParamsV2) MarshalToSizedBuffer 

func (m *PubkeyRegistrationParamsV2) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PubkeyRegistrationParamsV2) ProtoMessage 

func (*PubkeyRegistrationParamsV2) ProtoMessage()

func (*PubkeyRegistrationParamsV2) Reset 

func (m *PubkeyRegistrationParamsV2) Reset()

func (*PubkeyRegistrationParamsV2) Size 

func (m *PubkeyRegistrationParamsV2) Size() (n int)

func (*PubkeyRegistrationParamsV2) String 

func (m *PubkeyRegistrationParamsV2) String() string

func (*PubkeyRegistrationParamsV2) Unmarshal 

func (m *PubkeyRegistrationParamsV2) Unmarshal(dAtA []byte) error

func (*PubkeyRegistrationParamsV2) XXX_DiscardUnknown 

func (m *PubkeyRegistrationParamsV2) XXX_DiscardUnknown()

func (*PubkeyRegistrationParamsV2) XXX_Marshal 

func (m *PubkeyRegistrationParamsV2) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PubkeyRegistrationParamsV2) XXX_Merge 

func (m *PubkeyRegistrationParamsV2) XXX_Merge(src proto.Message)

func (*PubkeyRegistrationParamsV2) XXX_Size 

func (m *PubkeyRegistrationParamsV2) XXX_Size() int

func (*PubkeyRegistrationParamsV2) XXX_Unmarshal 

func (m *PubkeyRegistrationParamsV2) XXX_Unmarshal(b []byte) error

type QueryClient 

type QueryClient interface {
	// Queries SystemContract
	GetEpochChangedOperatorSharesSnapshot(ctx context.Context, in *QueryEpochChangedOperatorSharesSnapshotRequest, opts ...grpc.CallOption) (*QueryGetEpochChangedOperatorSharesSnapshotResponse, error)
	// Queries blocks per epoch
	GetEpochInfo(ctx context.Context, in *QueryEpochInfoRequest, opts ...grpc.CallOption) (*QueryGetEpochInfoResponse, error)
	// Queries outbound state by chain id
	GetOutboundStateByChainID(ctx context.Context, in *QueryOutboundStateByChainIDRequest, opts ...grpc.CallOption) (*QueryGetOutboundStateByChainIDResponse, error)
	// Queries dvs supported chain outbound state by chain id
	QueryDVSSupportedChainStatus(ctx context.Context, in *QueryDVSSupportedChainStatusRequest, opts ...grpc.CallOption) (*QueryDVSSupportedChainStatusResponse, error)
	// Queries dvs group data sync status
	QueryDVSGroupSyncStatus(ctx context.Context, in *QueryDVSGroupSyncStatusRequest, opts ...grpc.CallOption) (*QueryDVSGroupSyncStatusResponse, error)
	// Queries dvs supported chain list
	QueryDVSSupportedChainList(ctx context.Context, in *QueryDVSSupportedChainListRequest, opts ...grpc.CallOption) (*QueryDVSSupportedChainListResponse, error)
	// Queries registry router list
	QueryDVSRegistryRouterList(ctx context.Context, in *QueryDVSRegistryRouterListRequest, opts ...grpc.CallOption) (*QueryDVSRegistryRouterListResponse, error)
	// Queries group date list
	QueryDVSGroupDataList(ctx context.Context, in *QueryDVSGroupDataListRequest, opts ...grpc.CallOption) (*QueryDVSGroupDataListResponse, error)
	// Queries group operator registration list
	QueryDVSGroupOperatorRegistrationList(ctx context.Context, in *QueryDVSGroupOperatorRegistrationListRequest, opts ...grpc.CallOption) (*QueryDVSGroupOperatorRegistrationListResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryDVSGroupDataListRequest 

type QueryDVSGroupDataListRequest struct {
	RegistryRouterAddress string `` /* 126-byte string literal not displayed */
}

request of query group data list

func (*QueryDVSGroupDataListRequest) Descriptor 

func (*QueryDVSGroupDataListRequest) Descriptor() ([]byte, []int)

func (*QueryDVSGroupDataListRequest) GetRegistryRouterAddress 

func (m *QueryDVSGroupDataListRequest) GetRegistryRouterAddress() string

func (*QueryDVSGroupDataListRequest) Marshal 

func (m *QueryDVSGroupDataListRequest) Marshal() (dAtA []byte, err error)

func (*QueryDVSGroupDataListRequest) MarshalTo 

func (m *QueryDVSGroupDataListRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSGroupDataListRequest) MarshalToSizedBuffer 

func (m *QueryDVSGroupDataListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSGroupDataListRequest) ProtoMessage 

func (*QueryDVSGroupDataListRequest) ProtoMessage()

func (*QueryDVSGroupDataListRequest) Reset 

func (m *QueryDVSGroupDataListRequest) Reset()

func (*QueryDVSGroupDataListRequest) Size 

func (m *QueryDVSGroupDataListRequest) Size() (n int)

func (*QueryDVSGroupDataListRequest) String 

func (m *QueryDVSGroupDataListRequest) String() string

func (*QueryDVSGroupDataListRequest) Unmarshal 

func (m *QueryDVSGroupDataListRequest) Unmarshal(dAtA []byte) error

func (*QueryDVSGroupDataListRequest) XXX_DiscardUnknown 

func (m *QueryDVSGroupDataListRequest) XXX_DiscardUnknown()

func (*QueryDVSGroupDataListRequest) XXX_Marshal 

func (m *QueryDVSGroupDataListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSGroupDataListRequest) XXX_Merge 

func (m *QueryDVSGroupDataListRequest) XXX_Merge(src proto.Message)

func (*QueryDVSGroupDataListRequest) XXX_Size 

func (m *QueryDVSGroupDataListRequest) XXX_Size() int

func (*QueryDVSGroupDataListRequest) XXX_Unmarshal 

func (m *QueryDVSGroupDataListRequest) XXX_Unmarshal(b []byte) error

type QueryDVSGroupDataListResponse 

type QueryDVSGroupDataListResponse struct {
	Groups []*Group `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
}

response of query group data list

func (*QueryDVSGroupDataListResponse) Descriptor 

func (*QueryDVSGroupDataListResponse) Descriptor() ([]byte, []int)

func (*QueryDVSGroupDataListResponse) GetGroups 

func (m *QueryDVSGroupDataListResponse) GetGroups() []*Group

func (*QueryDVSGroupDataListResponse) Marshal 

func (m *QueryDVSGroupDataListResponse) Marshal() (dAtA []byte, err error)

func (*QueryDVSGroupDataListResponse) MarshalTo 

func (m *QueryDVSGroupDataListResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSGroupDataListResponse) MarshalToSizedBuffer 

func (m *QueryDVSGroupDataListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSGroupDataListResponse) ProtoMessage 

func (*QueryDVSGroupDataListResponse) ProtoMessage()

func (*QueryDVSGroupDataListResponse) Reset 

func (m *QueryDVSGroupDataListResponse) Reset()

func (*QueryDVSGroupDataListResponse) Size 

func (m *QueryDVSGroupDataListResponse) Size() (n int)

func (*QueryDVSGroupDataListResponse) String 

func (m *QueryDVSGroupDataListResponse) String() string

func (*QueryDVSGroupDataListResponse) Unmarshal 

func (m *QueryDVSGroupDataListResponse) Unmarshal(dAtA []byte) error

func (*QueryDVSGroupDataListResponse) XXX_DiscardUnknown 

func (m *QueryDVSGroupDataListResponse) XXX_DiscardUnknown()

func (*QueryDVSGroupDataListResponse) XXX_Marshal 

func (m *QueryDVSGroupDataListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSGroupDataListResponse) XXX_Merge 

func (m *QueryDVSGroupDataListResponse) XXX_Merge(src proto.Message)

func (*QueryDVSGroupDataListResponse) XXX_Size 

func (m *QueryDVSGroupDataListResponse) XXX_Size() int

func (*QueryDVSGroupDataListResponse) XXX_Unmarshal 

func (m *QueryDVSGroupDataListResponse) XXX_Unmarshal(b []byte) error

type QueryDVSGroupOperatorRegistrationListRequest 

type QueryDVSGroupOperatorRegistrationListRequest struct {
	RegistryRouterAddress string `` /* 126-byte string literal not displayed */
}

request of query group operator registration list

func (*QueryDVSGroupOperatorRegistrationListRequest) Descriptor 

func (*QueryDVSGroupOperatorRegistrationListRequest) Descriptor() ([]byte, []int)

func (*QueryDVSGroupOperatorRegistrationListRequest) GetRegistryRouterAddress 

func (m *QueryDVSGroupOperatorRegistrationListRequest) GetRegistryRouterAddress() string

func (*QueryDVSGroupOperatorRegistrationListRequest) Marshal 

func (m *QueryDVSGroupOperatorRegistrationListRequest) Marshal() (dAtA []byte, err error)

func (*QueryDVSGroupOperatorRegistrationListRequest) MarshalTo 

func (m *QueryDVSGroupOperatorRegistrationListRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSGroupOperatorRegistrationListRequest) MarshalToSizedBuffer 

func (m *QueryDVSGroupOperatorRegistrationListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSGroupOperatorRegistrationListRequest) ProtoMessage 

func (*QueryDVSGroupOperatorRegistrationListRequest) ProtoMessage()

func (*QueryDVSGroupOperatorRegistrationListRequest) Reset 

func (m *QueryDVSGroupOperatorRegistrationListRequest) Reset()

func (*QueryDVSGroupOperatorRegistrationListRequest) Size 

func (m *QueryDVSGroupOperatorRegistrationListRequest) Size() (n int)

func (*QueryDVSGroupOperatorRegistrationListRequest) String 

func (m *QueryDVSGroupOperatorRegistrationListRequest) String() string

func (*QueryDVSGroupOperatorRegistrationListRequest) Unmarshal 

func (m *QueryDVSGroupOperatorRegistrationListRequest) Unmarshal(dAtA []byte) error

func (*QueryDVSGroupOperatorRegistrationListRequest) XXX_DiscardUnknown 

func (m *QueryDVSGroupOperatorRegistrationListRequest) XXX_DiscardUnknown()

func (*QueryDVSGroupOperatorRegistrationListRequest) XXX_Marshal 

func (m *QueryDVSGroupOperatorRegistrationListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSGroupOperatorRegistrationListRequest) XXX_Merge 

func (m *QueryDVSGroupOperatorRegistrationListRequest) XXX_Merge(src proto.Message)

func (*QueryDVSGroupOperatorRegistrationListRequest) XXX_Size 

func (m *QueryDVSGroupOperatorRegistrationListRequest) XXX_Size() int

func (*QueryDVSGroupOperatorRegistrationListRequest) XXX_Unmarshal 

func (m *QueryDVSGroupOperatorRegistrationListRequest) XXX_Unmarshal(b []byte) error

type QueryDVSGroupOperatorRegistrationListResponse 

type QueryDVSGroupOperatorRegistrationListResponse struct {
	OperatorRegisteredInfos []*GroupOperatorRegistrationV2 `` /* 132-byte string literal not displayed */
}

response of query group operator registration list

func (*QueryDVSGroupOperatorRegistrationListResponse) Descriptor 

func (*QueryDVSGroupOperatorRegistrationListResponse) Descriptor() ([]byte, []int)

func (*QueryDVSGroupOperatorRegistrationListResponse) GetOperatorRegisteredInfos 

func (m *QueryDVSGroupOperatorRegistrationListResponse) GetOperatorRegisteredInfos() []*GroupOperatorRegistrationV2

func (*QueryDVSGroupOperatorRegistrationListResponse) Marshal 

func (m *QueryDVSGroupOperatorRegistrationListResponse) Marshal() (dAtA []byte, err error)

func (*QueryDVSGroupOperatorRegistrationListResponse) MarshalTo 

func (m *QueryDVSGroupOperatorRegistrationListResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSGroupOperatorRegistrationListResponse) MarshalToSizedBuffer 

func (m *QueryDVSGroupOperatorRegistrationListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSGroupOperatorRegistrationListResponse) ProtoMessage 

func (*QueryDVSGroupOperatorRegistrationListResponse) ProtoMessage()

func (*QueryDVSGroupOperatorRegistrationListResponse) Reset 

func (m *QueryDVSGroupOperatorRegistrationListResponse) Reset()

func (*QueryDVSGroupOperatorRegistrationListResponse) Size 

func (m *QueryDVSGroupOperatorRegistrationListResponse) Size() (n int)

func (*QueryDVSGroupOperatorRegistrationListResponse) String 

func (m *QueryDVSGroupOperatorRegistrationListResponse) String() string

func (*QueryDVSGroupOperatorRegistrationListResponse) Unmarshal 

func (m *QueryDVSGroupOperatorRegistrationListResponse) Unmarshal(dAtA []byte) error

func (*QueryDVSGroupOperatorRegistrationListResponse) XXX_DiscardUnknown 

func (m *QueryDVSGroupOperatorRegistrationListResponse) XXX_DiscardUnknown()

func (*QueryDVSGroupOperatorRegistrationListResponse) XXX_Marshal 

func (m *QueryDVSGroupOperatorRegistrationListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSGroupOperatorRegistrationListResponse) XXX_Merge 

func (m *QueryDVSGroupOperatorRegistrationListResponse) XXX_Merge(src proto.Message)

func (*QueryDVSGroupOperatorRegistrationListResponse) XXX_Size 

func (m *QueryDVSGroupOperatorRegistrationListResponse) XXX_Size() int

func (*QueryDVSGroupOperatorRegistrationListResponse) XXX_Unmarshal 

func (m *QueryDVSGroupOperatorRegistrationListResponse) XXX_Unmarshal(b []byte) error

type QueryDVSGroupSyncStatusRequest 

type QueryDVSGroupSyncStatusRequest struct {
	TxHash string `protobuf:"bytes,1,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
}

request of query dvs group data sync status

func (*QueryDVSGroupSyncStatusRequest) Descriptor 

func (*QueryDVSGroupSyncStatusRequest) Descriptor() ([]byte, []int)

func (*QueryDVSGroupSyncStatusRequest) GetTxHash 

func (m *QueryDVSGroupSyncStatusRequest) GetTxHash() string

func (*QueryDVSGroupSyncStatusRequest) Marshal 

func (m *QueryDVSGroupSyncStatusRequest) Marshal() (dAtA []byte, err error)

func (*QueryDVSGroupSyncStatusRequest) MarshalTo 

func (m *QueryDVSGroupSyncStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSGroupSyncStatusRequest) MarshalToSizedBuffer 

func (m *QueryDVSGroupSyncStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSGroupSyncStatusRequest) ProtoMessage 

func (*QueryDVSGroupSyncStatusRequest) ProtoMessage()

func (*QueryDVSGroupSyncStatusRequest) Reset 

func (m *QueryDVSGroupSyncStatusRequest) Reset()

func (*QueryDVSGroupSyncStatusRequest) Size 

func (m *QueryDVSGroupSyncStatusRequest) Size() (n int)

func (*QueryDVSGroupSyncStatusRequest) String 

func (m *QueryDVSGroupSyncStatusRequest) String() string

func (*QueryDVSGroupSyncStatusRequest) Unmarshal 

func (m *QueryDVSGroupSyncStatusRequest) Unmarshal(dAtA []byte) error

func (*QueryDVSGroupSyncStatusRequest) XXX_DiscardUnknown 

func (m *QueryDVSGroupSyncStatusRequest) XXX_DiscardUnknown()

func (*QueryDVSGroupSyncStatusRequest) XXX_Marshal 

func (m *QueryDVSGroupSyncStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSGroupSyncStatusRequest) XXX_Merge 

func (m *QueryDVSGroupSyncStatusRequest) XXX_Merge(src proto.Message)

func (*QueryDVSGroupSyncStatusRequest) XXX_Size 

func (m *QueryDVSGroupSyncStatusRequest) XXX_Size() int

func (*QueryDVSGroupSyncStatusRequest) XXX_Unmarshal 

func (m *QueryDVSGroupSyncStatusRequest) XXX_Unmarshal(b []byte) error

type QueryDVSGroupSyncStatusResponse 

type QueryDVSGroupSyncStatusResponse struct {
	Xmsg []*types.Xmsg `protobuf:"bytes,1,rep,name=xmsg,proto3" json:"xmsg,omitempty"`
}

response of query dvs group data sync status

func (*QueryDVSGroupSyncStatusResponse) Descriptor 

func (*QueryDVSGroupSyncStatusResponse) Descriptor() ([]byte, []int)

func (*QueryDVSGroupSyncStatusResponse) GetXmsg 

func (m *QueryDVSGroupSyncStatusResponse) GetXmsg() []*types.Xmsg

func (*QueryDVSGroupSyncStatusResponse) Marshal 

func (m *QueryDVSGroupSyncStatusResponse) Marshal() (dAtA []byte, err error)

func (*QueryDVSGroupSyncStatusResponse) MarshalTo 

func (m *QueryDVSGroupSyncStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSGroupSyncStatusResponse) MarshalToSizedBuffer 

func (m *QueryDVSGroupSyncStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSGroupSyncStatusResponse) ProtoMessage 

func (*QueryDVSGroupSyncStatusResponse) ProtoMessage()

func (*QueryDVSGroupSyncStatusResponse) Reset 

func (m *QueryDVSGroupSyncStatusResponse) Reset()

func (*QueryDVSGroupSyncStatusResponse) Size 

func (m *QueryDVSGroupSyncStatusResponse) Size() (n int)

func (*QueryDVSGroupSyncStatusResponse) String 

func (m *QueryDVSGroupSyncStatusResponse) String() string

func (*QueryDVSGroupSyncStatusResponse) Unmarshal 

func (m *QueryDVSGroupSyncStatusResponse) Unmarshal(dAtA []byte) error

func (*QueryDVSGroupSyncStatusResponse) XXX_DiscardUnknown 

func (m *QueryDVSGroupSyncStatusResponse) XXX_DiscardUnknown()

func (*QueryDVSGroupSyncStatusResponse) XXX_Marshal 

func (m *QueryDVSGroupSyncStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSGroupSyncStatusResponse) XXX_Merge 

func (m *QueryDVSGroupSyncStatusResponse) XXX_Merge(src proto.Message)

func (*QueryDVSGroupSyncStatusResponse) XXX_Size 

func (m *QueryDVSGroupSyncStatusResponse) XXX_Size() int

func (*QueryDVSGroupSyncStatusResponse) XXX_Unmarshal 

func (m *QueryDVSGroupSyncStatusResponse) XXX_Unmarshal(b []byte) error

type QueryDVSRegistryRouterListRequest 

type QueryDVSRegistryRouterListRequest struct {
}

request of query registry router list

func (*QueryDVSRegistryRouterListRequest) Descriptor 

func (*QueryDVSRegistryRouterListRequest) Descriptor() ([]byte, []int)

func (*QueryDVSRegistryRouterListRequest) Marshal 

func (m *QueryDVSRegistryRouterListRequest) Marshal() (dAtA []byte, err error)

func (*QueryDVSRegistryRouterListRequest) MarshalTo 

func (m *QueryDVSRegistryRouterListRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSRegistryRouterListRequest) MarshalToSizedBuffer 

func (m *QueryDVSRegistryRouterListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSRegistryRouterListRequest) ProtoMessage 

func (*QueryDVSRegistryRouterListRequest) ProtoMessage()

func (*QueryDVSRegistryRouterListRequest) Reset 

func (m *QueryDVSRegistryRouterListRequest) Reset()

func (*QueryDVSRegistryRouterListRequest) Size 

func (m *QueryDVSRegistryRouterListRequest) Size() (n int)

func (*QueryDVSRegistryRouterListRequest) String 

func (m *QueryDVSRegistryRouterListRequest) String() string

func (*QueryDVSRegistryRouterListRequest) Unmarshal 

func (m *QueryDVSRegistryRouterListRequest) Unmarshal(dAtA []byte) error

func (*QueryDVSRegistryRouterListRequest) XXX_DiscardUnknown 

func (m *QueryDVSRegistryRouterListRequest) XXX_DiscardUnknown()

func (*QueryDVSRegistryRouterListRequest) XXX_Marshal 

func (m *QueryDVSRegistryRouterListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSRegistryRouterListRequest) XXX_Merge 

func (m *QueryDVSRegistryRouterListRequest) XXX_Merge(src proto.Message)

func (*QueryDVSRegistryRouterListRequest) XXX_Size 

func (m *QueryDVSRegistryRouterListRequest) XXX_Size() int

func (*QueryDVSRegistryRouterListRequest) XXX_Unmarshal 

func (m *QueryDVSRegistryRouterListRequest) XXX_Unmarshal(b []byte) error

type QueryDVSRegistryRouterListResponse 

type QueryDVSRegistryRouterListResponse struct {
	RegistryRouterSet []*RegistryRouterSet `protobuf:"bytes,1,rep,name=registry_router_set,json=registryRouterSet,proto3" json:"registry_router_set,omitempty"`
}

response of query registry router list

func (*QueryDVSRegistryRouterListResponse) Descriptor 

func (*QueryDVSRegistryRouterListResponse) Descriptor() ([]byte, []int)

func (*QueryDVSRegistryRouterListResponse) GetRegistryRouterSet 

func (m *QueryDVSRegistryRouterListResponse) GetRegistryRouterSet() []*RegistryRouterSet

func (*QueryDVSRegistryRouterListResponse) Marshal 

func (m *QueryDVSRegistryRouterListResponse) Marshal() (dAtA []byte, err error)

func (*QueryDVSRegistryRouterListResponse) MarshalTo 

func (m *QueryDVSRegistryRouterListResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSRegistryRouterListResponse) MarshalToSizedBuffer 

func (m *QueryDVSRegistryRouterListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSRegistryRouterListResponse) ProtoMessage 

func (*QueryDVSRegistryRouterListResponse) ProtoMessage()

func (*QueryDVSRegistryRouterListResponse) Reset 

func (m *QueryDVSRegistryRouterListResponse) Reset()

func (*QueryDVSRegistryRouterListResponse) Size 

func (m *QueryDVSRegistryRouterListResponse) Size() (n int)

func (*QueryDVSRegistryRouterListResponse) String 

func (m *QueryDVSRegistryRouterListResponse) String() string

func (*QueryDVSRegistryRouterListResponse) Unmarshal 

func (m *QueryDVSRegistryRouterListResponse) Unmarshal(dAtA []byte) error

func (*QueryDVSRegistryRouterListResponse) XXX_DiscardUnknown 

func (m *QueryDVSRegistryRouterListResponse) XXX_DiscardUnknown()

func (*QueryDVSRegistryRouterListResponse) XXX_Marshal 

func (m *QueryDVSRegistryRouterListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSRegistryRouterListResponse) XXX_Merge 

func (m *QueryDVSRegistryRouterListResponse) XXX_Merge(src proto.Message)

func (*QueryDVSRegistryRouterListResponse) XXX_Size 

func (m *QueryDVSRegistryRouterListResponse) XXX_Size() int

func (*QueryDVSRegistryRouterListResponse) XXX_Unmarshal 

func (m *QueryDVSRegistryRouterListResponse) XXX_Unmarshal(b []byte) error

type QueryDVSSupportedChainListRequest 

type QueryDVSSupportedChainListRequest struct {
	RegistryRouterAddress string `` /* 126-byte string literal not displayed */
}

request of query dvs supported chain list

func (*QueryDVSSupportedChainListRequest) Descriptor 

func (*QueryDVSSupportedChainListRequest) Descriptor() ([]byte, []int)

func (*QueryDVSSupportedChainListRequest) GetRegistryRouterAddress 

func (m *QueryDVSSupportedChainListRequest) GetRegistryRouterAddress() string

func (*QueryDVSSupportedChainListRequest) Marshal 

func (m *QueryDVSSupportedChainListRequest) Marshal() (dAtA []byte, err error)

func (*QueryDVSSupportedChainListRequest) MarshalTo 

func (m *QueryDVSSupportedChainListRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSSupportedChainListRequest) MarshalToSizedBuffer 

func (m *QueryDVSSupportedChainListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSSupportedChainListRequest) ProtoMessage 

func (*QueryDVSSupportedChainListRequest) ProtoMessage()

func (*QueryDVSSupportedChainListRequest) Reset 

func (m *QueryDVSSupportedChainListRequest) Reset()

func (*QueryDVSSupportedChainListRequest) Size 

func (m *QueryDVSSupportedChainListRequest) Size() (n int)

func (*QueryDVSSupportedChainListRequest) String 

func (m *QueryDVSSupportedChainListRequest) String() string

func (*QueryDVSSupportedChainListRequest) Unmarshal 

func (m *QueryDVSSupportedChainListRequest) Unmarshal(dAtA []byte) error

func (*QueryDVSSupportedChainListRequest) XXX_DiscardUnknown 

func (m *QueryDVSSupportedChainListRequest) XXX_DiscardUnknown()

func (*QueryDVSSupportedChainListRequest) XXX_Marshal 

func (m *QueryDVSSupportedChainListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSSupportedChainListRequest) XXX_Merge 

func (m *QueryDVSSupportedChainListRequest) XXX_Merge(src proto.Message)

func (*QueryDVSSupportedChainListRequest) XXX_Size 

func (m *QueryDVSSupportedChainListRequest) XXX_Size() int

func (*QueryDVSSupportedChainListRequest) XXX_Unmarshal 

func (m *QueryDVSSupportedChainListRequest) XXX_Unmarshal(b []byte) error

type QueryDVSSupportedChainListResponse 

type QueryDVSSupportedChainListResponse struct {
	DvsInfos *DVSInfoList `protobuf:"bytes,1,opt,name=dvs_infos,json=dvsInfos,proto3" json:"dvs_infos,omitempty"`
}

response of query dvs supported chain list

func (*QueryDVSSupportedChainListResponse) Descriptor 

func (*QueryDVSSupportedChainListResponse) Descriptor() ([]byte, []int)

func (*QueryDVSSupportedChainListResponse) GetDvsInfos 

func (m *QueryDVSSupportedChainListResponse) GetDvsInfos() *DVSInfoList

func (*QueryDVSSupportedChainListResponse) Marshal 

func (m *QueryDVSSupportedChainListResponse) Marshal() (dAtA []byte, err error)

func (*QueryDVSSupportedChainListResponse) MarshalTo 

func (m *QueryDVSSupportedChainListResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSSupportedChainListResponse) MarshalToSizedBuffer 

func (m *QueryDVSSupportedChainListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSSupportedChainListResponse) ProtoMessage 

func (*QueryDVSSupportedChainListResponse) ProtoMessage()

func (*QueryDVSSupportedChainListResponse) Reset 

func (m *QueryDVSSupportedChainListResponse) Reset()

func (*QueryDVSSupportedChainListResponse) Size 

func (m *QueryDVSSupportedChainListResponse) Size() (n int)

func (*QueryDVSSupportedChainListResponse) String 

func (m *QueryDVSSupportedChainListResponse) String() string

func (*QueryDVSSupportedChainListResponse) Unmarshal 

func (m *QueryDVSSupportedChainListResponse) Unmarshal(dAtA []byte) error

func (*QueryDVSSupportedChainListResponse) XXX_DiscardUnknown 

func (m *QueryDVSSupportedChainListResponse) XXX_DiscardUnknown()

func (*QueryDVSSupportedChainListResponse) XXX_Marshal 

func (m *QueryDVSSupportedChainListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSSupportedChainListResponse) XXX_Merge 

func (m *QueryDVSSupportedChainListResponse) XXX_Merge(src proto.Message)

func (*QueryDVSSupportedChainListResponse) XXX_Size 

func (m *QueryDVSSupportedChainListResponse) XXX_Size() int

func (*QueryDVSSupportedChainListResponse) XXX_Unmarshal 

func (m *QueryDVSSupportedChainListResponse) XXX_Unmarshal(b []byte) error

type QueryDVSSupportedChainStatusRequest 

type QueryDVSSupportedChainStatusRequest struct {
	RegistryRouterAddress string `` /* 126-byte string literal not displayed */
	ChainId               uint64 `protobuf:"varint,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
}

request of query dvs supported chain status

func (*QueryDVSSupportedChainStatusRequest) Descriptor 

func (*QueryDVSSupportedChainStatusRequest) Descriptor() ([]byte, []int)

func (*QueryDVSSupportedChainStatusRequest) GetChainId 

func (m *QueryDVSSupportedChainStatusRequest) GetChainId() uint64

func (*QueryDVSSupportedChainStatusRequest) GetRegistryRouterAddress 

func (m *QueryDVSSupportedChainStatusRequest) GetRegistryRouterAddress() string

func (*QueryDVSSupportedChainStatusRequest) Marshal 

func (m *QueryDVSSupportedChainStatusRequest) Marshal() (dAtA []byte, err error)

func (*QueryDVSSupportedChainStatusRequest) MarshalTo 

func (m *QueryDVSSupportedChainStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSSupportedChainStatusRequest) MarshalToSizedBuffer 

func (m *QueryDVSSupportedChainStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSSupportedChainStatusRequest) ProtoMessage 

func (*QueryDVSSupportedChainStatusRequest) ProtoMessage()

func (*QueryDVSSupportedChainStatusRequest) Reset 

func (m *QueryDVSSupportedChainStatusRequest) Reset()

func (*QueryDVSSupportedChainStatusRequest) Size 

func (m *QueryDVSSupportedChainStatusRequest) Size() (n int)

func (*QueryDVSSupportedChainStatusRequest) String 

func (m *QueryDVSSupportedChainStatusRequest) String() string

func (*QueryDVSSupportedChainStatusRequest) Unmarshal 

func (m *QueryDVSSupportedChainStatusRequest) Unmarshal(dAtA []byte) error

func (*QueryDVSSupportedChainStatusRequest) XXX_DiscardUnknown 

func (m *QueryDVSSupportedChainStatusRequest) XXX_DiscardUnknown()

func (*QueryDVSSupportedChainStatusRequest) XXX_Marshal 

func (m *QueryDVSSupportedChainStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSSupportedChainStatusRequest) XXX_Merge 

func (m *QueryDVSSupportedChainStatusRequest) XXX_Merge(src proto.Message)

func (*QueryDVSSupportedChainStatusRequest) XXX_Size 

func (m *QueryDVSSupportedChainStatusRequest) XXX_Size() int

func (*QueryDVSSupportedChainStatusRequest) XXX_Unmarshal 

func (m *QueryDVSSupportedChainStatusRequest) XXX_Unmarshal(b []byte) error

type QueryDVSSupportedChainStatusResponse 

type QueryDVSSupportedChainStatusResponse struct {
	OutboundState OutboundStatus `` /* 131-byte string literal not displayed */
}

response of query dvs supported chain status

func (*QueryDVSSupportedChainStatusResponse) Descriptor 

func (*QueryDVSSupportedChainStatusResponse) Descriptor() ([]byte, []int)

func (*QueryDVSSupportedChainStatusResponse) GetOutboundState 

func (m *QueryDVSSupportedChainStatusResponse) GetOutboundState() OutboundStatus

func (*QueryDVSSupportedChainStatusResponse) Marshal 

func (m *QueryDVSSupportedChainStatusResponse) Marshal() (dAtA []byte, err error)

func (*QueryDVSSupportedChainStatusResponse) MarshalTo 

func (m *QueryDVSSupportedChainStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryDVSSupportedChainStatusResponse) MarshalToSizedBuffer 

func (m *QueryDVSSupportedChainStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryDVSSupportedChainStatusResponse) ProtoMessage 

func (*QueryDVSSupportedChainStatusResponse) ProtoMessage()

func (*QueryDVSSupportedChainStatusResponse) Reset 

func (m *QueryDVSSupportedChainStatusResponse) Reset()

func (*QueryDVSSupportedChainStatusResponse) Size 

func (m *QueryDVSSupportedChainStatusResponse) Size() (n int)

func (*QueryDVSSupportedChainStatusResponse) String 

func (m *QueryDVSSupportedChainStatusResponse) String() string

func (*QueryDVSSupportedChainStatusResponse) Unmarshal 

func (m *QueryDVSSupportedChainStatusResponse) Unmarshal(dAtA []byte) error

func (*QueryDVSSupportedChainStatusResponse) XXX_DiscardUnknown 

func (m *QueryDVSSupportedChainStatusResponse) XXX_DiscardUnknown()

func (*QueryDVSSupportedChainStatusResponse) XXX_Marshal 

func (m *QueryDVSSupportedChainStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDVSSupportedChainStatusResponse) XXX_Merge 

func (m *QueryDVSSupportedChainStatusResponse) XXX_Merge(src proto.Message)

func (*QueryDVSSupportedChainStatusResponse) XXX_Size 

func (m *QueryDVSSupportedChainStatusResponse) XXX_Size() int

func (*QueryDVSSupportedChainStatusResponse) XXX_Unmarshal 

func (m *QueryDVSSupportedChainStatusResponse) XXX_Unmarshal(b []byte) error

type QueryEpochChangedOperatorSharesSnapshotRequest 

type QueryEpochChangedOperatorSharesSnapshotRequest struct {
	EpochNumber uint64 `protobuf:"varint,1,opt,name=epoch_number,json=epochNumber,proto3" json:"epoch_number,omitempty"`
}

request of query epoch changed operator shares snapshot

func (*QueryEpochChangedOperatorSharesSnapshotRequest) Descriptor 

func (*QueryEpochChangedOperatorSharesSnapshotRequest) Descriptor() ([]byte, []int)

func (*QueryEpochChangedOperatorSharesSnapshotRequest) GetEpochNumber 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) GetEpochNumber() uint64

func (*QueryEpochChangedOperatorSharesSnapshotRequest) Marshal 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) Marshal() (dAtA []byte, err error)

func (*QueryEpochChangedOperatorSharesSnapshotRequest) MarshalTo 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryEpochChangedOperatorSharesSnapshotRequest) MarshalToSizedBuffer 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryEpochChangedOperatorSharesSnapshotRequest) ProtoMessage 

func (*QueryEpochChangedOperatorSharesSnapshotRequest) ProtoMessage()

func (*QueryEpochChangedOperatorSharesSnapshotRequest) Reset 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) Reset()

func (*QueryEpochChangedOperatorSharesSnapshotRequest) Size 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) Size() (n int)

func (*QueryEpochChangedOperatorSharesSnapshotRequest) String 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) String() string

func (*QueryEpochChangedOperatorSharesSnapshotRequest) Unmarshal 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) Unmarshal(dAtA []byte) error

func (*QueryEpochChangedOperatorSharesSnapshotRequest) XXX_DiscardUnknown 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) XXX_DiscardUnknown()

func (*QueryEpochChangedOperatorSharesSnapshotRequest) XXX_Marshal 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryEpochChangedOperatorSharesSnapshotRequest) XXX_Merge 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) XXX_Merge(src proto.Message)

func (*QueryEpochChangedOperatorSharesSnapshotRequest) XXX_Size 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) XXX_Size() int

func (*QueryEpochChangedOperatorSharesSnapshotRequest) XXX_Unmarshal 

func (m *QueryEpochChangedOperatorSharesSnapshotRequest) XXX_Unmarshal(b []byte) error

type QueryEpochInfoRequest 

type QueryEpochInfoRequest struct {
}

request of query blocks per epoch

func (*QueryEpochInfoRequest) Descriptor 

func (*QueryEpochInfoRequest) Descriptor() ([]byte, []int)

func (*QueryEpochInfoRequest) Marshal 

func (m *QueryEpochInfoRequest) Marshal() (dAtA []byte, err error)

func (*QueryEpochInfoRequest) MarshalTo 

func (m *QueryEpochInfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryEpochInfoRequest) MarshalToSizedBuffer 

func (m *QueryEpochInfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryEpochInfoRequest) ProtoMessage 

func (*QueryEpochInfoRequest) ProtoMessage()

func (*QueryEpochInfoRequest) Reset 

func (m *QueryEpochInfoRequest) Reset()

func (*QueryEpochInfoRequest) Size 

func (m *QueryEpochInfoRequest) Size() (n int)

func (*QueryEpochInfoRequest) String 

func (m *QueryEpochInfoRequest) String() string

func (*QueryEpochInfoRequest) Unmarshal 

func (m *QueryEpochInfoRequest) Unmarshal(dAtA []byte) error

func (*QueryEpochInfoRequest) XXX_DiscardUnknown 

func (m *QueryEpochInfoRequest) XXX_DiscardUnknown()

func (*QueryEpochInfoRequest) XXX_Marshal 

func (m *QueryEpochInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryEpochInfoRequest) XXX_Merge 

func (m *QueryEpochInfoRequest) XXX_Merge(src proto.Message)

func (*QueryEpochInfoRequest) XXX_Size 

func (m *QueryEpochInfoRequest) XXX_Size() int

func (*QueryEpochInfoRequest) XXX_Unmarshal 

func (m *QueryEpochInfoRequest) XXX_Unmarshal(b []byte) error

type QueryGetEpochChangedOperatorSharesSnapshotResponse 

type QueryGetEpochChangedOperatorSharesSnapshotResponse struct {
	ChangedOperatorSharesSnapshot []OperatorShares `` /* 142-byte string literal not displayed */
}

response of query epoch changed operator shares snapshot

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) Descriptor 

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) Descriptor() ([]byte, []int)

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) GetChangedOperatorSharesSnapshot 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) GetChangedOperatorSharesSnapshot() []OperatorShares

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) Marshal 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) Marshal() (dAtA []byte, err error)

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) MarshalTo 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) MarshalToSizedBuffer 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) ProtoMessage 

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) ProtoMessage()

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) Reset 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) Reset()

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) Size 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) Size() (n int)

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) String 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) String() string

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) Unmarshal 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) Unmarshal(dAtA []byte) error

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) XXX_DiscardUnknown 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) XXX_DiscardUnknown()

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) XXX_Marshal 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) XXX_Merge 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) XXX_Merge(src proto.Message)

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) XXX_Size 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) XXX_Size() int

func (*QueryGetEpochChangedOperatorSharesSnapshotResponse) XXX_Unmarshal 

func (m *QueryGetEpochChangedOperatorSharesSnapshotResponse) XXX_Unmarshal(b []byte) error

type QueryGetEpochInfoResponse 

type QueryGetEpochInfoResponse struct {
	BlockNumber uint64 `protobuf:"varint,1,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
}

response of query blocks per epoch

func (*QueryGetEpochInfoResponse) Descriptor 

func (*QueryGetEpochInfoResponse) Descriptor() ([]byte, []int)

func (*QueryGetEpochInfoResponse) GetBlockNumber 

func (m *QueryGetEpochInfoResponse) GetBlockNumber() uint64

func (*QueryGetEpochInfoResponse) Marshal 

func (m *QueryGetEpochInfoResponse) Marshal() (dAtA []byte, err error)

func (*QueryGetEpochInfoResponse) MarshalTo 

func (m *QueryGetEpochInfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetEpochInfoResponse) MarshalToSizedBuffer 

func (m *QueryGetEpochInfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetEpochInfoResponse) ProtoMessage 

func (*QueryGetEpochInfoResponse) ProtoMessage()

func (*QueryGetEpochInfoResponse) Reset 

func (m *QueryGetEpochInfoResponse) Reset()

func (*QueryGetEpochInfoResponse) Size 

func (m *QueryGetEpochInfoResponse) Size() (n int)

func (*QueryGetEpochInfoResponse) String 

func (m *QueryGetEpochInfoResponse) String() string

func (*QueryGetEpochInfoResponse) Unmarshal 

func (m *QueryGetEpochInfoResponse) Unmarshal(dAtA []byte) error

func (*QueryGetEpochInfoResponse) XXX_DiscardUnknown 

func (m *QueryGetEpochInfoResponse) XXX_DiscardUnknown()

func (*QueryGetEpochInfoResponse) XXX_Marshal 

func (m *QueryGetEpochInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryGetEpochInfoResponse) XXX_Merge 

func (m *QueryGetEpochInfoResponse) XXX_Merge(src proto.Message)

func (*QueryGetEpochInfoResponse) XXX_Size 

func (m *QueryGetEpochInfoResponse) XXX_Size() int

func (*QueryGetEpochInfoResponse) XXX_Unmarshal 

func (m *QueryGetEpochInfoResponse) XXX_Unmarshal(b []byte) error

type QueryGetOutboundStateByChainIDResponse 

type QueryGetOutboundStateByChainIDResponse struct {
	OutboundState *EpochOutboundState `protobuf:"bytes,1,opt,name=outbound_state,json=outboundState,proto3" json:"outbound_state,omitempty"`
}

response of query outbound state by chain id

func (*QueryGetOutboundStateByChainIDResponse) Descriptor 

func (*QueryGetOutboundStateByChainIDResponse) Descriptor() ([]byte, []int)

func (*QueryGetOutboundStateByChainIDResponse) GetOutboundState 

func (m *QueryGetOutboundStateByChainIDResponse) GetOutboundState() *EpochOutboundState

func (*QueryGetOutboundStateByChainIDResponse) Marshal 

func (m *QueryGetOutboundStateByChainIDResponse) Marshal() (dAtA []byte, err error)

func (*QueryGetOutboundStateByChainIDResponse) MarshalTo 

func (m *QueryGetOutboundStateByChainIDResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryGetOutboundStateByChainIDResponse) MarshalToSizedBuffer 

func (m *QueryGetOutboundStateByChainIDResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryGetOutboundStateByChainIDResponse) ProtoMessage 

func (*QueryGetOutboundStateByChainIDResponse) ProtoMessage()

func (*QueryGetOutboundStateByChainIDResponse) Reset 

func (m *QueryGetOutboundStateByChainIDResponse) Reset()

func (*QueryGetOutboundStateByChainIDResponse) Size 

func (m *QueryGetOutboundStateByChainIDResponse) Size() (n int)

func (*QueryGetOutboundStateByChainIDResponse) String 

func (m *QueryGetOutboundStateByChainIDResponse) String() string

func (*QueryGetOutboundStateByChainIDResponse) Unmarshal 

func (m *QueryGetOutboundStateByChainIDResponse) Unmarshal(dAtA []byte) error

func (*QueryGetOutboundStateByChainIDResponse) XXX_DiscardUnknown 

func (m *QueryGetOutboundStateByChainIDResponse) XXX_DiscardUnknown()

func (*QueryGetOutboundStateByChainIDResponse) XXX_Marshal 

func (m *QueryGetOutboundStateByChainIDResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryGetOutboundStateByChainIDResponse) XXX_Merge 

func (m *QueryGetOutboundStateByChainIDResponse) XXX_Merge(src proto.Message)

func (*QueryGetOutboundStateByChainIDResponse) XXX_Size 

func (m *QueryGetOutboundStateByChainIDResponse) XXX_Size() int

func (*QueryGetOutboundStateByChainIDResponse) XXX_Unmarshal 

func (m *QueryGetOutboundStateByChainIDResponse) XXX_Unmarshal(b []byte) error

type QueryOutboundStateByChainIDRequest 

type QueryOutboundStateByChainIDRequest struct {
	ChainId uint64 `protobuf:"varint,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
}

request of query outbound state by chain id

func (*QueryOutboundStateByChainIDRequest) Descriptor 

func (*QueryOutboundStateByChainIDRequest) Descriptor() ([]byte, []int)

func (*QueryOutboundStateByChainIDRequest) GetChainId 

func (m *QueryOutboundStateByChainIDRequest) GetChainId() uint64

func (*QueryOutboundStateByChainIDRequest) Marshal 

func (m *QueryOutboundStateByChainIDRequest) Marshal() (dAtA []byte, err error)

func (*QueryOutboundStateByChainIDRequest) MarshalTo 

func (m *QueryOutboundStateByChainIDRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryOutboundStateByChainIDRequest) MarshalToSizedBuffer 

func (m *QueryOutboundStateByChainIDRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryOutboundStateByChainIDRequest) ProtoMessage 

func (*QueryOutboundStateByChainIDRequest) ProtoMessage()

func (*QueryOutboundStateByChainIDRequest) Reset 

func (m *QueryOutboundStateByChainIDRequest) Reset()

func (*QueryOutboundStateByChainIDRequest) Size 

func (m *QueryOutboundStateByChainIDRequest) Size() (n int)

func (*QueryOutboundStateByChainIDRequest) String 

func (m *QueryOutboundStateByChainIDRequest) String() string

func (*QueryOutboundStateByChainIDRequest) Unmarshal 

func (m *QueryOutboundStateByChainIDRequest) Unmarshal(dAtA []byte) error

func (*QueryOutboundStateByChainIDRequest) XXX_DiscardUnknown 

func (m *QueryOutboundStateByChainIDRequest) XXX_DiscardUnknown()

func (*QueryOutboundStateByChainIDRequest) XXX_Marshal 

func (m *QueryOutboundStateByChainIDRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryOutboundStateByChainIDRequest) XXX_Merge 

func (m *QueryOutboundStateByChainIDRequest) XXX_Merge(src proto.Message)

func (*QueryOutboundStateByChainIDRequest) XXX_Size 

func (m *QueryOutboundStateByChainIDRequest) XXX_Size() int

func (*QueryOutboundStateByChainIDRequest) XXX_Unmarshal 

func (m *QueryOutboundStateByChainIDRequest) XXX_Unmarshal(b []byte) error

type QueryServer 

type QueryServer interface {
	// Queries SystemContract
	GetEpochChangedOperatorSharesSnapshot(context.Context, *QueryEpochChangedOperatorSharesSnapshotRequest) (*QueryGetEpochChangedOperatorSharesSnapshotResponse, error)
	// Queries blocks per epoch
	GetEpochInfo(context.Context, *QueryEpochInfoRequest) (*QueryGetEpochInfoResponse, error)
	// Queries outbound state by chain id
	GetOutboundStateByChainID(context.Context, *QueryOutboundStateByChainIDRequest) (*QueryGetOutboundStateByChainIDResponse, error)
	// Queries dvs supported chain outbound state by chain id
	QueryDVSSupportedChainStatus(context.Context, *QueryDVSSupportedChainStatusRequest) (*QueryDVSSupportedChainStatusResponse, error)
	// Queries dvs group data sync status
	QueryDVSGroupSyncStatus(context.Context, *QueryDVSGroupSyncStatusRequest) (*QueryDVSGroupSyncStatusResponse, error)
	// Queries dvs supported chain list
	QueryDVSSupportedChainList(context.Context, *QueryDVSSupportedChainListRequest) (*QueryDVSSupportedChainListResponse, error)
	// Queries registry router list
	QueryDVSRegistryRouterList(context.Context, *QueryDVSRegistryRouterListRequest) (*QueryDVSRegistryRouterListResponse, error)
	// Queries group date list
	QueryDVSGroupDataList(context.Context, *QueryDVSGroupDataListRequest) (*QueryDVSGroupDataListResponse, error)
	// Queries group operator registration list
	QueryDVSGroupOperatorRegistrationList(context.Context, *QueryDVSGroupOperatorRegistrationListRequest) (*QueryDVSGroupOperatorRegistrationListResponse, error)
}

QueryServer is the server API for Query service.

type RegistryRouterData 

type RegistryRouterData struct {
	RegistryRouterSet             RegistryRouterSet               `protobuf:"bytes,1,opt,name=registry_router_set,json=registryRouterSet,proto3" json:"registry_router_set"`
	DvsInfoList                   DVSInfoList                     `protobuf:"bytes,2,opt,name=dvs_info_list,json=dvsInfoList,proto3" json:"dvs_info_list"`
	GroupList                     GroupList                       `protobuf:"bytes,3,opt,name=group_list,json=groupList,proto3" json:"group_list"`
	GroupOperatorRegistrationList GroupOperatorRegistrationListV2 `` /* 142-byte string literal not displayed */
}

RegistryRouterData is the data structure for registry router

func (*RegistryRouterData) Descriptor 

func (*RegistryRouterData) Descriptor() ([]byte, []int)

func (*RegistryRouterData) GetDvsInfoList 

func (m *RegistryRouterData) GetDvsInfoList() DVSInfoList

func (*RegistryRouterData) GetGroupList 

func (m *RegistryRouterData) GetGroupList() GroupList

func (*RegistryRouterData) GetGroupOperatorRegistrationList 

func (m *RegistryRouterData) GetGroupOperatorRegistrationList() GroupOperatorRegistrationListV2

func (*RegistryRouterData) GetRegistryRouterSet 

func (m *RegistryRouterData) GetRegistryRouterSet() RegistryRouterSet

func (*RegistryRouterData) Marshal 

func (m *RegistryRouterData) Marshal() (dAtA []byte, err error)

func (*RegistryRouterData) MarshalTo 

func (m *RegistryRouterData) MarshalTo(dAtA []byte) (int, error)

func (*RegistryRouterData) MarshalToSizedBuffer 

func (m *RegistryRouterData) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegistryRouterData) ProtoMessage 

func (*RegistryRouterData) ProtoMessage()

func (*RegistryRouterData) Reset 

func (m *RegistryRouterData) Reset()

func (*RegistryRouterData) Size 

func (m *RegistryRouterData) Size() (n int)

func (*RegistryRouterData) String 

func (m *RegistryRouterData) String() string

func (*RegistryRouterData) Unmarshal 

func (m *RegistryRouterData) Unmarshal(dAtA []byte) error

func (*RegistryRouterData) XXX_DiscardUnknown 

func (m *RegistryRouterData) XXX_DiscardUnknown()

func (*RegistryRouterData) XXX_Marshal 

func (m *RegistryRouterData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegistryRouterData) XXX_Merge 

func (m *RegistryRouterData) XXX_Merge(src proto.Message)

func (*RegistryRouterData) XXX_Size 

func (m *RegistryRouterData) XXX_Size() int

func (*RegistryRouterData) XXX_Unmarshal 

func (m *RegistryRouterData) XXX_Unmarshal(b []byte) error

type RegistryRouterList 

type RegistryRouterList struct {
	Addresses []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
}

RegistryRouterList is a list of registry router addresses

func (*RegistryRouterList) Descriptor 

func (*RegistryRouterList) Descriptor() ([]byte, []int)

func (*RegistryRouterList) GetAddresses 

func (m *RegistryRouterList) GetAddresses() []string

func (*RegistryRouterList) Marshal 

func (m *RegistryRouterList) Marshal() (dAtA []byte, err error)

func (*RegistryRouterList) MarshalTo 

func (m *RegistryRouterList) MarshalTo(dAtA []byte) (int, error)

func (*RegistryRouterList) MarshalToSizedBuffer 

func (m *RegistryRouterList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegistryRouterList) ProtoMessage 

func (*RegistryRouterList) ProtoMessage()

func (*RegistryRouterList) Reset 

func (m *RegistryRouterList) Reset()

func (*RegistryRouterList) Size 

func (m *RegistryRouterList) Size() (n int)

func (*RegistryRouterList) String 

func (m *RegistryRouterList) String() string

func (*RegistryRouterList) Unmarshal 

func (m *RegistryRouterList) Unmarshal(dAtA []byte) error

func (*RegistryRouterList) XXX_DiscardUnknown 

func (m *RegistryRouterList) XXX_DiscardUnknown()

func (*RegistryRouterList) XXX_Marshal 

func (m *RegistryRouterList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegistryRouterList) XXX_Merge 

func (m *RegistryRouterList) XXX_Merge(src proto.Message)

func (*RegistryRouterList) XXX_Size 

func (m *RegistryRouterList) XXX_Size() int

func (*RegistryRouterList) XXX_Unmarshal 

func (m *RegistryRouterList) XXX_Unmarshal(b []byte) error

type RegistryRouterSet 

type RegistryRouterSet struct {
	RegistryRouterAddress      string `` /* 126-byte string literal not displayed */
	StakeRegistryRouterAddress string `` /* 143-byte string literal not displayed */
}

RegistryRouterSet is a set of registry router address and stake registry router address

func (*RegistryRouterSet) Descriptor 

func (*RegistryRouterSet) Descriptor() ([]byte, []int)

func (*RegistryRouterSet) GetRegistryRouterAddress 

func (m *RegistryRouterSet) GetRegistryRouterAddress() string

func (*RegistryRouterSet) GetStakeRegistryRouterAddress 

func (m *RegistryRouterSet) GetStakeRegistryRouterAddress() string

func (*RegistryRouterSet) Marshal 

func (m *RegistryRouterSet) Marshal() (dAtA []byte, err error)

func (*RegistryRouterSet) MarshalTo 

func (m *RegistryRouterSet) MarshalTo(dAtA []byte) (int, error)

func (*RegistryRouterSet) MarshalToSizedBuffer 

func (m *RegistryRouterSet) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RegistryRouterSet) ProtoMessage 

func (*RegistryRouterSet) ProtoMessage()

func (*RegistryRouterSet) Reset 

func (m *RegistryRouterSet) Reset()

func (*RegistryRouterSet) Size 

func (m *RegistryRouterSet) Size() (n int)

func (*RegistryRouterSet) String 

func (m *RegistryRouterSet) String() string

func (*RegistryRouterSet) Unmarshal 

func (m *RegistryRouterSet) Unmarshal(dAtA []byte) error

func (*RegistryRouterSet) XXX_DiscardUnknown 

func (m *RegistryRouterSet) XXX_DiscardUnknown()

func (*RegistryRouterSet) XXX_Marshal 

func (m *RegistryRouterSet) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegistryRouterSet) XXX_Merge 

func (m *RegistryRouterSet) XXX_Merge(src proto.Message)

func (*RegistryRouterSet) XXX_Size 

func (m *RegistryRouterSet) XXX_Size() int

func (*RegistryRouterSet) XXX_Unmarshal 

func (m *RegistryRouterSet) XXX_Unmarshal(b []byte) error

type RelayerKeeper 

type RelayerKeeper interface {
	SetPevmKeeper(pevmKeeper relayertypes.PevmKeeper)
	GetSupportedChains(ctx sdk.Context) []*chains.Chain
	GetTSS(ctx sdk.Context) (tss relayertypes.TSS, found bool)
	GetSupportedChainFromChainID(ctx sdk.Context, chainID int64) *chains.Chain
	GetChainParamsByChainID(ctx sdk.Context, chainID int64) (*relayertypes.ChainParams, bool)
	IsInboundEnabled(ctx sdk.Context) (found bool)
}

type SignatureWithSaltAndExpiry 

type SignatureWithSaltAndExpiry struct {
	Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"`
	Salt      []byte `protobuf:"bytes,2,opt,name=salt,proto3" json:"salt,omitempty"`
	Expiry    uint64 `protobuf:"varint,3,opt,name=expiry,proto3" json:"expiry,omitempty"`
}

SignatureWithSaltAndExpiry holds the operator's signature details

func (*SignatureWithSaltAndExpiry) Descriptor 

func (*SignatureWithSaltAndExpiry) Descriptor() ([]byte, []int)

func (*SignatureWithSaltAndExpiry) GetExpiry 

func (m *SignatureWithSaltAndExpiry) GetExpiry() uint64

func (*SignatureWithSaltAndExpiry) GetSalt 

func (m *SignatureWithSaltAndExpiry) GetSalt() []byte

func (*SignatureWithSaltAndExpiry) GetSignature 

func (m *SignatureWithSaltAndExpiry) GetSignature() []byte

func (*SignatureWithSaltAndExpiry) Marshal 

func (m *SignatureWithSaltAndExpiry) Marshal() (dAtA []byte, err error)

func (*SignatureWithSaltAndExpiry) MarshalTo 

func (m *SignatureWithSaltAndExpiry) MarshalTo(dAtA []byte) (int, error)

func (*SignatureWithSaltAndExpiry) MarshalToSizedBuffer 

func (m *SignatureWithSaltAndExpiry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SignatureWithSaltAndExpiry) ProtoMessage 

func (*SignatureWithSaltAndExpiry) ProtoMessage()

func (*SignatureWithSaltAndExpiry) Reset 

func (m *SignatureWithSaltAndExpiry) Reset()

func (*SignatureWithSaltAndExpiry) Size 

func (m *SignatureWithSaltAndExpiry) Size() (n int)

func (*SignatureWithSaltAndExpiry) String 

func (m *SignatureWithSaltAndExpiry) String() string

func (*SignatureWithSaltAndExpiry) Unmarshal 

func (m *SignatureWithSaltAndExpiry) Unmarshal(dAtA []byte) error

func (*SignatureWithSaltAndExpiry) XXX_DiscardUnknown 

func (m *SignatureWithSaltAndExpiry) XXX_DiscardUnknown()

func (*SignatureWithSaltAndExpiry) XXX_Marshal 

func (m *SignatureWithSaltAndExpiry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SignatureWithSaltAndExpiry) XXX_Merge 

func (m *SignatureWithSaltAndExpiry) XXX_Merge(src proto.Message)

func (*SignatureWithSaltAndExpiry) XXX_Size 

func (m *SignatureWithSaltAndExpiry) XXX_Size() int

func (*SignatureWithSaltAndExpiry) XXX_Unmarshal 

func (m *SignatureWithSaltAndExpiry) XXX_Unmarshal(b []byte) error

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) UpdateBlocksPerEpoch 

func (*UnimplementedMsgServer) UpdateBlocksPerEpoch(ctx context.Context, req *MsgUpdateBlocksPerEpoch) (*MsgUpdateBlocksPerEpochResponse, error)

func (*UnimplementedMsgServer) UpsertOutboundState 

func (*UnimplementedMsgServer) UpsertOutboundState(ctx context.Context, req *MsgUpsertOutboundState) (*MsgUpsertOutboundStateResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetEpochChangedOperatorSharesSnapshot 

func (*UnimplementedQueryServer) GetEpochChangedOperatorSharesSnapshot(ctx context.Context, req *QueryEpochChangedOperatorSharesSnapshotRequest) (*QueryGetEpochChangedOperatorSharesSnapshotResponse, error)

func (*UnimplementedQueryServer) GetEpochInfo 

func (*UnimplementedQueryServer) GetEpochInfo(ctx context.Context, req *QueryEpochInfoRequest) (*QueryGetEpochInfoResponse, error)

func (*UnimplementedQueryServer) GetOutboundStateByChainID 

func (*UnimplementedQueryServer) GetOutboundStateByChainID(ctx context.Context, req *QueryOutboundStateByChainIDRequest) (*QueryGetOutboundStateByChainIDResponse, error)

func (*UnimplementedQueryServer) QueryDVSGroupDataList 

func (*UnimplementedQueryServer) QueryDVSGroupDataList(ctx context.Context, req *QueryDVSGroupDataListRequest) (*QueryDVSGroupDataListResponse, error)

func (*UnimplementedQueryServer) QueryDVSGroupOperatorRegistrationList 

func (*UnimplementedQueryServer) QueryDVSGroupOperatorRegistrationList(ctx context.Context, req *QueryDVSGroupOperatorRegistrationListRequest) (*QueryDVSGroupOperatorRegistrationListResponse, error)

func (*UnimplementedQueryServer) QueryDVSGroupSyncStatus 

func (*UnimplementedQueryServer) QueryDVSGroupSyncStatus(ctx context.Context, req *QueryDVSGroupSyncStatusRequest) (*QueryDVSGroupSyncStatusResponse, error)

func (*UnimplementedQueryServer) QueryDVSRegistryRouterList 

func (*UnimplementedQueryServer) QueryDVSRegistryRouterList(ctx context.Context, req *QueryDVSRegistryRouterListRequest) (*QueryDVSRegistryRouterListResponse, error)

func (*UnimplementedQueryServer) QueryDVSSupportedChainList 

func (*UnimplementedQueryServer) QueryDVSSupportedChainList(ctx context.Context, req *QueryDVSSupportedChainListRequest) (*QueryDVSSupportedChainListResponse, error)

func (*UnimplementedQueryServer) QueryDVSSupportedChainStatus 

func (*UnimplementedQueryServer) QueryDVSSupportedChainStatus(ctx context.Context, req *QueryDVSSupportedChainStatusRequest) (*QueryDVSSupportedChainStatusResponse, error)

type XmsgKeeper 

type XmsgKeeper interface {
	GetGasPrice(ctx sdk.Context, chainID int64) (val xmsgtypes.GasPrice, found bool)
	ProcessXmsg(ctx sdk.Context, xmsg xmsgtypes.Xmsg, receiverChain *chains.Chain) error
	ProcessPellSentEvent(
		ctx sdk.Context,
		event *pellconnector.PellConnectorPellSent,
		emittingContract ethcommon.Address,
		txOrigin string,
		tss relayertypes.TSS,
	) error
	IsAllowedXmsgSender(ctx sdk.Context, builder string) bool
	XmsgAll(c context.Context, req *xmsgtypes.QueryAllXmsgRequest) (*xmsgtypes.QueryXmsgAllResponse, error)
	GetAllCrosschainEventFees(ctx sdk.Context) ([]xmsgtypes.CrosschainFeeParam, error)
	GetCrosschainEventFee(ctx sdk.Context, chainId int64) (xmsgtypes.CrosschainFeeParam, bool)
	DeductFees(ctx sdk.Context, fees []*xmsgtypes.CrossChainFee) error
}

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.