types

package
v0.0.9-2 Latest Latest
Warning

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

 Go to latest Published: Oct 9, 2024 License: MIT Imports: 44 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ClaimPrimaryKeyPrefix is the prefix to retrieve the entire Claim object (the primary store)
	// TODO_TECHDEBT: consider renaming to ClaimSessionIDPrefix.
	ClaimPrimaryKeyPrefix = "Claim/primary_key/"

	// ClaimSupplierOperatorAddressPrefix is the key to retrieve a Claim's Primary Key from the Address index
	ClaimSupplierOperatorAddressPrefix = "Claim/address/"

	// ClaimSessionEndHeightPrefix is the key to retrieve a Claim's Primary Key from the Height index
	ClaimSessionEndHeightPrefix = "Claim/height/"
)
View Source 
const (
	// ProofPrimaryKeyPrefix is the prefix to retrieve the entire Proof object (the primary store)
	// TODO_TECHDEBT: consider renaming to ProofSessionIDPrefix.
	ProofPrimaryKeyPrefix = "Proof/primary_key/"

	// ProofSupplierOperatorAddressPrefix is the key to retrieve a Proof's Primary Key from the Address index
	ProofSupplierOperatorAddressPrefix = "Proof/address/"

	// ProofSessionEndHeightPrefix is the key to retrieve a Proof's Primary Key from the Height index
	ProofSessionEndHeightPrefix = "Proof/height/"
)
View Source 
const (
	// ModuleName defines the module name
	ModuleName = "proof"

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

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_proof"
)
View Source 
const TypeMsgCreateClaim = "create_claim"

Variables

View Source 
var (
	ErrProofInvalidSigner             = sdkerrors.Register(ModuleName, 1100, "expected gov account as only signer for proposal message")
	ErrProofInvalidAddress            = sdkerrors.Register(ModuleName, 1101, "invalid address")
	ErrProofNotFound                  = sdkerrors.Register(ModuleName, 1102, "supplier not found")
	ErrProofInvalidService            = sdkerrors.Register(ModuleName, 1103, "invalid service in supplier")
	ErrProofInvalidClaimRootHash      = sdkerrors.Register(ModuleName, 1104, "invalid root hash")
	ErrProofInvalidQueryRequest       = sdkerrors.Register(ModuleName, 1105, "invalid query request")
	ErrProofClaimNotFound             = sdkerrors.Register(ModuleName, 1106, "claim not found")
	ErrProofProofNotFound             = sdkerrors.Register(ModuleName, 1107, "proof not found")
	ErrProofInvalidProof              = sdkerrors.Register(ModuleName, 1108, "invalid proof")
	ErrProofInvalidRelay              = sdkerrors.Register(ModuleName, 1109, "invalid relay")
	ErrProofInvalidRelayRequest       = sdkerrors.Register(ModuleName, 1110, "invalid relay request")
	ErrProofInvalidRelayResponse      = sdkerrors.Register(ModuleName, 1111, "invalid relay response")
	ErrProofNotSecp256k1Curve         = sdkerrors.Register(ModuleName, 1112, "not secp256k1 curve")
	ErrProofApplicationNotFound       = sdkerrors.Register(ModuleName, 1113, "application not found")
	ErrProofPubKeyNotFound            = sdkerrors.Register(ModuleName, 1114, "public key not found")
	ErrProofInvalidSessionHeader      = sdkerrors.Register(ModuleName, 1115, "invalid session header")
	ErrProofInvalidSessionId          = sdkerrors.Register(ModuleName, 1116, "invalid session ID")
	ErrProofInvalidSessionEndHeight   = sdkerrors.Register(ModuleName, 1117, "invalid session end height")
	ErrProofInvalidSessionStartHeight = sdkerrors.Register(ModuleName, 1118, "invalid session start height")
	ErrProofParamNameInvalid          = sdkerrors.Register(ModuleName, 1119, "the provided param name is invalid")
	ErrProofParamInvalid              = sdkerrors.Register(ModuleName, 1120, "the provided param is invalid")
	ErrProofClaimOutsideOfWindow      = sdkerrors.Register(ModuleName, 1121, "claim attempted outside of the session's claim window")
	ErrProofProofOutsideOfWindow      = sdkerrors.Register(ModuleName, 1122, "proof attempted outside of the session's proof window")
	ErrProofSupplierMismatch          = sdkerrors.Register(ModuleName, 1123, "supplier operator address does not match the claim or proof")
	ErrProofAccNotFound               = sdkerrors.Register(ModuleName, 1124, "account not found")
	ErrProofServiceNotFound           = sdkerrors.Register(ModuleName, 1125, "service not found")
	ErrProofComputeUnitsMismatch      = sdkerrors.Register(ModuleName, 1126, "mismatch: claim compute units != number of relays * service compute units per relay")
	ErrProofNotEnoughFunds            = sdkerrors.Register(ModuleName, 1127, "not enough funds to submit proof")
	ErrProofFailedToDeductFee         = sdkerrors.Register(ModuleName, 1128, "failed to deduct proof submission fee")
	ErrProofNotRequired               = sdkerrors.Register(ModuleName, 1129, "proof not required")
)

x/proof module sentinel errors

