types

package
v1.4.6 Latest Latest
Warning

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

 Go to latest Published: Jan 12, 2025 License: MIT Imports: 27 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// AdhocRequestKeyPrefix is the prefix to retrieve all adhoc requests
	AdhocRequestKeyPrefix = "AdhocRequest/value/"
	// AdhocRequestNonceKey is the key to retrieve the nonce of the latest adhoc request
	AdhocRequestNonceKey = "AdhocRequestNonce/value/"
)
View Source 
const (
	// ModuleName defines the module name
	ModuleName = "txlookup"

	// 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_txlookup"
)
View Source 
const (
	DefaultGasPrice = uint64(50000000)
)
View Source 
const DefaultIndex uint64 = 1

DefaultIndex is the default global index

View Source 
const (
	// TxDataRequestKeyPrefix is the prefix to retrieve all tx data requests
	TxDataRequestKeyPrefix = "TxDataRequest/value/"
)
View Source 
const TypeMsgCreateAdhocRequest = "create_adhoc_request"
View Source 
const TypeMsgCreateTxDataRequest = "create_tx_data_request"
View Source 
const (
	// ValidatedTxDataRequestKeyPrefix is the prefix to retrieve all validated tx data requests
	ValidatedTxDataRequestKeyPrefix = "ValidatedTxDataRequest/value/"
)

Variables