View Source 
var (
	ErrInvalidLengthEvent        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvent          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupEvent = 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 (
	ParamsKey = []byte("p_proof")
	// KeyDelimiter is the delimiter for composite keys.
	KeyDelimiter = []byte("/")
)
View Source 
var (

	// TODO_FOLLOWUP(@olshansk, #690): Delete this parameter.
	KeyRelayDifficultyTargetHash        = []byte("RelayDifficultyTargetHash")
	ParamRelayDifficultyTargetHash      = "relay_difficulty_target_hash"
	DefaultRelayDifficultyTargetHashHex = "ffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffffff" // all relays are payable
	DefaultRelayDifficultyTargetHash, _ = hex.DecodeString(DefaultRelayDifficultyTargetHashHex)

	KeyProofRequestProbability             = []byte("ProofRequestProbability")
	ParamProofRequestProbability           = "proof_request_probability"
	DefaultProofRequestProbability float32 = 0.25 // See: https://github.com/pokt-network/pocket-core/blob/staging/docs/proposals/probabilistic_proofs.md

	KeyProofRequirementThreshold            = []byte("ProofRequirementThreshold")
	ParamProofRequirementThreshold          = "proof_requirement_threshold"
	DefaultProofRequirementThreshold uint64 = 20 // See: https://github.com/pokt-network/pocket-core/blob/staging/docs/proposals/probabilistic_proofs.md

	KeyProofMissingPenalty     = []byte("ProofMissingPenalty")
	ParamProofMissingPenalty   = "proof_missing_penalty"
	DefaultProofMissingPenalty = cosmostypes.NewCoin(volatile.DenomuPOKT, math.NewInt(320)) // See: https://github.com/pokt-network/pocket-core/blob/staging/docs/proposals/probabilistic_proofs.md

	KeyProofSubmissionFee   = []byte("ProofSubmissionFee")
	ParamProofSubmissionFee = "proof_submission_fee"
	// TODO_MAINNET: Determine a sensible default value for the proof submission fee.
	// MinProofSubmissionFee is the default and minimum fee for submitting a proof.
	MinProofSubmissionFee = cosmostypes.NewCoin(volatile.DenomuPOKT, math.NewInt(1000000))
)
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 (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ClaimProofStage_name = map[int32]string{
	0: "CLAIMED",
	1: "PROVEN",
	2: "SETTLED",
	3: "EXPIRED",
}
View Source 
var ClaimProofStage_value = map[string]int32{
	"CLAIMED": 0,
	"PROVEN":  1,
	"SETTLED": 2,
	"EXPIRED": 3,
}
View Source 
var ProofRequirementReason_name = map[int32]string{
	0: "NOT_REQUIRED",
	1: "PROBABILISTIC",
	2: "THRESHOLD",
}
View Source 
var ProofRequirementReason_value = map[string]int32{
	"NOT_REQUIRED":  0,
	"PROBABILISTIC": 1,
	"THRESHOLD":     2,
}

Functions

func ClaimPrimaryKey 

func ClaimPrimaryKey(sessionId, supplierOperatorAddr string) []byte

ClaimPrimaryKey returns the primary store key used to retrieve a Claim by creating a composite key of the sessionId and supplierOperatorAddr.

func ClaimSupplierEndSessionHeightKey 

func ClaimSupplierEndSessionHeightKey(sessionEndHeight int64, primaryKey []byte) []byte

ClaimSupplierEndSessionHeightKey returns the key used to iterate through claims given a session end height.

func ClaimSupplierOperatorAddressKey added in v0.0.6 

func ClaimSupplierOperatorAddressKey(supplierOperatorAddr string, primaryKey []byte) []byte

ClaimSupplierOperatorAddressKey returns the key used to iterate through claims given a supplier operator address.

func KeyComposite 

func KeyComposite(keys ...[]byte) []byte

KeyComposite combines the given keys into a single key for use with KVStore.

func KeyPrefix 

func KeyPrefix(p string) []byte

func NewAccountKeeperQueryClient 

func NewAccountKeeperQueryClient(accountKeeper AccountKeeper) client.AccountQueryClient

NewAccountKeeperQueryClient returns a new AccountQueryClient that is backed by an AccountKeeper instance. It is used by the PubKeyClient to get the public key that corresponds to the provided address. It should be injected into the PubKeyClient when initialized from within the a keeper.

func NewAppKeeperQueryClient 

func NewAppKeeperQueryClient(appKeeper ApplicationKeeper) client.ApplicationQueryClient

NewAppKeeperQueryClient returns a new ApplicationQueryClient that is backed by an ApplicationKeeper instance. It is used by the RingClient to get the gateway address that an application has delegated its signing power to. It should be injected into the RingClient when initialized from within the a keeper.

func NewSharedKeeperQueryClient added in v0.0.3 

func NewSharedKeeperQueryClient(
	sharedKeeper SharedKeeper,
	sessionKeeper SessionKeeper,
) client.SharedQueryClient

NewSharedKeeperQueryClient returns a new SharedQueryClient that is backed by an SharedKeeper instance.

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable the param key table for launch module

func ProofPrimaryKey 

func ProofPrimaryKey(sessionId, supplierOperatorAddr string) []byte

ProofPrimaryKey returns the primary store key used to retrieve a Proof by creating a composite key of the sessionId and supplierOperatorAddr.

func ProofSupplierEndSessionHeightKey 

func ProofSupplierEndSessionHeightKey(sessionEndHeight int64, primaryKey []byte) []byte

ProofSupplierEndSessionHeightKey returns the key used to iterate through Proofs given a session end height.

func ProofSupplierOperatorAddressKey added in v0.0.6 

func ProofSupplierOperatorAddressKey(supplierOperatorAddr string, primaryKey []byte) []byte

ProofSupplierOperatorAddressKey returns the key used to iterate through Proofs given a supplier operator Address.

func RegisterInterfaces 

func RegisterInterfaces(registry cdctypes.InterfaceRegistry)

func RegisterMsgServer added in v0.0.3 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler added in v0.0.3 

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 added in v0.0.3 

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 added in v0.0.3 

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 added in v0.0.3 

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 added in v0.0.3 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateProofMissingPenalty added in v0.0.3 

func ValidateProofMissingPenalty(v interface{}) error

ValidateProofMissingPenalty validates the ProofMissingPenalty param. NB: The argument is an interface type to satisfy the ParamSetPair function signature.

func ValidateProofRequestProbability added in v0.0.3 

func ValidateProofRequestProbability(v interface{}) error

ValidateProofRequestProbability validates the ProofRequestProbability param. NB: The argument is an interface type to satisfy the ParamSetPair function signature.

func ValidateProofRequirementThreshold added in v0.0.3 

func ValidateProofRequirementThreshold(v interface{}) error

ValidateProofRequirementThreshold validates the ProofRequirementThreshold param. NB: The argument is an interface type to satisfy the ParamSetPair function signature.

func ValidateProofSubmissionFee added in v0.0.8 

func ValidateProofSubmissionFee(v interface{}) error

ValidateProofSubmission validates the ProofSubmissionFee param. NB: The argument is an interface type to satisfy the ParamSetPair function signature.

func ValidateRelayDifficultyTargetHash added in v0.0.5 

func ValidateRelayDifficultyTargetHash(v interface{}) error

ValidateRelayDifficultyTargetHash validates the MinRelayDifficultyBits param. NB: The argument is an interface type to satisfy the ParamSetPair function signature.

Types

type AccountKeeper 

type AccountKeeper interface {
	GetAccount(context.Context, sdk.AccAddress) sdk.AccountI
	SetAccount(context.Context, sdk.AccountI)
	// Return a new account with the next account number and the specified address. Does not save the new account to the store.
	NewAccountWithAddress(context.Context, sdk.AccAddress) sdk.AccountI
	// Fetch the next account number, and increment the internal counter.
	NextAccountNumber(context.Context) uint64
}

AccountKeeper defines the expected interface for the Account module.

type AccountKeeperQueryClient 

type AccountKeeperQueryClient struct {
	// contains filtered or unexported fields
}

AccountKeeperQueryClient is a thin wrapper around the AccountKeeper. It does not rely on the QueryClient, and therefore does not make any network requests as in the off-chain implementation.

func (*AccountKeeperQueryClient) GetAccount 

func (accountQueryClient *AccountKeeperQueryClient) GetAccount(
	ctx context.Context,
	addr string,
) (account types.AccountI, err error)

GetAccount returns the account associated with the provided address.

func (*AccountKeeperQueryClient) GetPubKeyFromAddress 

func (accountQueryClient *AccountKeeperQueryClient) GetPubKeyFromAddress(
	ctx context.Context,
	address string,
) (cryptotypes.PubKey, error)

GetPubKeyFromAddress returns the public key of the given address. It uses the accountQuerier to get the account and then returns its public key.

type AppKeeperQueryClient 

type AppKeeperQueryClient struct {
	// contains filtered or unexported fields
}

AppKeeperQueryClient is a thin wrapper around the AccountKeeper. It does not rely on the QueryClient, and therefore does not make any network requests as in the off-chain implementation.

func (*AppKeeperQueryClient) GetAllApplications 

func (appQueryClient *AppKeeperQueryClient) GetAllApplications(ctx context.Context) ([]apptypes.Application, error)

GetAllApplications returns all the applications in the application store.

func (*AppKeeperQueryClient) GetApplication 

func (appQueryClient *AppKeeperQueryClient) GetApplication(
	ctx context.Context,
	appAddr string,
) (apptypes.Application, error)

GetApplication returns the application corresponding to the given address.

type ApplicationKeeper 

type ApplicationKeeper interface {
	GetApplication(ctx context.Context, address string) (app apptypes.Application, found bool)
	GetAllApplications(ctx context.Context) []apptypes.Application
	SetApplication(context.Context, apptypes.Application)
}

ApplicationKeeper defines the expected application keeper to retrieve applications

type BankKeeper 

type BankKeeper interface {
	SpendableCoins(context.Context, sdk.AccAddress) sdk.Coins
	// We use the bankkeeper SendXXX instead of DelegateXX methods
	// because their purpose is to "escrow" funds on behalf of an account rather
	// than "delegate" funds from one account to another which is more closely
	// linked to staking.
	SendCoinsFromAccountToModule(ctx context.Context, senderAddr sdk.AccAddress, recipientModule string, amt sdk.Coins) error
	SendCoinsFromModuleToAccount(ctx context.Context, senderModule string, recipientAddr sdk.AccAddress, amt sdk.Coins) error
}

BankKeeper defines the expected interface for the Bank module.

type Claim added in v0.0.3 

type Claim struct {
	SupplierOperatorAddress string `` /* 132-byte string literal not displayed */
	// The session header of the session that this claim is for.
	SessionHeader *types.SessionHeader `protobuf:"bytes,2,opt,name=session_header,json=sessionHeader,proto3" json:"session_header,omitempty"`
	// Root hash returned from smt.SMST#Root().
	RootHash []byte `protobuf:"bytes,3,opt,name=root_hash,json=rootHash,proto3" json:"root_hash,omitempty"`
}

Claim is the serialized object stored on-chain for claims pending to be proven

func (*Claim) Descriptor added in v0.0.3 

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

func (*Claim) GetHash added in v0.0.3 

func (claim *Claim) GetHash() ([]byte, error)

GetHash returns the SHA-256 hash of the serialized claim.

func (*Claim) GetNumComputeUnits added in v0.0.3 

func (claim *Claim) GetNumComputeUnits() (numComputeUnits uint64, err error)

GetNumComputeUnits returns the number of compute units for a given claim as determined by the sum of the root hash.

func (*Claim) GetNumRelays added in v0.0.3 

func (claim *Claim) GetNumRelays() (numRelays uint64, err error)

GetNumRelays returns the number of relays for a given claim as determined by the count of the root hash.

func (*Claim) GetProofRequirementSampleValue added in v0.0.8 

func (claim *Claim) GetProofRequirementSampleValue(
	proofRequirementSeedBlockHash []byte,
) (proofRequirementSampleValue float32, err error)

GetProofRequirementSampleValue returns a pseudo-random value between 0 and 1 to determine if a proof is required probabilistically. IMPORTANT: It is assumed that the caller has ensured the hash of the block seed

func (*Claim) GetRootHash added in v0.0.3 

func (m *Claim) GetRootHash() []byte

func (*Claim) GetSessionHeader added in v0.0.3 

func (m *Claim) GetSessionHeader() *types.SessionHeader

func (*Claim) GetSupplierOperatorAddress added in v0.0.6 

func (m *Claim) GetSupplierOperatorAddress() string

func (*Claim) Marshal added in v0.0.3 

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

func (*Claim) MarshalTo added in v0.0.3 

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

func (*Claim) MarshalToSizedBuffer added in v0.0.3 

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

func (*Claim) ProtoMessage added in v0.0.3 

func (*Claim) ProtoMessage()

func (*Claim) Reset added in v0.0.3 

func (m *Claim) Reset()

func (*Claim) Size added in v0.0.3 

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

func (*Claim) String added in v0.0.3 

func (m *Claim) String() string

func (*Claim) Unmarshal added in v0.0.3 

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

func (*Claim) XXX_DiscardUnknown added in v0.0.3 

func (m *Claim) XXX_DiscardUnknown()

func (*Claim) XXX_Marshal added in v0.0.3 

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

func (*Claim) XXX_Merge added in v0.0.3 

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

func (*Claim) XXX_Size added in v0.0.3 

func (m *Claim) XXX_Size() int

func (*Claim) XXX_Unmarshal added in v0.0.3 

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

type ClaimProofStage added in v0.0.3 

type ClaimProofStage int32
const (
	ClaimProofStage_CLAIMED ClaimProofStage = 0
	ClaimProofStage_PROVEN  ClaimProofStage = 1
	ClaimProofStage_SETTLED ClaimProofStage = 2
	ClaimProofStage_EXPIRED ClaimProofStage = 3
)

func (ClaimProofStage) EnumDescriptor added in v0.0.3 

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

func (ClaimProofStage) String added in v0.0.3 

func (x ClaimProofStage) String() string

type EventClaimCreated added in v0.0.3 

type EventClaimCreated struct {
	Claim           *Claim `protobuf:"bytes,1,opt,name=claim,proto3" json:"claim"`
	NumRelays       uint64 `protobuf:"varint,2,opt,name=num_relays,json=numRelays,proto3" json:"num_relays"`
	NumComputeUnits uint64 `protobuf:"varint,3,opt,name=num_compute_units,json=numComputeUnits,proto3" json:"num_compute_units"`
}

func (*EventClaimCreated) Descriptor added in v0.0.3 

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

func (*EventClaimCreated) GetClaim added in v0.0.3 

func (m *EventClaimCreated) GetClaim() *Claim

func (*EventClaimCreated) GetNumComputeUnits added in v0.0.3 

func (m *EventClaimCreated) GetNumComputeUnits() uint64

func (*EventClaimCreated) GetNumRelays added in v0.0.3 

func (m *EventClaimCreated) GetNumRelays() uint64

func (*EventClaimCreated) Marshal added in v0.0.3 

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

func (*EventClaimCreated) MarshalTo added in v0.0.3 

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

func (*EventClaimCreated) MarshalToSizedBuffer added in v0.0.3 

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

func (*EventClaimCreated) ProtoMessage added in v0.0.3 

func (*EventClaimCreated) ProtoMessage()

func (*EventClaimCreated) Reset added in v0.0.3 

func (m *EventClaimCreated) Reset()

func (*EventClaimCreated) Size added in v0.0.3 

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

func (*EventClaimCreated) String added in v0.0.3 

func (m *EventClaimCreated) String() string

func (*EventClaimCreated) Unmarshal added in v0.0.3 

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

func (*EventClaimCreated) XXX_DiscardUnknown added in v0.0.3 

func (m *EventClaimCreated) XXX_DiscardUnknown()

func (*EventClaimCreated) XXX_Marshal added in v0.0.3 

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

func (*EventClaimCreated) XXX_Merge added in v0.0.3 

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

func (*EventClaimCreated) XXX_Size added in v0.0.3 

func (m *EventClaimCreated) XXX_Size() int

func (*EventClaimCreated) XXX_Unmarshal added in v0.0.3 

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

type EventClaimUpdated added in v0.0.3 

type EventClaimUpdated struct {
	Claim           *Claim `protobuf:"bytes,1,opt,name=claim,proto3" json:"claim"`
	NumRelays       uint64 `protobuf:"varint,2,opt,name=num_relays,json=numRelays,proto3" json:"num_relays"`
	NumComputeUnits uint64 `protobuf:"varint,3,opt,name=num_compute_units,json=numComputeUnits,proto3" json:"num_compute_units"`
}

TODO_TEST: Add coverage for claim updates.

func (*EventClaimUpdated) Descriptor added in v0.0.3 

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

func (*EventClaimUpdated) GetClaim added in v0.0.3 

func (m *EventClaimUpdated) GetClaim() *Claim

func (*EventClaimUpdated) GetNumComputeUnits added in v0.0.3 

func (m *EventClaimUpdated) GetNumComputeUnits() uint64

func (*EventClaimUpdated) GetNumRelays added in v0.0.3 

func (m *EventClaimUpdated) GetNumRelays() uint64

func (*EventClaimUpdated) Marshal added in v0.0.3 

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

func (*EventClaimUpdated) MarshalTo added in v0.0.3 

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

func (*EventClaimUpdated) MarshalToSizedBuffer added in v0.0.3 

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

func (*EventClaimUpdated) ProtoMessage added in v0.0.3 

func (*EventClaimUpdated) ProtoMessage()

func (*EventClaimUpdated) Reset added in v0.0.3 

func (m *EventClaimUpdated) Reset()

func (*EventClaimUpdated) Size added in v0.0.3 

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

func (*EventClaimUpdated) String added in v0.0.3 

func (m *EventClaimUpdated) String() string

func (*EventClaimUpdated) Unmarshal added in v0.0.3 

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

func (*EventClaimUpdated) XXX_DiscardUnknown added in v0.0.3 

func (m *EventClaimUpdated) XXX_DiscardUnknown()

func (*EventClaimUpdated) XXX_Marshal added in v0.0.3 

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

func (*EventClaimUpdated) XXX_Merge added in v0.0.3 

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

func (*EventClaimUpdated) XXX_Size added in v0.0.3 

func (m *EventClaimUpdated) XXX_Size() int

func (*EventClaimUpdated) XXX_Unmarshal added in v0.0.3 

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

type EventProofSubmitted added in v0.0.3 

type EventProofSubmitted struct {
	Claim           *Claim `protobuf:"bytes,1,opt,name=claim,proto3" json:"claim"`
	Proof           *Proof `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof"`
	NumRelays       uint64 `protobuf:"varint,3,opt,name=num_relays,json=numRelays,proto3" json:"num_relays"`
	NumComputeUnits uint64 `protobuf:"varint,4,opt,name=num_compute_units,json=numComputeUnits,proto3" json:"num_compute_units"`
}

func (*EventProofSubmitted) Descriptor added in v0.0.3 

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

func (*EventProofSubmitted) GetClaim added in v0.0.3 

func (m *EventProofSubmitted) GetClaim() *Claim

func (*EventProofSubmitted) GetNumComputeUnits added in v0.0.3 

func (m *EventProofSubmitted) GetNumComputeUnits() uint64

func (*EventProofSubmitted) GetNumRelays added in v0.0.3 

func (m *EventProofSubmitted) GetNumRelays() uint64

func (*EventProofSubmitted) GetProof added in v0.0.3 

func (m *EventProofSubmitted) GetProof() *Proof

func (*EventProofSubmitted) Marshal added in v0.0.3 

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

func (*EventProofSubmitted) MarshalTo added in v0.0.3 

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

func (*EventProofSubmitted) MarshalToSizedBuffer added in v0.0.3 

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

func (*EventProofSubmitted) ProtoMessage added in v0.0.3 

func (*EventProofSubmitted) ProtoMessage()

func (*EventProofSubmitted) Reset added in v0.0.3 

func (m *EventProofSubmitted) Reset()

func (*EventProofSubmitted) Size added in v0.0.3 

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

func (*EventProofSubmitted) String added in v0.0.3 

func (m *EventProofSubmitted) String() string

func (*EventProofSubmitted) Unmarshal added in v0.0.3 

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

func (*EventProofSubmitted) XXX_DiscardUnknown added in v0.0.3 

func (m *EventProofSubmitted) XXX_DiscardUnknown()

func (*EventProofSubmitted) XXX_Marshal added in v0.0.3 

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

func (*EventProofSubmitted) XXX_Merge added in v0.0.3 

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

func (*EventProofSubmitted) XXX_Size added in v0.0.3 

func (m *EventProofSubmitted) XXX_Size() int

func (*EventProofSubmitted) XXX_Unmarshal added in v0.0.3 

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

type EventProofUpdated added in v0.0.3 

type EventProofUpdated struct {
	Claim           *Claim `protobuf:"bytes,1,opt,name=claim,proto3" json:"claim"`
	Proof           *Proof `protobuf:"bytes,2,opt,name=proof,proto3" json:"proof"`
	NumRelays       uint64 `protobuf:"varint,3,opt,name=num_relays,json=numRelays,proto3" json:"num_relays"`
	NumComputeUnits uint64 `protobuf:"varint,4,opt,name=num_compute_units,json=numComputeUnits,proto3" json:"num_compute_units"`
}

TODO_TEST: Add coverage for proof updates.

func (*EventProofUpdated) Descriptor added in v0.0.3 

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

func (*EventProofUpdated) GetClaim added in v0.0.3 

func (m *EventProofUpdated) GetClaim() *Claim

func (*EventProofUpdated) GetNumComputeUnits added in v0.0.3 

func (m *EventProofUpdated) GetNumComputeUnits() uint64

func (*EventProofUpdated) GetNumRelays added in v0.0.3 

func (m *EventProofUpdated) GetNumRelays() uint64

func (*EventProofUpdated) GetProof added in v0.0.3 

func (m *EventProofUpdated) GetProof() *Proof

func (*EventProofUpdated) Marshal added in v0.0.3 

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

func (*EventProofUpdated) MarshalTo added in v0.0.3 

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

func (*EventProofUpdated) MarshalToSizedBuffer added in v0.0.3 

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

func (*EventProofUpdated) ProtoMessage added in v0.0.3 

func (*EventProofUpdated) ProtoMessage()

func (*EventProofUpdated) Reset added in v0.0.3 

func (m *EventProofUpdated) Reset()

func (*EventProofUpdated) Size added in v0.0.3 

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

func (*EventProofUpdated) String added in v0.0.3 

func (m *EventProofUpdated) String() string

func (*EventProofUpdated) Unmarshal added in v0.0.3 

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

func (*EventProofUpdated) XXX_DiscardUnknown added in v0.0.3 

func (m *EventProofUpdated) XXX_DiscardUnknown()

func (*EventProofUpdated) XXX_Marshal added in v0.0.3 

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

func (*EventProofUpdated) XXX_Merge added in v0.0.3 

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

func (*EventProofUpdated) XXX_Size added in v0.0.3 

func (m *EventProofUpdated) XXX_Size() int

func (*EventProofUpdated) XXX_Unmarshal added in v0.0.3 

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

type GenesisState added in v0.0.3 

type GenesisState struct {
	// params defines all the parameters of the module.
	Params    Params  `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	ClaimList []Claim `protobuf:"bytes,2,rep,name=claim_list,json=claimList,proto3" json:"claim_list"`
	ProofList []Proof `protobuf:"bytes,3,rep,name=proof_list,json=proofList,proto3" json:"proof_list"`
}

GenesisState defines the proof module's genesis state.

func DefaultGenesis added in v0.0.3 

func DefaultGenesis() *GenesisState

DefaultGenesis returns the default genesis state

func (*GenesisState) Descriptor added in v0.0.3 

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

func (*GenesisState) GetClaimList added in v0.0.3 

func (m *GenesisState) GetClaimList() []Claim

func (*GenesisState) GetParams added in v0.0.3 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetProofList added in v0.0.3 

func (m *GenesisState) GetProofList() []Proof

func (*GenesisState) Marshal added in v0.0.3 

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

func (*GenesisState) MarshalTo added in v0.0.3 

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

func (*GenesisState) MarshalToSizedBuffer added in v0.0.3 

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

func (*GenesisState) ProtoMessage added in v0.0.3 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset added in v0.0.3 

func (m *GenesisState) Reset()

func (*GenesisState) Size added in v0.0.3 

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

func (*GenesisState) String added in v0.0.3 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal added in v0.0.3 

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

func (GenesisState) Validate added in v0.0.3 

func (gs GenesisState) Validate() error

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

func (*GenesisState) XXX_DiscardUnknown added in v0.0.3 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal added in v0.0.3 

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

func (*GenesisState) XXX_Merge added in v0.0.3 

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

func (*GenesisState) XXX_Size added in v0.0.3 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal added in v0.0.3 

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

type MsgClient added in v0.0.3 

type MsgClient interface {
	// UpdateParams defines a (governance) operation for updating the module
	// parameters. The authority defaults to the x/gov module account.
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
	CreateClaim(ctx context.Context, in *MsgCreateClaim, opts ...grpc.CallOption) (*MsgCreateClaimResponse, error)
	SubmitProof(ctx context.Context, in *MsgSubmitProof, opts ...grpc.CallOption) (*MsgSubmitProofResponse, error)
	UpdateParam(ctx context.Context, in *MsgUpdateParam, opts ...grpc.CallOption) (*MsgUpdateParamResponse, 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 added in v0.0.3 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgCreateClaim added in v0.0.3 

type MsgCreateClaim struct {
	SupplierOperatorAddress string                `` /* 132-byte string literal not displayed */
	SessionHeader           *types1.SessionHeader `protobuf:"bytes,2,opt,name=session_header,json=sessionHeader,proto3" json:"session_header,omitempty"`
	// root returned from smt.SMST#Root()
	RootHash []byte `protobuf:"bytes,3,opt,name=root_hash,json=rootHash,proto3" json:"root_hash,omitempty"`
}

func NewMsgCreateClaim added in v0.0.3 

func NewMsgCreateClaim(
	supplierOperatorAddr string,
	sessionHeader *sessiontypes.SessionHeader,
	rootHash []byte,
) *MsgCreateClaim

func (*MsgCreateClaim) Descriptor added in v0.0.3 

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

func (*MsgCreateClaim) GetRootHash added in v0.0.3 

func (m *MsgCreateClaim) GetRootHash() []byte

func (*MsgCreateClaim) GetSessionHeader added in v0.0.3 

func (m *MsgCreateClaim) GetSessionHeader() *types1.SessionHeader

func (*MsgCreateClaim) GetSupplierOperatorAddress added in v0.0.6 

func (m *MsgCreateClaim) GetSupplierOperatorAddress() string

func (*MsgCreateClaim) Marshal added in v0.0.3 

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

func (*MsgCreateClaim) MarshalTo added in v0.0.3 

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

func (*MsgCreateClaim) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgCreateClaim) ProtoMessage added in v0.0.3 

func (*MsgCreateClaim) ProtoMessage()

func (*MsgCreateClaim) Reset added in v0.0.3 

func (m *MsgCreateClaim) Reset()

func (*MsgCreateClaim) Size added in v0.0.3 

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

func (*MsgCreateClaim) String added in v0.0.3 

func (m *MsgCreateClaim) String() string

func (*MsgCreateClaim) Unmarshal added in v0.0.3 

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

func (*MsgCreateClaim) ValidateBasic added in v0.0.3 

func (msg *MsgCreateClaim) ValidateBasic() error

ValidateBasic performs basic stateless validation of a MsgCreateClaim.

func (*MsgCreateClaim) XXX_DiscardUnknown added in v0.0.3 

func (m *MsgCreateClaim) XXX_DiscardUnknown()

func (*MsgCreateClaim) XXX_Marshal added in v0.0.3 

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

func (*MsgCreateClaim) XXX_Merge added in v0.0.3 

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

func (*MsgCreateClaim) XXX_Size added in v0.0.3 

func (m *MsgCreateClaim) XXX_Size() int

func (*MsgCreateClaim) XXX_Unmarshal added in v0.0.3 

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

type MsgCreateClaimResponse added in v0.0.3 

type MsgCreateClaimResponse struct {
	Claim *Claim `protobuf:"bytes,1,opt,name=claim,proto3" json:"claim,omitempty"`
}

func (*MsgCreateClaimResponse) Descriptor added in v0.0.3 

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

func (*MsgCreateClaimResponse) GetClaim added in v0.0.3 

func (m *MsgCreateClaimResponse) GetClaim() *Claim

func (*MsgCreateClaimResponse) Marshal added in v0.0.3 

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

func (*MsgCreateClaimResponse) MarshalTo added in v0.0.3 

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

func (*MsgCreateClaimResponse) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgCreateClaimResponse) ProtoMessage added in v0.0.3 

func (*MsgCreateClaimResponse) ProtoMessage()

func (*MsgCreateClaimResponse) Reset added in v0.0.3 

func (m *MsgCreateClaimResponse) Reset()

func (*MsgCreateClaimResponse) Size added in v0.0.3 

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

func (*MsgCreateClaimResponse) String added in v0.0.3 

func (m *MsgCreateClaimResponse) String() string

func (*MsgCreateClaimResponse) Unmarshal added in v0.0.3 

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

func (*MsgCreateClaimResponse) XXX_DiscardUnknown added in v0.0.3 

func (m *MsgCreateClaimResponse) XXX_DiscardUnknown()

func (*MsgCreateClaimResponse) XXX_Marshal added in v0.0.3 

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

func (*MsgCreateClaimResponse) XXX_Merge added in v0.0.3 

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

func (*MsgCreateClaimResponse) XXX_Size added in v0.0.3 

func (m *MsgCreateClaimResponse) XXX_Size() int

func (*MsgCreateClaimResponse) XXX_Unmarshal added in v0.0.3 

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

type MsgServer added in v0.0.3 

type MsgServer interface {
	// UpdateParams defines a (governance) operation for updating the module
	// parameters. The authority defaults to the x/gov module account.
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
	CreateClaim(context.Context, *MsgCreateClaim) (*MsgCreateClaimResponse, error)
	SubmitProof(context.Context, *MsgSubmitProof) (*MsgSubmitProofResponse, error)
	UpdateParam(context.Context, *MsgUpdateParam) (*MsgUpdateParamResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSubmitProof added in v0.0.3 

type MsgSubmitProof struct {
	SupplierOperatorAddress string                `` /* 132-byte string literal not displayed */
	SessionHeader           *types1.SessionHeader `protobuf:"bytes,2,opt,name=session_header,json=sessionHeader,proto3" json:"session_header,omitempty"`
	// serialized version of *smt.SparseMerkleClosestProof
	Proof []byte `protobuf:"bytes,3,opt,name=proof,proto3" json:"proof,omitempty"`
}

func NewMsgSubmitProof added in v0.0.3 

func NewMsgSubmitProof(supplierOperatorAddress string, sessionHeader *sessiontypes.SessionHeader, proof []byte) *MsgSubmitProof

func (*MsgSubmitProof) Descriptor added in v0.0.3 

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

func (*MsgSubmitProof) GetProof added in v0.0.3 

func (m *MsgSubmitProof) GetProof() []byte

func (*MsgSubmitProof) GetSessionHeader added in v0.0.3 

func (m *MsgSubmitProof) GetSessionHeader() *types1.SessionHeader

func (*MsgSubmitProof) GetSupplierOperatorAddress added in v0.0.6 

func (m *MsgSubmitProof) GetSupplierOperatorAddress() string

func (*MsgSubmitProof) Marshal added in v0.0.3 

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

func (*MsgSubmitProof) MarshalTo added in v0.0.3 

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

func (*MsgSubmitProof) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgSubmitProof) ProtoMessage added in v0.0.3 

func (*MsgSubmitProof) ProtoMessage()

func (*MsgSubmitProof) Reset added in v0.0.3 

func (m *MsgSubmitProof) Reset()

func (*MsgSubmitProof) Size added in v0.0.3 

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

func (*MsgSubmitProof) String added in v0.0.3 

func (m *MsgSubmitProof) String() string

func (*MsgSubmitProof) Unmarshal added in v0.0.3 

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

func (*MsgSubmitProof) ValidateBasic added in v0.0.3 

func (msg *MsgSubmitProof) ValidateBasic() error

ValidateBasic performs basic stateless validation of a MsgSubmitProof.

func (*MsgSubmitProof) XXX_DiscardUnknown added in v0.0.3 

func (m *MsgSubmitProof) XXX_DiscardUnknown()

func (*MsgSubmitProof) XXX_Marshal added in v0.0.3 

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

func (*MsgSubmitProof) XXX_Merge added in v0.0.3 

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

func (*MsgSubmitProof) XXX_Size added in v0.0.3 

func (m *MsgSubmitProof) XXX_Size() int

func (*MsgSubmitProof) XXX_Unmarshal added in v0.0.3 

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

type MsgSubmitProofResponse added in v0.0.3 

type MsgSubmitProofResponse struct {
	Proof *Proof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof,omitempty"`
}

func (*MsgSubmitProofResponse) Descriptor added in v0.0.3 

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

func (*MsgSubmitProofResponse) GetProof added in v0.0.3 

func (m *MsgSubmitProofResponse) GetProof() *Proof

func (*MsgSubmitProofResponse) Marshal added in v0.0.3 

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

func (*MsgSubmitProofResponse) MarshalTo added in v0.0.3 

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

func (*MsgSubmitProofResponse) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgSubmitProofResponse) ProtoMessage added in v0.0.3 

func (*MsgSubmitProofResponse) ProtoMessage()

func (*MsgSubmitProofResponse) Reset added in v0.0.3 

func (m *MsgSubmitProofResponse) Reset()

func (*MsgSubmitProofResponse) Size added in v0.0.3 

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

func (*MsgSubmitProofResponse) String added in v0.0.3 

func (m *MsgSubmitProofResponse) String() string

func (*MsgSubmitProofResponse) Unmarshal added in v0.0.3 

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

func (*MsgSubmitProofResponse) XXX_DiscardUnknown added in v0.0.3 

func (m *MsgSubmitProofResponse) XXX_DiscardUnknown()

func (*MsgSubmitProofResponse) XXX_Marshal added in v0.0.3 

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

func (*MsgSubmitProofResponse) XXX_Merge added in v0.0.3 

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

func (*MsgSubmitProofResponse) XXX_Size added in v0.0.3 

func (m *MsgSubmitProofResponse) XXX_Size() int

func (*MsgSubmitProofResponse) XXX_Unmarshal added in v0.0.3 

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

type MsgUpdateParam added in v0.0.3 

type MsgUpdateParam struct {
	// authority is the address that controls the module (defaults to x/gov unless overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// The (name, as_type) tuple must match the corresponding name and type as
	// specified in the `Params“ message in `proof/params.proto.`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are valid to be assigned to AsType:
	//	*MsgUpdateParam_AsString
	//	*MsgUpdateParam_AsInt64
	//	*MsgUpdateParam_AsBytes
	//	*MsgUpdateParam_AsFloat
	//	*MsgUpdateParam_AsCoin
	AsType isMsgUpdateParam_AsType `protobuf_oneof:"as_type"`
}

MsgUpdateParam is the Msg/UpdateParam request type to update a single param.

func NewMsgUpdateParam added in v0.0.3 

func NewMsgUpdateParam(authority string, name string, value any) (*MsgUpdateParam, error)

NewMsgUpdateParam creates a new MsgUpdateParam instance for a single governance parameter update.

func (*MsgUpdateParam) Descriptor added in v0.0.3 

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

func (*MsgUpdateParam) GetAsBytes added in v0.0.3 

func (m *MsgUpdateParam) GetAsBytes() []byte

func (*MsgUpdateParam) GetAsCoin added in v0.0.3 

func (m *MsgUpdateParam) GetAsCoin() *types.Coin

func (*MsgUpdateParam) GetAsFloat added in v0.0.3 

func (m *MsgUpdateParam) GetAsFloat() float32

func (*MsgUpdateParam) GetAsInt64 added in v0.0.3 

func (m *MsgUpdateParam) GetAsInt64() int64

func (*MsgUpdateParam) GetAsString added in v0.0.3 

func (m *MsgUpdateParam) GetAsString() string

func (*MsgUpdateParam) GetAsType added in v0.0.3 

func (m *MsgUpdateParam) GetAsType() isMsgUpdateParam_AsType

func (*MsgUpdateParam) GetAuthority added in v0.0.3 

func (m *MsgUpdateParam) GetAuthority() string

func (*MsgUpdateParam) GetName added in v0.0.3 

func (m *MsgUpdateParam) GetName() string

func (*MsgUpdateParam) Marshal added in v0.0.3 

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

func (*MsgUpdateParam) MarshalTo added in v0.0.3 

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

func (*MsgUpdateParam) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgUpdateParam) ProtoMessage added in v0.0.3 

func (*MsgUpdateParam) ProtoMessage()

func (*MsgUpdateParam) Reset added in v0.0.3 

func (m *MsgUpdateParam) Reset()

func (*MsgUpdateParam) Size added in v0.0.3 

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

func (*MsgUpdateParam) String added in v0.0.3 

func (m *MsgUpdateParam) String() string

func (*MsgUpdateParam) Unmarshal added in v0.0.3 

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

func (*MsgUpdateParam) ValidateBasic added in v0.0.3 

func (msg *MsgUpdateParam) ValidateBasic() error

ValidateBasic performs a basic validation of the MsgUpdateParam fields. It ensures the parameter name is supported and the parameter type matches the expected type for a given parameter name.

func (*MsgUpdateParam) XXX_DiscardUnknown added in v0.0.3 

func (m *MsgUpdateParam) XXX_DiscardUnknown()

func (*MsgUpdateParam) XXX_Marshal added in v0.0.3 

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

func (*MsgUpdateParam) XXX_Merge added in v0.0.3 

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

func (*MsgUpdateParam) XXX_OneofWrappers added in v0.0.3 

func (*MsgUpdateParam) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MsgUpdateParam) XXX_Size added in v0.0.3 

func (m *MsgUpdateParam) XXX_Size() int

func (*MsgUpdateParam) XXX_Unmarshal added in v0.0.3 

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