View Source 
var (
	ErrInvalidLengthAdhocRequest        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAdhocRequest          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAdhocRequest = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var (
	ErrInvalidAmount     = errorsmod.Register(ModuleName, 1, "invalid amount")
	ErrInsufficientFunds = errorsmod.Register(ModuleName, 2, "insufficient funds")
	ErrUnregisteredChain = errorsmod.Register(ModuleName, 3, "unregistered chain id")
	ErrInvalidGasLimit   = errorsmod.Register(ModuleName, 4, "invalid gas limit")
	ErrAlreadyExisted    = errorsmod.Register(ModuleName, 5, "already existed")
	ErrInput             = errorsmod.Register(ModuleName, 6, "wrong input")
)

x/pricefeed module sentinel errors

View Source 
var (
	ErrInvalidLengthEvents        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group")
)
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 (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = 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 (
	ErrInvalidLengthTxDataRequest        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTxDataRequest          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTxDataRequest = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	KeyGasPrice = []byte("GasPrice")
)

Functions

func AdhocRequestKey 

func AdhocRequestKey(
	middlewareContractAddress string,
	chainIds []string,
	hashes []string,
	metadata [][]byte,
) []byte

AdhocRequestKey returns the store key to retrieve a adhoc request from the index fields

func KeyPrefix 

func KeyPrefix(p string) []byte

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable the param key table for launch module

func RegisterCodec 

func RegisterCodec(cdc *codec.LegacyAmino)

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterLegacyAminoCodec 

func RegisterLegacyAminoCodec(cdc *codec.LegacyAmino)

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func TxDataRequestKey 

func TxDataRequestKey(
	chainId string,
	txHash string,
	claimHash []byte,
) []byte

TxDataRequestKey returns the store key to retrieve a transaction data request from the index fields

func ValidatedTxDataRequestKey 

func ValidatedTxDataRequestKey(
	chainId string,
	txHash string,
) []byte

ValidatedTxDataRequestKey returns the store key to retrieve a transaction data request from the index fields

Types

type AdhocRequest 

type AdhocRequest struct {
	From                      string     `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ChainIds                  []string   `protobuf:"bytes,2,rep,name=chain_ids,json=chainIds,proto3" json:"chain_ids,omitempty"`
	TxHashes                  []string   `protobuf:"bytes,3,rep,name=tx_hashes,json=txHashes,proto3" json:"tx_hashes,omitempty"`
	MetaData                  [][]byte   `protobuf:"bytes,4,rep,name=meta_data,json=metaData,proto3" json:"meta_data,omitempty"`
	MiddlewareContractAddress string     `` /* 138-byte string literal not displayed */
	ProcessingFee             types.Coin `protobuf:"bytes,6,opt,name=processing_fee,json=processingFee,proto3" json:"processing_fee"`
	GasLimit                  uint64     `protobuf:"varint,7,opt,name=gas_limit,json=gasLimit,proto3" json:"gas_limit,omitempty"`
}

func (*AdhocRequest) Descriptor 

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

func (*AdhocRequest) GetChainIds 

func (m *AdhocRequest) GetChainIds() []string

func (*AdhocRequest) GetFrom 

func (m *AdhocRequest) GetFrom() string

func (*AdhocRequest) GetGasLimit 

func (m *AdhocRequest) GetGasLimit() uint64

func (*AdhocRequest) GetMetaData 

func (m *AdhocRequest) GetMetaData() [][]byte

func (*AdhocRequest) GetMiddlewareContractAddress 

func (m *AdhocRequest) GetMiddlewareContractAddress() string

func (*AdhocRequest) GetProcessingFee 

func (m *AdhocRequest) GetProcessingFee() types.Coin

func (*AdhocRequest) GetTxHashes 

func (m *AdhocRequest) GetTxHashes() []string

func (*AdhocRequest) Marshal 

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

func (*AdhocRequest) MarshalTo 

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

func (*AdhocRequest) MarshalToSizedBuffer 

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

func (*AdhocRequest) ProtoMessage 

func (*AdhocRequest) ProtoMessage()

func (*AdhocRequest) Reset 

func (m *AdhocRequest) Reset()

func (*AdhocRequest) Size 

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

func (*AdhocRequest) String 

func (m *AdhocRequest) String() string

func (*AdhocRequest) Unmarshal 

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

func (*AdhocRequest) XXX_DiscardUnknown 

func (m *AdhocRequest) XXX_DiscardUnknown()

func (*AdhocRequest) XXX_Marshal 

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

func (*AdhocRequest) XXX_Merge 

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

func (*AdhocRequest) XXX_Size 

func (m *AdhocRequest) XXX_Size() int

func (*AdhocRequest) XXX_Unmarshal 

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

type AttestationKeeper 

type AttestationKeeper interface {
	// Methods imported from attestation should be defined here
	CheckOrchestratorValidatorInSet(ctx sdk.Context, orchestrator string) error
	ClaimHandlerCommon(ctx sdk.Context, msgAny *codectypes.Any, msg attestationTypes.Claim, isAdhoc bool) error
	TallyAdhocAttestation(ctx sdk.Context, chainId string, txHash string, claimHash []byte)
	GetObservedAttestation(ctx sdk.Context, chainId string, contract string, eventNonce uint64, claimHash []byte) (val attestationTypes.Attestation, found bool)
}

type BankKeeper 

type BankKeeper interface {
	GetBalance(ctx sdk.Context, addr sdk.AccAddress, denom string) sdk.Coin
	SendCoinsFromAccountToModule(ctx sdk.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx sdk.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
}

BankKeeper defines the expected interface needed to retrieve account balances.

type EventTxDataRequestCreated 

type EventTxDataRequestCreated struct {
	AttestationId []byte `protobuf:"bytes,1,opt,name=attestation_id,json=attestationId,proto3" json:"attestation_id,omitempty"`
	ChainId       string `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	TxHash        string `protobuf:"bytes,3,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	BlockHeight   uint64 `protobuf:"varint,4,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
}

func (*EventTxDataRequestCreated) Descriptor 

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

func (*EventTxDataRequestCreated) GetAttestationId 

func (m *EventTxDataRequestCreated) GetAttestationId() []byte

func (*EventTxDataRequestCreated) GetBlockHeight 

func (m *EventTxDataRequestCreated) GetBlockHeight() uint64

func (*EventTxDataRequestCreated) GetChainId 

func (m *EventTxDataRequestCreated) GetChainId() string

func (*EventTxDataRequestCreated) GetTxHash 

func (m *EventTxDataRequestCreated) GetTxHash() string

func (*EventTxDataRequestCreated) Marshal 

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

func (*EventTxDataRequestCreated) MarshalTo 

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

func (*EventTxDataRequestCreated) MarshalToSizedBuffer 

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

func (*EventTxDataRequestCreated) ProtoMessage 

func (*EventTxDataRequestCreated) ProtoMessage()

func (*EventTxDataRequestCreated) Reset 

func (m *EventTxDataRequestCreated) Reset()

func (*EventTxDataRequestCreated) Size 

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

func (*EventTxDataRequestCreated) String 

func (m *EventTxDataRequestCreated) String() string

func (*EventTxDataRequestCreated) Unmarshal 

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

func (*EventTxDataRequestCreated) XXX_DiscardUnknown 

func (m *EventTxDataRequestCreated) XXX_DiscardUnknown()

func (*EventTxDataRequestCreated) XXX_Marshal 

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

func (*EventTxDataRequestCreated) XXX_Merge 

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

func (*EventTxDataRequestCreated) XXX_Size 

func (m *EventTxDataRequestCreated) XXX_Size() int

func (*EventTxDataRequestCreated) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params            Params          `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	AdhocRequestList  []AdhocRequest  `protobuf:"bytes,2,rep,name=adhoc_request_list,json=adhocRequestList,proto3" json:"adhoc_request_list"`
	TxDataRequestList []TxDataRequest `protobuf:"bytes,3,rep,name=tx_data_request_list,json=txDataRequestList,proto3" json:"tx_data_request_list"`
}

GenesisState defines the txlookup module's genesis state.

func DefaultGenesis 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetAdhocRequestList 

func (m *GenesisState) GetAdhocRequestList() []AdhocRequest

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetTxDataRequestList 

func (m *GenesisState) GetTxDataRequestList() []TxDataRequest

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 HandleAdhocRequest 

type HandleAdhocRequest struct {
	ChainIds    []string `json:"chain_ids"`
	TxHashes    []string `json:"tx_hashes"`
	TxResponses [][]byte `json:"tx_responses"`
	MetaData    [][]byte `json:"meta_data"`
}

type MsgClient 

type MsgClient interface {
	// CreateAdhocRequest defines a method to initiate an adhoc request from the user
	CreateAdhocRequest(ctx context.Context, in *MsgCreateAdhocRequest, opts ...grpc.CallOption) (*MsgCreateAdhocResponse, error)
	// CreateTxDataRequest defines a method to submit transaction data from orchestrator
	CreateTxDataRequest(ctx context.Context, in *MsgCreateTxDataRequest, opts ...grpc.CallOption) (*MsgCreateTxDataResponse, 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 MsgCreateAdhocRequest 

type MsgCreateAdhocRequest struct {
	From                      string     `protobuf:"bytes,1,opt,name=from,proto3" json:"from,omitempty"`
	ChainIds                  []string   `protobuf:"bytes,2,rep,name=chain_ids,json=chainIds,proto3" json:"chain_ids,omitempty"`
	TxHashes                  []string   `protobuf:"bytes,3,rep,name=tx_hashes,json=txHashes,proto3" json:"tx_hashes,omitempty"`
	MetaData                  [][]byte   `protobuf:"bytes,4,rep,name=meta_data,json=metaData,proto3" json:"meta_data,omitempty"`
	MiddlewareContractAddress string     `` /* 138-byte string literal not displayed */
	Fee                       types.Coin `protobuf:"bytes,6,opt,name=fee,proto3" json:"fee"`
	CwGasLimit                uint64     `protobuf:"varint,7,opt,name=cw_gas_limit,json=cwGasLimit,proto3" json:"cw_gas_limit,omitempty"`
}

func NewMsgCreateAdhocRequest 

func NewMsgCreateAdhocRequest(from string, chainIds []string, txHashes []string, metaData [][]byte, middlewareContractAddress string, fee sdk.Coin, gasLimit uint64) *MsgCreateAdhocRequest

func (*MsgCreateAdhocRequest) Descriptor 

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

func (*MsgCreateAdhocRequest) GetChainIds 

func (m *MsgCreateAdhocRequest) GetChainIds() []string

func (*MsgCreateAdhocRequest) GetCwGasLimit 

func (m *MsgCreateAdhocRequest) GetCwGasLimit() uint64

func (*MsgCreateAdhocRequest) GetFee 

func (m *MsgCreateAdhocRequest) GetFee() types.Coin

func (*MsgCreateAdhocRequest) GetFrom 

func (m *MsgCreateAdhocRequest) GetFrom() string

func (*MsgCreateAdhocRequest) GetMetaData 

func (m *MsgCreateAdhocRequest) GetMetaData() [][]byte

func (*MsgCreateAdhocRequest) GetMiddlewareContractAddress 

func (m *MsgCreateAdhocRequest) GetMiddlewareContractAddress() string

func (*MsgCreateAdhocRequest) GetSignBytes 

func (msg *MsgCreateAdhocRequest) GetSignBytes() []byte

func (*MsgCreateAdhocRequest) GetSigners 

func (msg *MsgCreateAdhocRequest) GetSigners() []sdk.AccAddress

func (*MsgCreateAdhocRequest) GetTxHashes 

func (m *MsgCreateAdhocRequest) GetTxHashes() []string

func (*MsgCreateAdhocRequest) Marshal 

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

func (*MsgCreateAdhocRequest) MarshalTo 

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

func (*MsgCreateAdhocRequest) MarshalToSizedBuffer 

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

func (*MsgCreateAdhocRequest) ProtoMessage 

func (*MsgCreateAdhocRequest) ProtoMessage()

func (*MsgCreateAdhocRequest) Reset 

func (m *MsgCreateAdhocRequest) Reset()

func (*MsgCreateAdhocRequest) Route 

func (msg *MsgCreateAdhocRequest) Route() string

func (*MsgCreateAdhocRequest) Size 

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

func (*MsgCreateAdhocRequest) String 

func (m *MsgCreateAdhocRequest) String() string

func (*MsgCreateAdhocRequest) Type 

func (msg *MsgCreateAdhocRequest) Type() string

func (*MsgCreateAdhocRequest) Unmarshal 

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

func (*MsgCreateAdhocRequest) ValidateBasic 

func (msg *MsgCreateAdhocRequest) ValidateBasic() (err error)

func (*MsgCreateAdhocRequest) XXX_DiscardUnknown 

func (m *MsgCreateAdhocRequest) XXX_DiscardUnknown()

func (*MsgCreateAdhocRequest) XXX_Marshal 

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

func (*MsgCreateAdhocRequest) XXX_Merge 

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

func (*MsgCreateAdhocRequest) XXX_Size 

func (m *MsgCreateAdhocRequest) XXX_Size() int

func (*MsgCreateAdhocRequest) XXX_Unmarshal 

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

type MsgCreateAdhocResponse 

type MsgCreateAdhocResponse struct {
}

func (*MsgCreateAdhocResponse) Descriptor 

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

func (*MsgCreateAdhocResponse) Marshal 

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

func (*MsgCreateAdhocResponse) MarshalTo 

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

func (*MsgCreateAdhocResponse) MarshalToSizedBuffer 

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

func (*MsgCreateAdhocResponse) ProtoMessage 

func (*MsgCreateAdhocResponse) ProtoMessage()

func (*MsgCreateAdhocResponse) Reset 

func (m *MsgCreateAdhocResponse) Reset()

func (*MsgCreateAdhocResponse) Size 

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

func (*MsgCreateAdhocResponse) String 

func (m *MsgCreateAdhocResponse) String() string

func (*MsgCreateAdhocResponse) Unmarshal 

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

func (*MsgCreateAdhocResponse) XXX_DiscardUnknown 

func (m *MsgCreateAdhocResponse) XXX_DiscardUnknown()

func (*MsgCreateAdhocResponse) XXX_Marshal 

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

func (*MsgCreateAdhocResponse) XXX_Merge 

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

func (*MsgCreateAdhocResponse) XXX_Size 

func (m *MsgCreateAdhocResponse) XXX_Size() int

func (*MsgCreateAdhocResponse) XXX_Unmarshal 

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

type MsgCreateTxDataRequest 

type MsgCreateTxDataRequest struct {
	Orchestrator string `protobuf:"bytes,1,opt,name=orchestrator,proto3" json:"orchestrator,omitempty"`
	ChainId      string `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	TxHash       string `protobuf:"bytes,3,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	TxData       []byte `protobuf:"bytes,4,opt,name=tx_data,json=txData,proto3" json:"tx_data,omitempty"`
	BlockHeight  uint64 `protobuf:"varint,5,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
}

func NewMsgCreateTxDataRequest 

func NewMsgCreateTxDataRequest(orchestrator string, chainId string, txHash string, txData []byte, blockHeight uint64) *MsgCreateTxDataRequest

func (*MsgCreateTxDataRequest) ClaimHash 

func (msg *MsgCreateTxDataRequest) ClaimHash() ([]byte, error)

Hash implements MsgCreateTxDataRequest.Hash modify this with care as it is security sensitive. If an element of the claim is not in this hash a single hostile validator could engineer a hash collision and execute a version of the claim with any unhashed data changed to benefit them. note that the Orchestrator is the only field excluded from this hash, this is because that value is used higher up in the store structure for who has made what claim and is verified by the msg ante-handler for signatures

func (*MsgCreateTxDataRequest) Descriptor 

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

func (*MsgCreateTxDataRequest) GetBlockHeight 

func (m *MsgCreateTxDataRequest) GetBlockHeight() uint64

func (*MsgCreateTxDataRequest) GetChainId 

func (m *MsgCreateTxDataRequest) GetChainId() string

func (MsgCreateTxDataRequest) GetClaimer 

func (msg MsgCreateTxDataRequest) GetClaimer() sdk.AccAddress

func (MsgCreateTxDataRequest) GetContract 

func (msg MsgCreateTxDataRequest) GetContract() string

func (MsgCreateTxDataRequest) GetEventNonce 

func (msg MsgCreateTxDataRequest) GetEventNonce() uint64

func (*MsgCreateTxDataRequest) GetOrchestrator 

func (m *MsgCreateTxDataRequest) GetOrchestrator() string

func (*MsgCreateTxDataRequest) GetSignBytes 

func (msg *MsgCreateTxDataRequest) GetSignBytes() []byte

func (*MsgCreateTxDataRequest) GetSigners 

func (msg *MsgCreateTxDataRequest) GetSigners() []sdk.AccAddress

func (*MsgCreateTxDataRequest) GetTxData 

func (m *MsgCreateTxDataRequest) GetTxData() []byte

func (*MsgCreateTxDataRequest) GetTxHash 

func (m *MsgCreateTxDataRequest) GetTxHash() string

func (*MsgCreateTxDataRequest) GetType 

func (msg *MsgCreateTxDataRequest) GetType() attestationTypes.ClaimType

GetType returns the type of the claim

func (*MsgCreateTxDataRequest) Marshal 

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

func (*MsgCreateTxDataRequest) MarshalTo 

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

func (*MsgCreateTxDataRequest) MarshalToSizedBuffer 

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

func (*MsgCreateTxDataRequest) ProtoMessage 

func (*MsgCreateTxDataRequest) ProtoMessage()

func (*MsgCreateTxDataRequest) Reset 

func (m *MsgCreateTxDataRequest) Reset()

func (*MsgCreateTxDataRequest) Route 

func (msg *MsgCreateTxDataRequest) Route() string

func (*MsgCreateTxDataRequest) Size 

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

func (*MsgCreateTxDataRequest) String 

func (m *MsgCreateTxDataRequest) String() string

func (*MsgCreateTxDataRequest) Type 

func (msg *MsgCreateTxDataRequest) Type() string

func (*MsgCreateTxDataRequest) Unmarshal 

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

func (*MsgCreateTxDataRequest) ValidateBasic 

func (msg *MsgCreateTxDataRequest) ValidateBasic() error

func (*MsgCreateTxDataRequest) XXX_DiscardUnknown 

func (m *MsgCreateTxDataRequest) XXX_DiscardUnknown()

func (*MsgCreateTxDataRequest) XXX_Marshal 

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

func (*MsgCreateTxDataRequest) XXX_Merge 

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

func (*MsgCreateTxDataRequest) XXX_Size 

func (m *MsgCreateTxDataRequest) XXX_Size() int

func (*MsgCreateTxDataRequest) XXX_Unmarshal 

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

type MsgCreateTxDataResponse 

type MsgCreateTxDataResponse struct {
}

func (*MsgCreateTxDataResponse) Descriptor 

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

func (*MsgCreateTxDataResponse) Marshal 

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

func (*MsgCreateTxDataResponse) MarshalTo 

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

func (*MsgCreateTxDataResponse) MarshalToSizedBuffer 

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

func (*MsgCreateTxDataResponse) ProtoMessage 

func (*MsgCreateTxDataResponse) ProtoMessage()

func (*MsgCreateTxDataResponse) Reset 

func (m *MsgCreateTxDataResponse) Reset()

func (*MsgCreateTxDataResponse) Size 

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

func (*MsgCreateTxDataResponse) String 

func (m *MsgCreateTxDataResponse) String() string

func (*MsgCreateTxDataResponse) Unmarshal 

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

func (*MsgCreateTxDataResponse) XXX_DiscardUnknown 

func (m *MsgCreateTxDataResponse) XXX_DiscardUnknown()

func (*MsgCreateTxDataResponse) XXX_Marshal 

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

func (*MsgCreateTxDataResponse) XXX_Merge 

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

func (*MsgCreateTxDataResponse) XXX_Size 

func (m *MsgCreateTxDataResponse) XXX_Size() int

func (*MsgCreateTxDataResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// CreateAdhocRequest defines a method to initiate an adhoc request from the user
	CreateAdhocRequest(context.Context, *MsgCreateAdhocRequest) (*MsgCreateAdhocResponse, error)
	// CreateTxDataRequest defines a method to submit transaction data from orchestrator
	CreateTxDataRequest(context.Context, *MsgCreateTxDataRequest) (*MsgCreateTxDataResponse, error)
}

MsgServer is the server API for Msg service.

type MultichainKeeper 

type MultichainKeeper interface {
	GetChainConfig(ctx sdk.Context, chainId string) (val multichainTypes.ChainConfig, found bool)
	IsNonceObserved(ctx sdk.Context, chainId string, contractAddress string, nonce uint64) (isObserved bool)
}

type Params 

type Params struct {
	GasPrice uint64 `protobuf:"varint,1,opt,name=gas_price,json=gasPrice,proto3" json:"gas_price,omitempty"`
}

Params defines the parameters for the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams 

func NewParams(
	gasPrice uint64,
) Params

NewParams creates a new Params instance

func (*Params) Descriptor 

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

func (*Params) GetGasPrice 

func (m *Params) GetGasPrice() uint64

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) ParamSetPairs 