type MsgUpdateParamResponse added in v0.0.3 

type MsgUpdateParamResponse struct {
	Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
}

MsgUpdateParamResponse defines the response structure for executing a MsgUpdateParam message after a single param update.

func (*MsgUpdateParamResponse) Descriptor added in v0.0.3 

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

func (*MsgUpdateParamResponse) GetParams added in v0.0.3 

func (m *MsgUpdateParamResponse) GetParams() *Params

func (*MsgUpdateParamResponse) Marshal added in v0.0.3 

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

func (*MsgUpdateParamResponse) MarshalTo added in v0.0.3 

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

func (*MsgUpdateParamResponse) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgUpdateParamResponse) ProtoMessage added in v0.0.3 

func (*MsgUpdateParamResponse) ProtoMessage()

func (*MsgUpdateParamResponse) Reset added in v0.0.3 

func (m *MsgUpdateParamResponse) Reset()

func (*MsgUpdateParamResponse) Size added in v0.0.3 

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

func (*MsgUpdateParamResponse) String added in v0.0.3 

func (m *MsgUpdateParamResponse) String() string

func (*MsgUpdateParamResponse) Unmarshal added in v0.0.3 

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

func (*MsgUpdateParamResponse) XXX_DiscardUnknown added in v0.0.3 

func (m *MsgUpdateParamResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamResponse) XXX_Marshal added in v0.0.3 

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

func (*MsgUpdateParamResponse) XXX_Merge added in v0.0.3 

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

func (*MsgUpdateParamResponse) XXX_Size added in v0.0.3 

func (m *MsgUpdateParamResponse) XXX_Size() int

func (*MsgUpdateParamResponse) XXX_Unmarshal added in v0.0.3 

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

type MsgUpdateParam_AsBytes added in v0.0.3 

type MsgUpdateParam_AsBytes struct {
	AsBytes []byte `protobuf:"bytes,7,opt,name=as_bytes,json=asBytes,proto3,oneof" json:"as_bytes"`
}

func (*MsgUpdateParam_AsBytes) MarshalTo added in v0.0.3 

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

func (*MsgUpdateParam_AsBytes) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgUpdateParam_AsBytes) Size added in v0.0.3 

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

type MsgUpdateParam_AsCoin added in v0.0.3 

type MsgUpdateParam_AsCoin struct {
	AsCoin *types.Coin `protobuf:"bytes,9,opt,name=as_coin,json=asCoin,proto3,oneof" json:"as_coin"`
}

func (*MsgUpdateParam_AsCoin) MarshalTo added in v0.0.3 

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

func (*MsgUpdateParam_AsCoin) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgUpdateParam_AsCoin) Size added in v0.0.3 

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

type MsgUpdateParam_AsFloat added in v0.0.3 

type MsgUpdateParam_AsFloat struct {
	AsFloat float32 `protobuf:"fixed32,8,opt,name=as_float,json=asFloat,proto3,oneof" json:"as_float"`
}

func (*MsgUpdateParam_AsFloat) MarshalTo added in v0.0.3 

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

func (*MsgUpdateParam_AsFloat) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgUpdateParam_AsFloat) Size added in v0.0.3 

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

type MsgUpdateParam_AsInt64 added in v0.0.3 

type MsgUpdateParam_AsInt64 struct {
	AsInt64 int64 `protobuf:"varint,6,opt,name=as_int64,json=asInt64,proto3,oneof" json:"as_int64"`
}

func (*MsgUpdateParam_AsInt64) MarshalTo added in v0.0.3 

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

func (*MsgUpdateParam_AsInt64) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgUpdateParam_AsInt64) Size added in v0.0.3 

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

type MsgUpdateParam_AsString added in v0.0.3 

type MsgUpdateParam_AsString struct {
	AsString string `protobuf:"bytes,3,opt,name=as_string,json=asString,proto3,oneof" json:"as_string"`
}

func (*MsgUpdateParam_AsString) MarshalTo added in v0.0.3 

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

func (*MsgUpdateParam_AsString) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgUpdateParam_AsString) Size added in v0.0.3 

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

type MsgUpdateParams added in v0.0.3 

type MsgUpdateParams struct {
	// authority is the address that controls the module (defaults to x/gov unless overwritten).
	Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
	// params defines the x/proof parameters to update.
	// NOTE: All parameters must be supplied.
	Params Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params"`
}

MsgUpdateParams is the Msg/UpdateParams request type to update all params at once.

func (*MsgUpdateParams) Descriptor added in v0.0.3 

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

func (*MsgUpdateParams) GetAuthority added in v0.0.3 

func (m *MsgUpdateParams) GetAuthority() string

func (*MsgUpdateParams) GetParams added in v0.0.3 

func (m *MsgUpdateParams) GetParams() Params

func (*MsgUpdateParams) Marshal added in v0.0.3 

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

func (*MsgUpdateParams) MarshalTo added in v0.0.3 

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

func (*MsgUpdateParams) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgUpdateParams) ProtoMessage added in v0.0.3 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset added in v0.0.3 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size added in v0.0.3 

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

func (*MsgUpdateParams) String added in v0.0.3 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal added in v0.0.3 

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

func (*MsgUpdateParams) ValidateBasic added in v0.0.3 

func (msg *MsgUpdateParams) ValidateBasic() error

ValidateBasic does a sanity check on the provided data.

func (*MsgUpdateParams) XXX_DiscardUnknown added in v0.0.3 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal added in v0.0.3 

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

func (*MsgUpdateParams) XXX_Merge added in v0.0.3 

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

func (*MsgUpdateParams) XXX_Size added in v0.0.3 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal added in v0.0.3 

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

type MsgUpdateParamsResponse added in v0.0.3 

type MsgUpdateParamsResponse struct {
}

MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.

func (*MsgUpdateParamsResponse) Descriptor added in v0.0.3 

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

func (*MsgUpdateParamsResponse) Marshal added in v0.0.3 

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

func (*MsgUpdateParamsResponse) MarshalTo added in v0.0.3 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer added in v0.0.3 

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

func (*MsgUpdateParamsResponse) ProtoMessage added in v0.0.3 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset added in v0.0.3 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size added in v0.0.3 

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

func (*MsgUpdateParamsResponse) String added in v0.0.3 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal added in v0.0.3 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown added in v0.0.3 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal added in v0.0.3 

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

func (*MsgUpdateParamsResponse) XXX_Merge added in v0.0.3 

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

func (*MsgUpdateParamsResponse) XXX_Size added in v0.0.3 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal added in v0.0.3 

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

type Params added in v0.0.3 

type Params struct {
	// TODO_FOLLOWUP(@olshansk, #690): Either delete this or change it to be named "minimum"
	// relay_difficulty_target_hash is the maximum value a relay hash must be less than to be volume/reward applicable.
	RelayDifficultyTargetHash []byte `` /* 130-byte string literal not displayed */
	// proof_request_probability is the probability of a session requiring a proof
	// if it's cost (i.e. compute unit consumption) is below the ProofRequirementThreshold.
	ProofRequestProbability float32 `protobuf:"fixed32,2,opt,name=proof_request_probability,json=proofRequestProbability,proto3" json:"proof_request_probability"`
	// proof_requirement_threshold is the session cost (i.e. compute unit consumption)
	// threshold which asserts that a session MUST have a corresponding proof when its cost
	// is equal to or above the threshold. This is in contrast to the this requirement
	// being determined probabilistically via ProofRequestProbability.
	//
	// TODO_MAINNET: Consider renaming this to `proof_requirement_threshold_compute_units`.
	ProofRequirementThreshold uint64 `` /* 129-byte string literal not displayed */
	// proof_missing_penalty is the number of tokens (uPOKT) which should be slashed from a supplier
	// when a proof is required (either via proof_requirement_threshold or proof_missing_penalty)
	// but is not provided.
	ProofMissingPenalty *types.Coin `protobuf:"bytes,4,opt,name=proof_missing_penalty,json=proofMissingPenalty,proto3" json:"proof_missing_penalty"`
	// proof_submission_fee is the number of tokens (uPOKT) which should be paid by
	// the supplier operator when submitting a proof.
	// This is needed to account for the cost of storing proofs on-chain and prevent
	// spamming (i.e. sybil bloat attacks) the network with non-required proofs.
	ProofSubmissionFee *types.Coin `protobuf:"bytes,5,opt,name=proof_submission_fee,json=proofSubmissionFee,proto3" json:"proof_submission_fee"`
}

Params defines the parameters for the module.

func DefaultParams added in v0.0.3 

func DefaultParams() Params

DefaultParams returns a default set of parameters

func NewParams added in v0.0.3 

func NewParams(
	relayDifficultyTargetHash []byte,
	proofRequestProbability float32,
	proofRequirementThreshold uint64,
	proofMissingPenalty *cosmostypes.Coin,
	proofSubmissionFee *cosmostypes.Coin,
) Params

NewParams creates a new Params instance

func (*Params) Descriptor added in v0.0.3 

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

func (*Params) Equal added in v0.0.3 

func (this *Params) Equal(that interface{}) bool

func (*Params) GetProofMissingPenalty added in v0.0.3 

func (m *Params) GetProofMissingPenalty() *types.Coin

func (*Params) GetProofRequestProbability added in v0.0.3 

func (m *Params) GetProofRequestProbability() float32

func (*Params) GetProofRequirementThreshold added in v0.0.3 

func (m *Params) GetProofRequirementThreshold() uint64

func (*Params) GetProofSubmissionFee added in v0.0.8 

func (m *Params) GetProofSubmissionFee() *types.Coin

func (*Params) GetRelayDifficultyTargetHash added in v0.0.5 

func (m *Params) GetRelayDifficultyTargetHash() []byte

func (*Params) Marshal added in v0.0.3 

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

func (*Params) MarshalTo added in v0.0.3 

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