func (p *Params) ParamSetPairs() paramtypes.ParamSetPairs

ParamSetPairs get the params.ParamSet

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 (p Params) String() string

String implements the Stringer interface.

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate validates the set of params

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 QueryClient 

type QueryClient interface {
	// Params queries the parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// ListAdhocRequests queries a list of adhoc request items.
	ListAdhocRequests(ctx context.Context, in *QueryListAdhocRequest, opts ...grpc.CallOption) (*QueryListAdhocResponse, error)
	// ListAdhocRequestsByMiddleware queries a list of adhoc request items for the certain middleware.
	ListAdhocRequestsByMiddleware(ctx context.Context, in *QueryListAdhocByMiddlewareRequest, opts ...grpc.CallOption) (*QueryListAdhocByMiddlewareResponse, error)
	// ListTxDataRequests queries a list of tx data request items.
	ListTxDataRequests(ctx context.Context, in *QueryListTxDataRequest, opts ...grpc.CallOption) (*QueryListTxDataResponse, 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 QueryListAdhocByMiddlewareRequest 

type QueryListAdhocByMiddlewareRequest struct {
	MiddlewareAddress string `protobuf:"bytes,1,opt,name=middleware_address,json=middlewareAddress,proto3" json:"middleware_address,omitempty"`
}

QueryListAdhocByMiddlewareRequest is request type for the Query/ListAdhocRequests RPC method.

func (*QueryListAdhocByMiddlewareRequest) Descriptor 

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

func (*QueryListAdhocByMiddlewareRequest) GetMiddlewareAddress 

func (m *QueryListAdhocByMiddlewareRequest) GetMiddlewareAddress() string

func (*QueryListAdhocByMiddlewareRequest) Marshal 

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

func (*QueryListAdhocByMiddlewareRequest) MarshalTo 

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

func (*QueryListAdhocByMiddlewareRequest) MarshalToSizedBuffer 

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

func (*QueryListAdhocByMiddlewareRequest) ProtoMessage 

func (*QueryListAdhocByMiddlewareRequest) ProtoMessage()

func (*QueryListAdhocByMiddlewareRequest) Reset 

func (m *QueryListAdhocByMiddlewareRequest) Reset()

func (*QueryListAdhocByMiddlewareRequest) Size 

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

func (*QueryListAdhocByMiddlewareRequest) String 

func (m *QueryListAdhocByMiddlewareRequest) String() string

func (*QueryListAdhocByMiddlewareRequest) Unmarshal 

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

func (*QueryListAdhocByMiddlewareRequest) XXX_DiscardUnknown 

func (m *QueryListAdhocByMiddlewareRequest) XXX_DiscardUnknown()

func (*QueryListAdhocByMiddlewareRequest) XXX_Marshal 

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

func (*QueryListAdhocByMiddlewareRequest) XXX_Merge 

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

func (*QueryListAdhocByMiddlewareRequest) XXX_Size 

func (m *QueryListAdhocByMiddlewareRequest) XXX_Size() int

func (*QueryListAdhocByMiddlewareRequest) XXX_Unmarshal 

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

type QueryListAdhocByMiddlewareResponse 

type QueryListAdhocByMiddlewareResponse struct {
	AdhocRequests []AdhocRequest `protobuf:"bytes,1,rep,name=adhoc_requests,json=adhocRequests,proto3" json:"adhoc_requests"`
}

QueryListAdhocByMiddlewareResponse is response type for the Query/ListAdhocRequests RPC method.

func (*QueryListAdhocByMiddlewareResponse) Descriptor 

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

func (*QueryListAdhocByMiddlewareResponse) GetAdhocRequests 

func (m *QueryListAdhocByMiddlewareResponse) GetAdhocRequests() []AdhocRequest

func (*QueryListAdhocByMiddlewareResponse) Marshal 

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

func (*QueryListAdhocByMiddlewareResponse) MarshalTo 

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

func (*QueryListAdhocByMiddlewareResponse) MarshalToSizedBuffer 

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

func (*QueryListAdhocByMiddlewareResponse) ProtoMessage 

func (*QueryListAdhocByMiddlewareResponse) ProtoMessage()

func (*QueryListAdhocByMiddlewareResponse) Reset 

func (m *QueryListAdhocByMiddlewareResponse) Reset()

func (*QueryListAdhocByMiddlewareResponse) Size 

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

func (*QueryListAdhocByMiddlewareResponse) String 

func (m *QueryListAdhocByMiddlewareResponse) String() string

func (*QueryListAdhocByMiddlewareResponse) Unmarshal 

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

func (*QueryListAdhocByMiddlewareResponse) XXX_DiscardUnknown 

func (m *QueryListAdhocByMiddlewareResponse) XXX_DiscardUnknown()

func (*QueryListAdhocByMiddlewareResponse) XXX_Marshal 

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

func (*QueryListAdhocByMiddlewareResponse) XXX_Merge 

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

func (*QueryListAdhocByMiddlewareResponse) XXX_Size 

func (m *QueryListAdhocByMiddlewareResponse) XXX_Size() int

func (*QueryListAdhocByMiddlewareResponse) XXX_Unmarshal 

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

type QueryListAdhocRequest 

type QueryListAdhocRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryListAdhocRequest is request type for the Query/ListAdhocRequests RPC method.

func (*QueryListAdhocRequest) Descriptor 

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

func (*QueryListAdhocRequest) GetPagination 

func (m *QueryListAdhocRequest) GetPagination() *query.PageRequest

func (*QueryListAdhocRequest) Marshal 

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

func (*QueryListAdhocRequest) MarshalTo 

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

func (*QueryListAdhocRequest) MarshalToSizedBuffer 

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

func (*QueryListAdhocRequest) ProtoMessage 

func (*QueryListAdhocRequest) ProtoMessage()

func (*QueryListAdhocRequest) Reset 

func (m *QueryListAdhocRequest) Reset()

func (*QueryListAdhocRequest) Size 

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

func (*QueryListAdhocRequest) String 

func (m *QueryListAdhocRequest) String() string

func (*QueryListAdhocRequest) Unmarshal 

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

func (*QueryListAdhocRequest) XXX_DiscardUnknown 

func (m *QueryListAdhocRequest) XXX_DiscardUnknown()

func (*QueryListAdhocRequest) XXX_Marshal 

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

func (*QueryListAdhocRequest) XXX_Merge 

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

func (*QueryListAdhocRequest) XXX_Size 

func (m *QueryListAdhocRequest) XXX_Size() int

func (*QueryListAdhocRequest) XXX_Unmarshal 

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

type QueryListAdhocResponse 

type QueryListAdhocResponse struct {
	AdhocRequests []AdhocRequest      `protobuf:"bytes,1,rep,name=adhoc_requests,json=adhocRequests,proto3" json:"adhoc_requests"`
	Pagination    *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryListAdhocResponse is response type for the Query/ListAdhocRequests RPC method.

func (*QueryListAdhocResponse) Descriptor 

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

func (*QueryListAdhocResponse) GetAdhocRequests 

func (m *QueryListAdhocResponse) GetAdhocRequests() []AdhocRequest

func (*QueryListAdhocResponse) GetPagination 

func (m *QueryListAdhocResponse) GetPagination() *query.PageResponse

func (*QueryListAdhocResponse) Marshal 

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

func (*QueryListAdhocResponse) MarshalTo 

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

func (*QueryListAdhocResponse) MarshalToSizedBuffer 

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

func (*QueryListAdhocResponse) ProtoMessage 

func (*QueryListAdhocResponse) ProtoMessage()

func (*QueryListAdhocResponse) Reset 

func (m *QueryListAdhocResponse) Reset()

func (*QueryListAdhocResponse) Size 

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

func (*QueryListAdhocResponse) String 

func (m *QueryListAdhocResponse) String() string

func (*QueryListAdhocResponse) Unmarshal 

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

func (*QueryListAdhocResponse) XXX_DiscardUnknown 

func (m *QueryListAdhocResponse) XXX_DiscardUnknown()

func (*QueryListAdhocResponse) XXX_Marshal 

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

func (*QueryListAdhocResponse) XXX_Merge 

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

func (*QueryListAdhocResponse) XXX_Size 

func (m *QueryListAdhocResponse) XXX_Size() int

func (*QueryListAdhocResponse) XXX_Unmarshal 

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

type QueryListTxDataRequest 

type QueryListTxDataRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryListTxDataRequest is request type for the Query/ListTxDataRequests RPC method.

func (*QueryListTxDataRequest) Descriptor 

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

func (*QueryListTxDataRequest) GetPagination 

func (m *QueryListTxDataRequest) GetPagination() *query.PageRequest

func (*QueryListTxDataRequest) Marshal 

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

func (*QueryListTxDataRequest) MarshalTo 

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

func (*QueryListTxDataRequest) MarshalToSizedBuffer 

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

func (*QueryListTxDataRequest) ProtoMessage 

func (*QueryListTxDataRequest) ProtoMessage()

func (*QueryListTxDataRequest) Reset 

func (m *QueryListTxDataRequest) Reset()

func (*QueryListTxDataRequest) Size 

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

func (*QueryListTxDataRequest) String 

func (m *QueryListTxDataRequest) String() string

func (*QueryListTxDataRequest) Unmarshal 

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

func (*QueryListTxDataRequest) XXX_DiscardUnknown 

func (m *QueryListTxDataRequest) XXX_DiscardUnknown()

func (*QueryListTxDataRequest) XXX_Marshal 

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

func (*QueryListTxDataRequest) XXX_Merge 

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

func (*QueryListTxDataRequest) XXX_Size 

func (m *QueryListTxDataRequest) XXX_Size() int

func (*QueryListTxDataRequest) XXX_Unmarshal 

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

type QueryListTxDataResponse 

type QueryListTxDataResponse struct {
	TxDataRequests []TxDataRequest     `protobuf:"bytes,1,rep,name=tx_data_requests,json=txDataRequests,proto3" json:"tx_data_requests"`
	Pagination     *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryListTxDataResponse is response type for the Query/ListTxDataRequests RPC method.

func (*QueryListTxDataResponse) Descriptor 

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

func (*QueryListTxDataResponse) GetPagination 

func (m *QueryListTxDataResponse) GetPagination() *query.PageResponse

func (*QueryListTxDataResponse) GetTxDataRequests 

func (m *QueryListTxDataResponse) GetTxDataRequests() []TxDataRequest

func (*QueryListTxDataResponse) Marshal 

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

func (*QueryListTxDataResponse) MarshalTo 

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

func (*QueryListTxDataResponse) MarshalToSizedBuffer 

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

func (*QueryListTxDataResponse) ProtoMessage 

func (*QueryListTxDataResponse) ProtoMessage()

func (*QueryListTxDataResponse) Reset 

func (m *QueryListTxDataResponse) Reset()

func (*QueryListTxDataResponse) Size 

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

func (*QueryListTxDataResponse) String 

func (m *QueryListTxDataResponse) String() string

func (*QueryListTxDataResponse) Unmarshal 

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

func (*QueryListTxDataResponse) XXX_DiscardUnknown 

func (m *QueryListTxDataResponse) XXX_DiscardUnknown()

func (*QueryListTxDataResponse) XXX_Marshal 

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

func (*QueryListTxDataResponse) XXX_Merge 

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

func (*QueryListTxDataResponse) XXX_Size 

func (m *QueryListTxDataResponse) XXX_Size() int

func (*QueryListTxDataResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// params holds all the parameters of this module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params queries the parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// ListAdhocRequests queries a list of adhoc request items.
	ListAdhocRequests(context.Context, *QueryListAdhocRequest) (*QueryListAdhocResponse, error)
	// ListAdhocRequestsByMiddleware queries a list of adhoc request items for the certain middleware.
	ListAdhocRequestsByMiddleware(context.Context, *QueryListAdhocByMiddlewareRequest) (*QueryListAdhocByMiddlewareResponse, error)
	// ListTxDataRequests queries a list of tx data request items.
	ListTxDataRequests(context.Context, *QueryListTxDataRequest) (*QueryListTxDataResponse, error)
}

QueryServer is the server API for Query service.

type StakingKeeper 

type StakingKeeper interface {
	GetLastValidatorPower(ctx sdk.Context, operator sdk.ValAddress) int64
}

type SudoReceiveMsg 

type SudoReceiveMsg struct {
	HandleAdhocRequest HandleAdhocRequest `json:"handle_adhoc_request"`
}

type TxDataRequest 

type TxDataRequest struct {
	ChainId     string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	TxHash      string `protobuf:"bytes,2,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	TxData      []byte `protobuf:"bytes,3,opt,name=tx_data,json=txData,proto3" json:"tx_data,omitempty"`
	BlockHeight uint64 `protobuf:"varint,4,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
}

func (*TxDataRequest) ClaimHash 

func (msg *TxDataRequest) ClaimHash() ([]byte, error)

func (*TxDataRequest) Descriptor 

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

func (*TxDataRequest) GetBlockHeight 

func (m *TxDataRequest) GetBlockHeight() uint64

func (*TxDataRequest) GetChainId 

func (m *TxDataRequest) GetChainId() string

func (*TxDataRequest) GetTxData 

func (m *TxDataRequest) GetTxData() []byte

func (*TxDataRequest) GetTxHash 

func (m *TxDataRequest) GetTxHash() string

func (*TxDataRequest) Marshal 

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

func (*TxDataRequest) MarshalTo 

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

func (*TxDataRequest) MarshalToSizedBuffer 

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

func (*TxDataRequest) ProtoMessage 

func (*TxDataRequest) ProtoMessage()

func (*TxDataRequest) Reset 

func (m *TxDataRequest) Reset()

func (*TxDataRequest) Size 

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

func (*TxDataRequest) String 

func (m *TxDataRequest) String() string

func (*TxDataRequest) Unmarshal 

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

func (*TxDataRequest) XXX_DiscardUnknown 

func (m *TxDataRequest) XXX_DiscardUnknown()

func (*TxDataRequest) XXX_Marshal 

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

func (*TxDataRequest) XXX_Merge 

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

func (*TxDataRequest) XXX_Size 

func (m *TxDataRequest) XXX_Size() int

func (*TxDataRequest) XXX_Unmarshal 

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

type TxDataRequestClaimHash 

type TxDataRequestClaimHash struct {
	ChainId     string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	TxHash      string `protobuf:"bytes,2,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
	TxData      []byte `protobuf:"bytes,3,opt,name=tx_data,json=txData,proto3" json:"tx_data,omitempty"`
	BlockHeight uint64 `protobuf:"varint,4,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
}

func (*TxDataRequestClaimHash) Descriptor 

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

func (*TxDataRequestClaimHash) GetBlockHeight 

func (m *TxDataRequestClaimHash) GetBlockHeight() uint64

func (*TxDataRequestClaimHash) GetChainId 

func (m *TxDataRequestClaimHash) GetChainId() string

func (*TxDataRequestClaimHash) GetTxData 

func (m *TxDataRequestClaimHash) GetTxData() []byte

func (*TxDataRequestClaimHash) GetTxHash 

func (m *TxDataRequestClaimHash) GetTxHash() string

func (*TxDataRequestClaimHash) Marshal 

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

func (*TxDataRequestClaimHash) MarshalTo 

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

func (*TxDataRequestClaimHash) MarshalToSizedBuffer 

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

func (*TxDataRequestClaimHash) ProtoMessage 

func (*TxDataRequestClaimHash) ProtoMessage()

func (*TxDataRequestClaimHash) Reset 

func (m *TxDataRequestClaimHash) Reset()

func (*TxDataRequestClaimHash) Size 

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

func (*TxDataRequestClaimHash) String 

func (m *TxDataRequestClaimHash) String() string

func (*TxDataRequestClaimHash) Unmarshal 

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

func (*TxDataRequestClaimHash) XXX_DiscardUnknown 

func (m *TxDataRequestClaimHash) XXX_DiscardUnknown()

func (*TxDataRequestClaimHash) XXX_Marshal 

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

func (*TxDataRequestClaimHash) XXX_Merge 

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

func (*TxDataRequestClaimHash) XXX_Size 

func (m *TxDataRequestClaimHash) XXX_Size() int

func (*TxDataRequestClaimHash) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CreateAdhocRequest 

func (*UnimplementedMsgServer) CreateAdhocRequest(ctx context.Context, req *MsgCreateAdhocRequest) (*MsgCreateAdhocResponse, error)

func (*UnimplementedMsgServer) CreateTxDataRequest 

func (*UnimplementedMsgServer) CreateTxDataRequest(ctx context.Context, req *MsgCreateTxDataRequest) (*MsgCreateTxDataResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) ListAdhocRequests 

func (*UnimplementedQueryServer) ListAdhocRequests(ctx context.Context, req *QueryListAdhocRequest) (*QueryListAdhocResponse, error)

func (*UnimplementedQueryServer) ListAdhocRequestsByMiddleware 

func (*UnimplementedQueryServer) ListAdhocRequestsByMiddleware(ctx context.Context, req *QueryListAdhocByMiddlewareRequest) (*QueryListAdhocByMiddlewareResponse, error)

func (*UnimplementedQueryServer) ListTxDataRequests 

func (*UnimplementedQueryServer) ListTxDataRequests(ctx context.Context, req *QueryListTxDataRequest) (*QueryListTxDataResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

type WasmKeeper 

type WasmKeeper interface {
	// Methods imported from wasmd should be defined here
	Sudo(ctx sdk.Context, contractAddress sdk.AccAddress, msg []byte) ([]byte, 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.