func (*Params) MarshalToSizedBuffer added in v0.0.3 

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

func (*Params) ParamSetPairs added in v0.0.3 

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

ParamSetPairs get the params.ParamSet

func (*Params) ProtoMessage added in v0.0.3 

func (*Params) ProtoMessage()

func (*Params) Reset added in v0.0.3 

func (m *Params) Reset()

func (*Params) Size added in v0.0.3 

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

func (*Params) String added in v0.0.3 

func (m *Params) String() string

func (*Params) Unmarshal added in v0.0.3 

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

func (*Params) ValidateBasic added in v0.0.3 

func (params *Params) ValidateBasic() error

ValidateBasic does a sanity check on the provided params.

func (*Params) XXX_DiscardUnknown added in v0.0.3 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal added in v0.0.3 

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

func (*Params) XXX_Merge added in v0.0.3 

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

func (*Params) XXX_Size added in v0.0.3 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal added in v0.0.3 

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

type Proof added in v0.0.3 

type Proof struct {
	// Address of the supplier's operator that submitted this proof.
	SupplierOperatorAddress string `` /* 132-byte string literal not displayed */
	// The session header of the session that this claim is for.
	SessionHeader *types.SessionHeader `protobuf:"bytes,2,opt,name=session_header,json=sessionHeader,proto3" json:"session_header,omitempty"`
	// The serialized SMST proof from the `#ClosestProof()` method.
	ClosestMerkleProof []byte `protobuf:"bytes,3,opt,name=closest_merkle_proof,json=closestMerkleProof,proto3" json:"closest_merkle_proof,omitempty"`
}

func (*Proof) Descriptor added in v0.0.3 

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

func (*Proof) GetClosestMerkleProof added in v0.0.3 

func (m *Proof) GetClosestMerkleProof() []byte

func (*Proof) GetSessionHeader added in v0.0.3 

func (m *Proof) GetSessionHeader() *types.SessionHeader

func (*Proof) GetSupplierOperatorAddress added in v0.0.6 

func (m *Proof) GetSupplierOperatorAddress() string

func (*Proof) Marshal added in v0.0.3 

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

func (*Proof) MarshalTo added in v0.0.3 

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

func (*Proof) MarshalToSizedBuffer added in v0.0.3 

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

func (*Proof) ProtoMessage added in v0.0.3 

func (*Proof) ProtoMessage()

func (*Proof) Reset added in v0.0.3 

func (m *Proof) Reset()

func (*Proof) Size added in v0.0.3 

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

func (*Proof) String added in v0.0.3 

func (m *Proof) String() string

func (*Proof) Unmarshal added in v0.0.3 

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

func (*Proof) XXX_DiscardUnknown added in v0.0.3 

func (m *Proof) XXX_DiscardUnknown()

func (*Proof) XXX_Marshal added in v0.0.3 

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

func (*Proof) XXX_Merge added in v0.0.3 

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

func (*Proof) XXX_Size added in v0.0.3 

func (m *Proof) XXX_Size() int

func (*Proof) XXX_Unmarshal added in v0.0.3 

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

type ProofRequirementReason added in v0.0.3 

type ProofRequirementReason int32
const (
	ProofRequirementReason_NOT_REQUIRED  ProofRequirementReason = 0
	ProofRequirementReason_PROBABILISTIC ProofRequirementReason = 1
	ProofRequirementReason_THRESHOLD     ProofRequirementReason = 2
)

func (ProofRequirementReason) EnumDescriptor added in v0.0.3 

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

func (ProofRequirementReason) String added in v0.0.3 

func (x ProofRequirementReason) String() string

type QueryAllClaimsRequest added in v0.0.3 

type QueryAllClaimsRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// Types that are valid to be assigned to Filter:
	//	*QueryAllClaimsRequest_SupplierOperatorAddress
	//	*QueryAllClaimsRequest_SessionId
	//	*QueryAllClaimsRequest_SessionEndHeight
	Filter isQueryAllClaimsRequest_Filter `protobuf_oneof:"filter"`
}

func (*QueryAllClaimsRequest) Descriptor added in v0.0.3 

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

func (*QueryAllClaimsRequest) GetFilter added in v0.0.3 

func (m *QueryAllClaimsRequest) GetFilter() isQueryAllClaimsRequest_Filter

func (*QueryAllClaimsRequest) GetPagination added in v0.0.3 

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

func (*QueryAllClaimsRequest) GetSessionEndHeight added in v0.0.3 

func (m *QueryAllClaimsRequest) GetSessionEndHeight() uint64

func (*QueryAllClaimsRequest) GetSessionId added in v0.0.3 

func (m *QueryAllClaimsRequest) GetSessionId() string

func (*QueryAllClaimsRequest) GetSupplierOperatorAddress added in v0.0.6 

func (m *QueryAllClaimsRequest) GetSupplierOperatorAddress() string

func (*QueryAllClaimsRequest) Marshal added in v0.0.3 

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

func (*QueryAllClaimsRequest) MarshalTo added in v0.0.3 

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

func (*QueryAllClaimsRequest) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryAllClaimsRequest) ProtoMessage added in v0.0.3 

func (*QueryAllClaimsRequest) ProtoMessage()

func (*QueryAllClaimsRequest) Reset added in v0.0.3 

func (m *QueryAllClaimsRequest) Reset()

func (*QueryAllClaimsRequest) Size added in v0.0.3 

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

func (*QueryAllClaimsRequest) String added in v0.0.3 

func (m *QueryAllClaimsRequest) String() string

func (*QueryAllClaimsRequest) Unmarshal added in v0.0.3 

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

func (*QueryAllClaimsRequest) ValidateBasic added in v0.0.3 

func (query *QueryAllClaimsRequest) ValidateBasic() error

ValidateBasic performs basic (non-state-dependant) validation on a QueryAllClaimsRequest.

func (*QueryAllClaimsRequest) XXX_DiscardUnknown added in v0.0.3 

func (m *QueryAllClaimsRequest) XXX_DiscardUnknown()

func (*QueryAllClaimsRequest) XXX_Marshal added in v0.0.3 

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

func (*QueryAllClaimsRequest) XXX_Merge added in v0.0.3 

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

func (*QueryAllClaimsRequest) XXX_OneofWrappers added in v0.0.3 

func (*QueryAllClaimsRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueryAllClaimsRequest) XXX_Size added in v0.0.3 

func (m *QueryAllClaimsRequest) XXX_Size() int

func (*QueryAllClaimsRequest) XXX_Unmarshal added in v0.0.3 

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

type QueryAllClaimsRequest_SessionEndHeight added in v0.0.3 

type QueryAllClaimsRequest_SessionEndHeight struct {
	SessionEndHeight uint64 `protobuf:"varint,4,opt,name=session_end_height,json=sessionEndHeight,proto3,oneof" json:"session_end_height,omitempty"`
}

func (*QueryAllClaimsRequest_SessionEndHeight) MarshalTo added in v0.0.3 

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

func (*QueryAllClaimsRequest_SessionEndHeight) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryAllClaimsRequest_SessionEndHeight) Size added in v0.0.3 

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

type QueryAllClaimsRequest_SessionId added in v0.0.3 

type QueryAllClaimsRequest_SessionId struct {
	SessionId string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3,oneof" json:"session_id,omitempty"`
}

func (*QueryAllClaimsRequest_SessionId) MarshalTo added in v0.0.3 

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

func (*QueryAllClaimsRequest_SessionId) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryAllClaimsRequest_SessionId) Size added in v0.0.3 

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

type QueryAllClaimsRequest_SupplierOperatorAddress added in v0.0.6 

type QueryAllClaimsRequest_SupplierOperatorAddress struct {
	SupplierOperatorAddress string `` /* 138-byte string literal not displayed */
}

func (*QueryAllClaimsRequest_SupplierOperatorAddress) MarshalTo added in v0.0.6 

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

func (*QueryAllClaimsRequest_SupplierOperatorAddress) MarshalToSizedBuffer added in v0.0.6 

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

func (*QueryAllClaimsRequest_SupplierOperatorAddress) Size added in v0.0.6 

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

type QueryAllClaimsResponse added in v0.0.3 

type QueryAllClaimsResponse struct {
	Claims     []Claim             `protobuf:"bytes,1,rep,name=claims,proto3" json:"claims"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryAllClaimsResponse) Descriptor added in v0.0.3 

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

func (*QueryAllClaimsResponse) GetClaims added in v0.0.3 

func (m *QueryAllClaimsResponse) GetClaims() []Claim

func (*QueryAllClaimsResponse) GetPagination added in v0.0.3 

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

func (*QueryAllClaimsResponse) Marshal added in v0.0.3 

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

func (*QueryAllClaimsResponse) MarshalTo added in v0.0.3 

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

func (*QueryAllClaimsResponse) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryAllClaimsResponse) ProtoMessage added in v0.0.3 

func (*QueryAllClaimsResponse) ProtoMessage()

func (*QueryAllClaimsResponse) Reset added in v0.0.3 

func (m *QueryAllClaimsResponse) Reset()

func (*QueryAllClaimsResponse) Size added in v0.0.3 

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

func (*QueryAllClaimsResponse) String added in v0.0.3 

func (m *QueryAllClaimsResponse) String() string

func (*QueryAllClaimsResponse) Unmarshal added in v0.0.3 

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

func (*QueryAllClaimsResponse) XXX_DiscardUnknown added in v0.0.3 

func (m *QueryAllClaimsResponse) XXX_DiscardUnknown()

func (*QueryAllClaimsResponse) XXX_Marshal added in v0.0.3 

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

func (*QueryAllClaimsResponse) XXX_Merge added in v0.0.3 

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

func (*QueryAllClaimsResponse) XXX_Size added in v0.0.3 

func (m *QueryAllClaimsResponse) XXX_Size() int

func (*QueryAllClaimsResponse) XXX_Unmarshal added in v0.0.3 

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

type QueryAllProofsRequest added in v0.0.3 

type QueryAllProofsRequest struct {
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// Types that are valid to be assigned to Filter:
	//
	//	*QueryAllProofsRequest_SupplierOperatorAddress
	//	*QueryAllProofsRequest_SessionId
	//	*QueryAllProofsRequest_SessionEndHeight
	Filter isQueryAllProofsRequest_Filter `protobuf_oneof:"filter"`
}

func (*QueryAllProofsRequest) Descriptor added in v0.0.3 

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

func (*QueryAllProofsRequest) GetFilter added in v0.0.3 

func (m *QueryAllProofsRequest) GetFilter() isQueryAllProofsRequest_Filter

func (*QueryAllProofsRequest) GetPagination added in v0.0.3 

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

func (*QueryAllProofsRequest) GetSessionEndHeight added in v0.0.3 

func (m *QueryAllProofsRequest) GetSessionEndHeight() uint64

func (*QueryAllProofsRequest) GetSessionId added in v0.0.3 

func (m *QueryAllProofsRequest) GetSessionId() string

func (*QueryAllProofsRequest) GetSupplierOperatorAddress added in v0.0.6 

func (m *QueryAllProofsRequest) GetSupplierOperatorAddress() string

func (*QueryAllProofsRequest) Marshal added in v0.0.3 

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

func (*QueryAllProofsRequest) MarshalTo added in v0.0.3 

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

func (*QueryAllProofsRequest) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryAllProofsRequest) ProtoMessage added in v0.0.3 

func (*QueryAllProofsRequest) ProtoMessage()

func (*QueryAllProofsRequest) Reset added in v0.0.3 

func (m *QueryAllProofsRequest) Reset()

func (*QueryAllProofsRequest) Size added in v0.0.3 

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

func (*QueryAllProofsRequest) String added in v0.0.3 

func (m *QueryAllProofsRequest) String() string

func (*QueryAllProofsRequest) Unmarshal added in v0.0.3 

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

func (*QueryAllProofsRequest) ValidateBasic added in v0.0.3 

func (query *QueryAllProofsRequest) ValidateBasic() error

func (*QueryAllProofsRequest) XXX_DiscardUnknown added in v0.0.3 

func (m *QueryAllProofsRequest) XXX_DiscardUnknown()

func (*QueryAllProofsRequest) XXX_Marshal added in v0.0.3 

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

func (*QueryAllProofsRequest) XXX_Merge added in v0.0.3 

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

func (*QueryAllProofsRequest) XXX_OneofWrappers added in v0.0.3 

func (*QueryAllProofsRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*QueryAllProofsRequest) XXX_Size added in v0.0.3 

func (m *QueryAllProofsRequest) XXX_Size() int

func (*QueryAllProofsRequest) XXX_Unmarshal added in v0.0.3 

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

type QueryAllProofsRequest_SessionEndHeight added in v0.0.3 

type QueryAllProofsRequest_SessionEndHeight struct {
	SessionEndHeight uint64 `protobuf:"varint,4,opt,name=session_end_height,json=sessionEndHeight,proto3,oneof" json:"session_end_height,omitempty"`
}

func (*QueryAllProofsRequest_SessionEndHeight) MarshalTo added in v0.0.3 

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

func (*QueryAllProofsRequest_SessionEndHeight) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryAllProofsRequest_SessionEndHeight) Size added in v0.0.3 

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

type QueryAllProofsRequest_SessionId added in v0.0.3 

type QueryAllProofsRequest_SessionId struct {
	SessionId string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3,oneof" json:"session_id,omitempty"`
}

func (*QueryAllProofsRequest_SessionId) MarshalTo added in v0.0.3 

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

func (*QueryAllProofsRequest_SessionId) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryAllProofsRequest_SessionId) Size added in v0.0.3 

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

type QueryAllProofsRequest_SupplierOperatorAddress added in v0.0.6 

type QueryAllProofsRequest_SupplierOperatorAddress struct {
	SupplierOperatorAddress string `` /* 138-byte string literal not displayed */
}

func (*QueryAllProofsRequest_SupplierOperatorAddress) MarshalTo added in v0.0.6 

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

func (*QueryAllProofsRequest_SupplierOperatorAddress) MarshalToSizedBuffer added in v0.0.6 

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

func (*QueryAllProofsRequest_SupplierOperatorAddress) Size added in v0.0.6 

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

type QueryAllProofsResponse added in v0.0.3 

type QueryAllProofsResponse struct {
	Proofs     []Proof             `protobuf:"bytes,1,rep,name=proofs,proto3" json:"proofs"`
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

func (*QueryAllProofsResponse) Descriptor added in v0.0.3 

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

func (*QueryAllProofsResponse) GetPagination added in v0.0.3 

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

func (*QueryAllProofsResponse) GetProofs added in v0.0.3 

func (m *QueryAllProofsResponse) GetProofs() []Proof

func (*QueryAllProofsResponse) Marshal added in v0.0.3 

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

func (*QueryAllProofsResponse) MarshalTo added in v0.0.3 

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

func (*QueryAllProofsResponse) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryAllProofsResponse) ProtoMessage added in v0.0.3 

func (*QueryAllProofsResponse) ProtoMessage()

func (*QueryAllProofsResponse) Reset added in v0.0.3 

func (m *QueryAllProofsResponse) Reset()

func (*QueryAllProofsResponse) Size added in v0.0.3 

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

func (*QueryAllProofsResponse) String added in v0.0.3 

func (m *QueryAllProofsResponse) String() string

func (*QueryAllProofsResponse) Unmarshal added in v0.0.3 

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

func (*QueryAllProofsResponse) XXX_DiscardUnknown added in v0.0.3 

func (m *QueryAllProofsResponse) XXX_DiscardUnknown()

func (*QueryAllProofsResponse) XXX_Marshal added in v0.0.3 

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

func (*QueryAllProofsResponse) XXX_Merge added in v0.0.3 

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

func (*QueryAllProofsResponse) XXX_Size added in v0.0.3 

func (m *QueryAllProofsResponse) XXX_Size() int

func (*QueryAllProofsResponse) XXX_Unmarshal added in v0.0.3 

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

type QueryClient added in v0.0.3 

type QueryClient interface {
	// Parameters queries the parameters of the module.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// Queries a list of Claim items.
	Claim(ctx context.Context, in *QueryGetClaimRequest, opts ...grpc.CallOption) (*QueryGetClaimResponse, error)
	AllClaims(ctx context.Context, in *QueryAllClaimsRequest, opts ...grpc.CallOption) (*QueryAllClaimsResponse, error)
	// Queries a list of Proof items.
	Proof(ctx context.Context, in *QueryGetProofRequest, opts ...grpc.CallOption) (*QueryGetProofResponse, error)
	AllProofs(ctx context.Context, in *QueryAllProofsRequest, opts ...grpc.CallOption) (*QueryAllProofsResponse, 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 added in v0.0.3 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryGetClaimRequest added in v0.0.3 

type QueryGetClaimRequest struct {
	SessionId               string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	SupplierOperatorAddress string `` /* 132-byte string literal not displayed */
}

func (*QueryGetClaimRequest) Descriptor added in v0.0.3 

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

func (*QueryGetClaimRequest) GetSessionId added in v0.0.3 

func (m *QueryGetClaimRequest) GetSessionId() string

func (*QueryGetClaimRequest) GetSupplierOperatorAddress added in v0.0.6 

func (m *QueryGetClaimRequest) GetSupplierOperatorAddress() string

func (*QueryGetClaimRequest) Marshal added in v0.0.3 

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

func (*QueryGetClaimRequest) MarshalTo added in v0.0.3 

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

func (*QueryGetClaimRequest) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryGetClaimRequest) ProtoMessage added in v0.0.3 

func (*QueryGetClaimRequest) ProtoMessage()

func (*QueryGetClaimRequest) Reset added in v0.0.3 

func (m *QueryGetClaimRequest) Reset()

func (*QueryGetClaimRequest) Size added in v0.0.3 

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

func (*QueryGetClaimRequest) String added in v0.0.3 

func (m *QueryGetClaimRequest) String() string

func (*QueryGetClaimRequest) Unmarshal added in v0.0.3 

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

func (*QueryGetClaimRequest) ValidateBasic added in v0.0.3 

func (query *QueryGetClaimRequest) ValidateBasic() error

ValidateBasic performs basic (non-state-dependant) validation on a QueryGetClaimRequest.

func (*QueryGetClaimRequest) XXX_DiscardUnknown added in v0.0.3 

func (m *QueryGetClaimRequest) XXX_DiscardUnknown()

func (*QueryGetClaimRequest) XXX_Marshal added in v0.0.3 

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

func (*QueryGetClaimRequest) XXX_Merge added in v0.0.3 

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

func (*QueryGetClaimRequest) XXX_Size added in v0.0.3 

func (m *QueryGetClaimRequest) XXX_Size() int

func (*QueryGetClaimRequest) XXX_Unmarshal added in v0.0.3 

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

type QueryGetClaimResponse added in v0.0.3 

type QueryGetClaimResponse struct {
	Claim Claim `protobuf:"bytes,1,opt,name=claim,proto3" json:"claim"`
}

func (*QueryGetClaimResponse) Descriptor added in v0.0.3 

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

func (*QueryGetClaimResponse) GetClaim added in v0.0.3 

func (m *QueryGetClaimResponse) GetClaim() Claim

func (*QueryGetClaimResponse) Marshal added in v0.0.3 

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

func (*QueryGetClaimResponse) MarshalTo added in v0.0.3 

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

func (*QueryGetClaimResponse) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryGetClaimResponse) ProtoMessage added in v0.0.3 

func (*QueryGetClaimResponse) ProtoMessage()

func (*QueryGetClaimResponse) Reset added in v0.0.3 

func (m *QueryGetClaimResponse) Reset()

func (*QueryGetClaimResponse) Size added in v0.0.3 

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

func (*QueryGetClaimResponse) String added in v0.0.3 

func (m *QueryGetClaimResponse) String() string

func (*QueryGetClaimResponse) Unmarshal added in v0.0.3 

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

func (*QueryGetClaimResponse) XXX_DiscardUnknown added in v0.0.3 

func (m *QueryGetClaimResponse) XXX_DiscardUnknown()

func (*QueryGetClaimResponse) XXX_Marshal added in v0.0.3 

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

func (*QueryGetClaimResponse) XXX_Merge added in v0.0.3 

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

func (*QueryGetClaimResponse) XXX_Size added in v0.0.3 

func (m *QueryGetClaimResponse) XXX_Size() int

func (*QueryGetClaimResponse) XXX_Unmarshal added in v0.0.3 

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

type QueryGetProofRequest added in v0.0.3 

type QueryGetProofRequest struct {
	SessionId               string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	SupplierOperatorAddress string `` /* 132-byte string literal not displayed */
}

func (*QueryGetProofRequest) Descriptor added in v0.0.3 

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

func (*QueryGetProofRequest) GetSessionId added in v0.0.3 

func (m *QueryGetProofRequest) GetSessionId() string

func (*QueryGetProofRequest) GetSupplierOperatorAddress added in v0.0.6 

func (m *QueryGetProofRequest) GetSupplierOperatorAddress() string

func (*QueryGetProofRequest) Marshal added in v0.0.3 

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

func (*QueryGetProofRequest) MarshalTo added in v0.0.3 

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

func (*QueryGetProofRequest) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryGetProofRequest) ProtoMessage added in v0.0.3 

func (*QueryGetProofRequest) ProtoMessage()

func (*QueryGetProofRequest) Reset added in v0.0.3 

func (m *QueryGetProofRequest) Reset()

func (*QueryGetProofRequest) Size added in v0.0.3 

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

func (*QueryGetProofRequest) String added in v0.0.3 

func (m *QueryGetProofRequest) String() string

func (*QueryGetProofRequest) Unmarshal added in v0.0.3 

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

func (*QueryGetProofRequest) ValidateBasic added in v0.0.3 

func (query *QueryGetProofRequest) ValidateBasic() error

func (*QueryGetProofRequest) XXX_DiscardUnknown added in v0.0.3 

func (m *QueryGetProofRequest) XXX_DiscardUnknown()

func (*QueryGetProofRequest) XXX_Marshal added in v0.0.3 

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

func (*QueryGetProofRequest) XXX_Merge added in v0.0.3 

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

func (*QueryGetProofRequest) XXX_Size added in v0.0.3 

func (m *QueryGetProofRequest) XXX_Size() int

func (*QueryGetProofRequest) XXX_Unmarshal added in v0.0.3 

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

type QueryGetProofResponse added in v0.0.3 

type QueryGetProofResponse struct {
	Proof Proof `protobuf:"bytes,1,opt,name=proof,proto3" json:"proof"`
}

func (*QueryGetProofResponse) Descriptor added in v0.0.3 

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

func (*QueryGetProofResponse) GetProof added in v0.0.3 

func (m *QueryGetProofResponse) GetProof() Proof

func (*QueryGetProofResponse) Marshal added in v0.0.3 

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

func (*QueryGetProofResponse) MarshalTo added in v0.0.3 

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

func (*QueryGetProofResponse) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryGetProofResponse) ProtoMessage added in v0.0.3 

func (*QueryGetProofResponse) ProtoMessage()

func (*QueryGetProofResponse) Reset added in v0.0.3 

func (m *QueryGetProofResponse) Reset()

func (*QueryGetProofResponse) Size added in v0.0.3 

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

func (*QueryGetProofResponse) String added in v0.0.3 

func (m *QueryGetProofResponse) String() string

func (*QueryGetProofResponse) Unmarshal added in v0.0.3 

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

func (*QueryGetProofResponse) XXX_DiscardUnknown added in v0.0.3 

func (m *QueryGetProofResponse) XXX_DiscardUnknown()

func (*QueryGetProofResponse) XXX_Marshal added in v0.0.3 

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

func (*QueryGetProofResponse) XXX_Merge added in v0.0.3 

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

func (*QueryGetProofResponse) XXX_Size added in v0.0.3 

func (m *QueryGetProofResponse) XXX_Size() int

func (*QueryGetProofResponse) XXX_Unmarshal added in v0.0.3 

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

type QueryParamsRequest added in v0.0.3 

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor added in v0.0.3 

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

func (*QueryParamsRequest) Marshal added in v0.0.3 

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

func (*QueryParamsRequest) MarshalTo added in v0.0.3 

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

func (*QueryParamsRequest) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryParamsRequest) ProtoMessage added in v0.0.3 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset added in v0.0.3 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size added in v0.0.3 

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

func (*QueryParamsRequest) String added in v0.0.3 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal added in v0.0.3 

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

func (*QueryParamsRequest) XXX_DiscardUnknown added in v0.0.3 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal added in v0.0.3 

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

func (*QueryParamsRequest) XXX_Merge added in v0.0.3 

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

func (*QueryParamsRequest) XXX_Size added in v0.0.3 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal added in v0.0.3 

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

type QueryParamsResponse added in v0.0.3 

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 added in v0.0.3 

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

func (*QueryParamsResponse) GetParams added in v0.0.3 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal added in v0.0.3 

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

func (*QueryParamsResponse) MarshalTo added in v0.0.3 

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

func (*QueryParamsResponse) MarshalToSizedBuffer added in v0.0.3 

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

func (*QueryParamsResponse) ProtoMessage added in v0.0.3 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset added in v0.0.3 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size added in v0.0.3 

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

func (*QueryParamsResponse) String added in v0.0.3 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal added in v0.0.3 

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

func (*QueryParamsResponse) XXX_DiscardUnknown added in v0.0.3 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal added in v0.0.3 

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

func (*QueryParamsResponse) XXX_Merge added in v0.0.3 

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

func (*QueryParamsResponse) XXX_Size added in v0.0.3 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal added in v0.0.3 

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

type QueryServer added in v0.0.3 

type QueryServer interface {
	// Parameters queries the parameters of the module.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// Queries a list of Claim items.
	Claim(context.Context, *QueryGetClaimRequest) (*QueryGetClaimResponse, error)
	AllClaims(context.Context, *QueryAllClaimsRequest) (*QueryAllClaimsResponse, error)
	// Queries a list of Proof items.
	Proof(context.Context, *QueryGetProofRequest) (*QueryGetProofResponse, error)
	AllProofs(context.Context, *QueryAllProofsRequest) (*QueryAllProofsResponse, error)
}

QueryServer is the server API for Query service.

type ServiceKeeper added in v0.0.8 

type ServiceKeeper interface {
	GetService(ctx context.Context, serviceID string) (sharedtypes.Service, bool)
	// Only used for testing & simulation
	SetService(ctx context.Context, service sharedtypes.Service)
}

ServiceKeeper defines the expected interface for the Service module.

type SessionKeeper 

type SessionKeeper interface {
	GetSession(context.Context, *sessiontypes.QueryGetSessionRequest) (*sessiontypes.QueryGetSessionResponse, error)
	GetBlockHash(ctx context.Context, height int64) []byte
	StoreBlockHash(ctx context.Context)
}

type SharedKeeper added in v0.0.3 

type SharedKeeper interface {
	GetParams(ctx context.Context) sharedtypes.Params
}

SharedKeeper defines the expected interface needed to retrieve shared information.

type SharedKeeperQueryClient added in v0.0.3 

type SharedKeeperQueryClient struct {
	// contains filtered or unexported fields
}

SharedKeeperQueryClient is a thin wrapper around the SharedKeeper. It does not rely on the QueryClient, and therefore does not make any network requests as in the off-chain implementation.

func (*SharedKeeperQueryClient) GetClaimWindowOpenHeight added in v0.0.3 

func (sqc *SharedKeeperQueryClient) GetClaimWindowOpenHeight(
	ctx context.Context,
	queryHeight int64,
) (int64, error)

GetClaimWindowOpenHeight returns the block height at which the claim window of the session that includes queryHeight opens.

TODO_BLOCKER(@bryanchriswhite, #543): We don't really want to use the current value of the params. Instead, we should be using the value that the params had for the session given by blockHeight.

func (*SharedKeeperQueryClient) GetEarliestSupplierClaimCommitHeight added in v0.0.3 

func (sqc *SharedKeeperQueryClient) GetEarliestSupplierClaimCommitHeight(
	ctx context.Context,
	queryHeight int64,
	supplierOperatorAddr string,
) (int64, error)

GetEarliestSupplierClaimCommitHeight returns the earliest block height at which a claim for the session that includes queryHeight can be committed for a given supplier.

func (*SharedKeeperQueryClient) GetEarliestSupplierProofCommitHeight added in v0.0.3 

func (sqc *SharedKeeperQueryClient) GetEarliestSupplierProofCommitHeight(
	ctx context.Context,
	queryHeight int64,
	supplierOperatorAddr string,
) (int64, error)

GetEarliestSupplierProofCommitHeight returns the earliest block height at which a proof for the session that includes queryHeight can be committed for a given supplier.

func (*SharedKeeperQueryClient) GetParams added in v0.0.3 

func (sqc *SharedKeeperQueryClient) GetParams(
	ctx context.Context,
) (params *sharedtypes.Params, err error)

GetParams queries & returns the shared module on-chain parameters.

func (*SharedKeeperQueryClient) GetProofWindowOpenHeight added in v0.0.3 

func (sqc *SharedKeeperQueryClient) GetProofWindowOpenHeight(
	ctx context.Context,
	queryHeight int64,
) (int64, error)

GetProofWindowOpenHeight returns the block height at which the proof window of the session that includes queryHeight opens.

TODO_BLOCKER(@bryanchriswhite, #543): We don't really want to use the current value of the params. Instead, we should be using the value that the params had for the session given by blockHeight.

func (*SharedKeeperQueryClient) GetSessionGracePeriodEndHeight added in v0.0.3 

func (sqc *SharedKeeperQueryClient) GetSessionGracePeriodEndHeight(
	ctx context.Context,
	queryHeight int64,
) (int64, error)

GetSessionGracePeriodEndHeight returns the block height at which the grace period for the session which includes queryHeight elapses. The grace period is the number of blocks after the session ends during which relays SHOULD be included in the session which most recently ended.

TODO_BLOCKER(@bryanchriswhite, #543): We don't really want to use the current value of the params. Instead, we should be using the value that the params had for the session given by blockHeight.

type SupplierKeeper 

type SupplierKeeper interface {
	SetSupplier(context.Context, sharedtypes.Supplier)
}

type UnimplementedMsgServer added in v0.0.3 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) CreateClaim added in v0.0.3 

func (*UnimplementedMsgServer) CreateClaim(ctx context.Context, req *MsgCreateClaim) (*MsgCreateClaimResponse, error)

func (*UnimplementedMsgServer) SubmitProof added in v0.0.3 

func (*UnimplementedMsgServer) SubmitProof(ctx context.Context, req *MsgSubmitProof) (*MsgSubmitProofResponse, error)

func (*UnimplementedMsgServer) UpdateParam added in v0.0.3 

func (*UnimplementedMsgServer) UpdateParam(ctx context.Context, req *MsgUpdateParam) (*MsgUpdateParamResponse, error)

func (*UnimplementedMsgServer) UpdateParams added in v0.0.3 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServer added in v0.0.3 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) AllClaims added in v0.0.3 

func (*UnimplementedQueryServer) AllClaims(ctx context.Context, req *QueryAllClaimsRequest) (*QueryAllClaimsResponse, error)

func (*UnimplementedQueryServer) AllProofs added in v0.0.3 

func (*UnimplementedQueryServer) AllProofs(ctx context.Context, req *QueryAllProofsRequest) (*QueryAllProofsResponse, error)

func (*UnimplementedQueryServer) Claim added in v0.0.3 

func (*UnimplementedQueryServer) Claim(ctx context.Context, req *QueryGetClaimRequest) (*QueryGetClaimResponse, error)

func (*UnimplementedQueryServer) Params added in v0.0.3 

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

func (*UnimplementedQueryServer) Proof added in v0.0.3 

func (*UnimplementedQueryServer) Proof(ctx context.Context, req *QueryGetProofRequest) (*QueryGetProofResponse, 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.