types

package
v3.1.2-0...-d11e5c9 Latest Latest
Warning

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

 Go to latest Published: Apr 7, 2022 License: Apache-2.0 Imports: 34 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeCork         = "cork"
	EventTypeCommitPeriod = "commit_period"

	AttributeKeySigner            = "signer"
	AttributeKeyValidator         = "validator"
	AttributeKeyPrevoteHash       = "hash"
	AttributeKeyCork              = "cork"
	AttributeKeyCommitPeriodStart = "commit_period_start"
	AttributeKeyCommitPeriodEnd   = "commit_period_end"
	AttributeKeyBlockHeight       = "block_height"

	AttributeValueCategory = ModuleName
)

cork module event types

View Source 
const (
	// ModuleName is the module name constant used in many places
	ModuleName = "cork"

	// StoreKey is the store key string for oracle
	StoreKey = ModuleName

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

	// QuerierRoute is the querier route for oracle
	QuerierRoute = ModuleName
)
View Source 
const (

	// CorkForAddressKeyPrefix - <prefix><val_address><address> -> <cork>
	CorkForAddressKeyPrefix // key for corks

	// CommitPeriodStartKey - <prefix> -> int64(height)
	CommitPeriodStartKey // key for commit period height start

	// LatestInvalidationNonceKey - <prefix> -> uint64(latestNonce)
	LatestInvalidationNonceKey

	// CellarIDsKey - <prefix> -> []string
	CellarIDsKey

	// ScheduledCorkKeyPrefix - <prefix><block_height><val_address><address> -> <cork>
	ScheduledCorkKeyPrefix
)

Keys for cork store, with <prefix><key> -> <value>

View Source 
const (
	TypeMsgSubmitCorkRequest   = "cork_submit"
	TypeMsgScheduleCorkRequest = "cork_schedule"
)
View Source 
const (
	ProposalTypeAddManagedCellarIDs    = "AddManagedCellarIDs"
	ProposalTypeRemoveManagedCellarIDs = "RemoveManagedCellarIDs"
)
View Source 
const DefaultParamspace = ModuleName

Variables

View Source 
var (
	ErrInvalidLengthCork        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCork          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCork = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidAddress         = sdkerrors.Register(ModuleName, 2, "invalid ethereum address")
	ErrUnmanagedCellarAddress = sdkerrors.Register(ModuleName, 3, "cork sent to address that has not passed governance")
	ErrEmptyContractCall      = sdkerrors.Register(ModuleName, 4, "cork has an empty contract call body")
	ErrSchedulingInThePast    = sdkerrors.Register(ModuleName, 5, "cork is trying to be scheduled for a block that has already passed")
)

x/cork module sentinel errors

View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	KeyVotePeriod    = []byte("voteperiod")
	KeyVoteThreshold = []byte("votethreshold")
)

Parameter keys

View Source 
var (
	ErrInvalidLengthProposal        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowProposal          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupProposal = 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")
)

Functions

func GetCorkForValidatorAddressKey 

func GetCorkForValidatorAddressKey(val sdk.ValAddress, contract common.Address) []byte

GetCorkForValidatorAddressKey returns the key for a validators vote for a given address

func GetCorkValidatorKeyPrefix 

func GetCorkValidatorKeyPrefix(val sdk.ValAddress) []byte

GetCorkValidatorKeyPrefix returns the key prefix for cork commits for a validator

func GetScheduledCorkKey 

func GetScheduledCorkKey(blockHeight uint64, val sdk.ValAddress, contract common.Address) []byte

func MakeCellarIDsKey 

func MakeCellarIDsKey() []byte

func ParamKeyTable 

func ParamKeyTable() paramtypes.KeyTable

ParamKeyTable returns the parameter key table.

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces registers the oracle proto files

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

Types

type AddManagedCellarIDsProposal 

type AddManagedCellarIDsProposal struct {
	Title       string       `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	CellarIds   *CellarIDSet `protobuf:"bytes,3,opt,name=cellar_ids,json=cellarIds,proto3" json:"cellar_ids,omitempty"`
}

func NewAddManagedCellarIDsProposal 

func NewAddManagedCellarIDsProposal(title string, description string, cellarIds *CellarIDSet) *AddManagedCellarIDsProposal

func (*AddManagedCellarIDsProposal) Descriptor 

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

func (*AddManagedCellarIDsProposal) GetCellarIds 

func (m *AddManagedCellarIDsProposal) GetCellarIds() *CellarIDSet

func (*AddManagedCellarIDsProposal) GetDescription 

func (m *AddManagedCellarIDsProposal) GetDescription() string

func (*AddManagedCellarIDsProposal) GetTitle 

func (m *AddManagedCellarIDsProposal) GetTitle() string

func (*AddManagedCellarIDsProposal) Marshal 

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

func (*AddManagedCellarIDsProposal) MarshalTo 

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

func (*AddManagedCellarIDsProposal) MarshalToSizedBuffer 

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

func (*AddManagedCellarIDsProposal) ProposalRoute 

func (m *AddManagedCellarIDsProposal) ProposalRoute() string

func (*AddManagedCellarIDsProposal) ProposalType 

func (m *AddManagedCellarIDsProposal) ProposalType() string

func (*AddManagedCellarIDsProposal) ProtoMessage 

func (*AddManagedCellarIDsProposal) ProtoMessage()

func (*AddManagedCellarIDsProposal) Reset 

func (m *AddManagedCellarIDsProposal) Reset()

func (*AddManagedCellarIDsProposal) Size 

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

func (*AddManagedCellarIDsProposal) String 

func (m *AddManagedCellarIDsProposal) String() string

func (*AddManagedCellarIDsProposal) Unmarshal 

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

func (*AddManagedCellarIDsProposal) ValidateBasic 

func (m *AddManagedCellarIDsProposal) ValidateBasic() error

func (*AddManagedCellarIDsProposal) XXX_DiscardUnknown 

func (m *AddManagedCellarIDsProposal) XXX_DiscardUnknown()

func (*AddManagedCellarIDsProposal) XXX_Marshal 

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

func (*AddManagedCellarIDsProposal) XXX_Merge 

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

func (*AddManagedCellarIDsProposal) XXX_Size 

func (m *AddManagedCellarIDsProposal) XXX_Size() int

func (*AddManagedCellarIDsProposal) XXX_Unmarshal 

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

type AddManagedCellarIDsProposalWithDeposit 

type AddManagedCellarIDsProposalWithDeposit struct {
	Title       string   `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	CellarIds   []string `protobuf:"bytes,3,rep,name=cellar_ids,json=cellarIds,proto3" json:"cellar_ids,omitempty"`
	Deposit     string   `protobuf:"bytes,4,opt,name=deposit,proto3" json:"deposit,omitempty"`
}

AddManagedCellarIDsProposalWithDeposit is a specific definition for CLI commands

func (*AddManagedCellarIDsProposalWithDeposit) Descriptor 

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

func (*AddManagedCellarIDsProposalWithDeposit) GetCellarIds 

func (m *AddManagedCellarIDsProposalWithDeposit) GetCellarIds() []string

func (*AddManagedCellarIDsProposalWithDeposit) GetDeposit 

func (m *AddManagedCellarIDsProposalWithDeposit) GetDeposit() string

func (*AddManagedCellarIDsProposalWithDeposit) GetDescription 

func (m *AddManagedCellarIDsProposalWithDeposit) GetDescription() string

func (*AddManagedCellarIDsProposalWithDeposit) GetTitle 

func (m *AddManagedCellarIDsProposalWithDeposit) GetTitle() string

func (*AddManagedCellarIDsProposalWithDeposit) Marshal 

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

func (*AddManagedCellarIDsProposalWithDeposit) MarshalTo 

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

func (*AddManagedCellarIDsProposalWithDeposit) MarshalToSizedBuffer 

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

func (*AddManagedCellarIDsProposalWithDeposit) ProtoMessage 

func (*AddManagedCellarIDsProposalWithDeposit) ProtoMessage()

func (*AddManagedCellarIDsProposalWithDeposit) Reset 

func (m *AddManagedCellarIDsProposalWithDeposit) Reset()

func (*AddManagedCellarIDsProposalWithDeposit) Size 

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

func (*AddManagedCellarIDsProposalWithDeposit) String 

func (m *AddManagedCellarIDsProposalWithDeposit) String() string

func (*AddManagedCellarIDsProposalWithDeposit) Unmarshal 

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

func (*AddManagedCellarIDsProposalWithDeposit) XXX_DiscardUnknown 

func (m *AddManagedCellarIDsProposalWithDeposit) XXX_DiscardUnknown()

func (*AddManagedCellarIDsProposalWithDeposit) XXX_Marshal 

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

func (*AddManagedCellarIDsProposalWithDeposit) XXX_Merge 

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

func (*AddManagedCellarIDsProposalWithDeposit) XXX_Size 

func (m *AddManagedCellarIDsProposalWithDeposit) XXX_Size() int

func (*AddManagedCellarIDsProposalWithDeposit) XXX_Unmarshal 

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

type CellarIDSet 

type CellarIDSet struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
}

func (*CellarIDSet) Descriptor 

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

func (*CellarIDSet) GetIds 

func (m *CellarIDSet) GetIds() []string

func (*CellarIDSet) Marshal 

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

func (*CellarIDSet) MarshalTo 

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

func (*CellarIDSet) MarshalToSizedBuffer 

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

func (*CellarIDSet) ProtoMessage 

func (*CellarIDSet) ProtoMessage()

func (*CellarIDSet) Reset 

func (m *CellarIDSet) Reset()

func (*CellarIDSet) Size 

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

func (*CellarIDSet) String 

func (m *CellarIDSet) String() string

func (*CellarIDSet) Unmarshal 

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

func (*CellarIDSet) XXX_DiscardUnknown 

func (m *CellarIDSet) XXX_DiscardUnknown()

func (*CellarIDSet) XXX_Marshal 

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

func (*CellarIDSet) XXX_Merge 

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

func (*CellarIDSet) XXX_Size 

func (m *CellarIDSet) XXX_Size() int

func (*CellarIDSet) XXX_Unmarshal 

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

type Cork 

type Cork struct {
	// call body containing the ABI encoded bytes to send to the contract
	EncodedContractCall []byte `protobuf:"bytes,1,opt,name=encoded_contract_call,json=encodedContractCall,proto3" json:"encoded_contract_call,omitempty"`
	// address of the contract to send the call
	TargetContractAddress string `` /* 126-byte string literal not displayed */
}

func (*Cork) Descriptor 

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

func (*Cork) Equals 

func (c *Cork) Equals(other Cork) bool

func (*Cork) GetEncodedContractCall 

func (m *Cork) GetEncodedContractCall() []byte

func (*Cork) GetTargetContractAddress 

func (m *Cork) GetTargetContractAddress() string

func (*Cork) InvalidationScope 

func (c *Cork) InvalidationScope() tmbytes.HexBytes

func (*Cork) Marshal 

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

func (*Cork) MarshalTo 

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

func (*Cork) MarshalToSizedBuffer 

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

func (*Cork) ProtoMessage 

func (*Cork) ProtoMessage()

func (*Cork) Reset 

func (m *Cork) Reset()

func (*Cork) Size 

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

func (*Cork) String 

func (m *Cork) String() string

func (*Cork) Unmarshal 

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

func (*Cork) ValidateBasic 

func (c *Cork) ValidateBasic() error

func (*Cork) XXX_DiscardUnknown 

func (m *Cork) XXX_DiscardUnknown()

func (*Cork) XXX_Marshal 

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

func (*Cork) XXX_Merge 

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

func (*Cork) XXX_Size 

func (m *Cork) XXX_Size() int

func (*Cork) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params            Params           `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	CellarIds         CellarIDSet      `protobuf:"bytes,2,opt,name=cellar_ids,json=cellarIds,proto3" json:"cellar_ids"`
	InvalidationNonce uint64           `protobuf:"varint,3,opt,name=invalidation_nonce,json=invalidationNonce,proto3" json:"invalidation_nonce,omitempty"`
	Corks             []*ValidatorCork `protobuf:"bytes,4,rep,name=corks,proto3" json:"corks,omitempty"`
	ScheduledCorks    []*ScheduledCork `protobuf:"bytes,5,rep,name=scheduled_corks,json=scheduledCorks,proto3" json:"scheduled_corks,omitempty"`
}

GenesisState - all cork state that must be provided at genesis

func DefaultGenesisState 

func DefaultGenesisState() GenesisState

DefaultGenesisState get raw genesis raw message for testing

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetCellarIds 

func (m *GenesisState) GetCellarIds() CellarIDSet

func (*GenesisState) GetCorks 

func (m *GenesisState) GetCorks() []*ValidatorCork

func (*GenesisState) GetInvalidationNonce 

func (m *GenesisState) GetInvalidationNonce() uint64

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetScheduledCorks 

func (m *GenesisState) GetScheduledCorks() []*ScheduledCork

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (GenesisState) Validate 

func (gs GenesisState) Validate() error

Validate performs a basic stateless validation of the genesis fields.

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type GravityKeeper 

type GravityKeeper interface {
	SetOutgoingTx(ctx sdk.Context, outgoing types.OutgoingTx)
	CreateContractCallTx(
		ctx sdk.Context,
		invalidationNonce uint64,
		invalidationScope tmbytes.HexBytes,
		address common.Address,
		payload []byte,
		tokens []types.ERC20Token,
		fees []types.ERC20Token) *types.ContractCallTx
	GetOrchestratorValidatorAddress(ctx sdk.Context, orchAddr sdk.AccAddress) sdk.ValAddress
	GetValidatorEthereumAddress(ctx sdk.Context, valAddr sdk.ValAddress) common.Address
	GetEthereumOrchestratorAddress(ctx sdk.Context, ethAddr common.Address) sdk.AccAddress
	SetOrchestratorValidatorAddress(ctx sdk.Context, val sdk.ValAddress, orchAddr sdk.AccAddress)
}

GravityKeeper defines the expected gravity keeper methods

type MsgClient 

type MsgClient interface {
	SubmitCork(ctx context.Context, in *MsgSubmitCorkRequest, opts ...grpc.CallOption) (*MsgSubmitCorkResponse, error)
	ScheduleCork(ctx context.Context, in *MsgScheduleCorkRequest, opts ...grpc.CallOption) (*MsgScheduleCorkResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgScheduleCorkRequest 

type MsgScheduleCorkRequest struct {
	// the scheduled cork
	Cork *Cork `protobuf:"bytes,1,opt,name=cork,proto3" json:"cork,omitempty"`
	// the block height that must be reached
	BlockHeight uint64 `protobuf:"varint,2,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	// signer account address
	Signer string `protobuf:"bytes,3,opt,name=signer,proto3" json:"signer,omitempty"`
}

MsgScheduleCorkRequest - sdk.Msg for scheduling a cork request for on or after a specific block height

func NewMsgScheduleCorkRequest 

func NewMsgScheduleCorkRequest(body []byte, address common.Address, blockHeight uint64, signer sdk.AccAddress) (*MsgScheduleCorkRequest, error)

NewMsgScheduleCorkRequest return a new MsgScheduleCorkRequest

func (*MsgScheduleCorkRequest) Descriptor 

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

func (*MsgScheduleCorkRequest) GetBlockHeight 

func (m *MsgScheduleCorkRequest) GetBlockHeight() uint64

func (*MsgScheduleCorkRequest) GetCork 

func (m *MsgScheduleCorkRequest) GetCork() *Cork

func (*MsgScheduleCorkRequest) GetSignBytes 

func (m *MsgScheduleCorkRequest) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (*MsgScheduleCorkRequest) GetSigner 

func (m *MsgScheduleCorkRequest) GetSigner() string

func (*MsgScheduleCorkRequest) GetSigners 

func (m *MsgScheduleCorkRequest) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgScheduleCorkRequest) Marshal 

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

func (*MsgScheduleCorkRequest) MarshalTo 

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

func (*MsgScheduleCorkRequest) MarshalToSizedBuffer 

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

func (*MsgScheduleCorkRequest) MustGetSigner 

func (m *MsgScheduleCorkRequest) MustGetSigner() sdk.AccAddress

MustGetSigner returns the signer address

func (*MsgScheduleCorkRequest) ProtoMessage 

func (*MsgScheduleCorkRequest) ProtoMessage()

func (*MsgScheduleCorkRequest) Reset 

func (m *MsgScheduleCorkRequest) Reset()

func (*MsgScheduleCorkRequest) Route 

func (m *MsgScheduleCorkRequest) Route() string

Route implements sdk.Msg

func (*MsgScheduleCorkRequest) Size 

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

func (*MsgScheduleCorkRequest) String 

func (m *MsgScheduleCorkRequest) String() string

func (*MsgScheduleCorkRequest) Type 

func (m *MsgScheduleCorkRequest) Type() string

Type implements sdk.Msg

func (*MsgScheduleCorkRequest) Unmarshal 

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

func (*MsgScheduleCorkRequest) ValidateBasic 

func (m *MsgScheduleCorkRequest) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgScheduleCorkRequest) XXX_DiscardUnknown 

func (m *MsgScheduleCorkRequest) XXX_DiscardUnknown()

func (*MsgScheduleCorkRequest) XXX_Marshal 

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

func (*MsgScheduleCorkRequest) XXX_Merge 

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

func (*MsgScheduleCorkRequest) XXX_Size 

func (m *MsgScheduleCorkRequest) XXX_Size() int

func (*MsgScheduleCorkRequest) XXX_Unmarshal 

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

type MsgScheduleCorkResponse 

type MsgScheduleCorkResponse struct {
}

func (*MsgScheduleCorkResponse) Descriptor 

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

func (*MsgScheduleCorkResponse) Marshal 

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

func (*MsgScheduleCorkResponse) MarshalTo 

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

func (*MsgScheduleCorkResponse) MarshalToSizedBuffer 

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

func (*MsgScheduleCorkResponse) ProtoMessage 

func (*MsgScheduleCorkResponse) ProtoMessage()

func (*MsgScheduleCorkResponse) Reset 

func (m *MsgScheduleCorkResponse) Reset()

func (*MsgScheduleCorkResponse) Size 

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

func (*MsgScheduleCorkResponse) String 

func (m *MsgScheduleCorkResponse) String() string

func (*MsgScheduleCorkResponse) Unmarshal 

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

func (*MsgScheduleCorkResponse) XXX_DiscardUnknown 

func (m *MsgScheduleCorkResponse) XXX_DiscardUnknown()

func (*MsgScheduleCorkResponse) XXX_Marshal 

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

func (*MsgScheduleCorkResponse) XXX_Merge 

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

func (*MsgScheduleCorkResponse) XXX_Size 

func (m *MsgScheduleCorkResponse) XXX_Size() int

func (*MsgScheduleCorkResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	SubmitCork(context.Context, *MsgSubmitCorkRequest) (*MsgSubmitCorkResponse, error)
	ScheduleCork(context.Context, *MsgScheduleCorkRequest) (*MsgScheduleCorkResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSubmitCorkRequest 

type MsgSubmitCorkRequest struct {
	// the cork to send across the bridge
	Cork *Cork `protobuf:"bytes,1,opt,name=cork,proto3" json:"cork,omitempty"`
	// signer account address
	Signer string `protobuf:"bytes,2,opt,name=signer,proto3" json:"signer,omitempty"`
}

MsgSubmitCorkRequest - sdk.Msg for submitting calls to Ethereum through the gravity bridge contract

func NewMsgSubmitCorkRequest 

func NewMsgSubmitCorkRequest(body []byte, address common.Address, signer sdk.AccAddress) (*MsgSubmitCorkRequest, error)

NewMsgSubmitCorkRequest return a new MsgSubmitCorkRequest

func (*MsgSubmitCorkRequest) Descriptor 

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

func (*MsgSubmitCorkRequest) GetCork 

func (m *MsgSubmitCorkRequest) GetCork() *Cork

func (*MsgSubmitCorkRequest) GetSignBytes 

func (m *MsgSubmitCorkRequest) GetSignBytes() []byte

GetSignBytes implements sdk.Msg

func (*MsgSubmitCorkRequest) GetSigner 

func (m *MsgSubmitCorkRequest) GetSigner() string

func (*MsgSubmitCorkRequest) GetSigners 

func (m *MsgSubmitCorkRequest) GetSigners() []sdk.AccAddress

GetSigners implements sdk.Msg

func (*MsgSubmitCorkRequest) Marshal 

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

func (*MsgSubmitCorkRequest) MarshalTo 

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

func (*MsgSubmitCorkRequest) MarshalToSizedBuffer 

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

func (*MsgSubmitCorkRequest) MustGetSigner 

func (m *MsgSubmitCorkRequest) MustGetSigner() sdk.AccAddress

MustGetSigner returns the signer address

func (*MsgSubmitCorkRequest) ProtoMessage 

func (*MsgSubmitCorkRequest) ProtoMessage()

func (*MsgSubmitCorkRequest) Reset 

func (m *MsgSubmitCorkRequest) Reset()

func (*MsgSubmitCorkRequest) Route 

func (m *MsgSubmitCorkRequest) Route() string

Route implements sdk.Msg

func (*MsgSubmitCorkRequest) Size 

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

func (*MsgSubmitCorkRequest) String 

func (m *MsgSubmitCorkRequest) String() string

func (*MsgSubmitCorkRequest) Type 

func (m *MsgSubmitCorkRequest) Type() string

Type implements sdk.Msg

func (*MsgSubmitCorkRequest) Unmarshal 

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

func (*MsgSubmitCorkRequest) ValidateBasic 

func (m *MsgSubmitCorkRequest) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgSubmitCorkRequest) XXX_DiscardUnknown 

func (m *MsgSubmitCorkRequest) XXX_DiscardUnknown()

func (*MsgSubmitCorkRequest) XXX_Marshal 

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

func (*MsgSubmitCorkRequest) XXX_Merge 

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

func (*MsgSubmitCorkRequest) XXX_Size 

func (m *MsgSubmitCorkRequest) XXX_Size() int

func (*MsgSubmitCorkRequest) XXX_Unmarshal 

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

type MsgSubmitCorkResponse 

type MsgSubmitCorkResponse struct {
}

func (*MsgSubmitCorkResponse) Descriptor 

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

func (*MsgSubmitCorkResponse) Marshal 

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

func (*MsgSubmitCorkResponse) MarshalTo 

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

func (*MsgSubmitCorkResponse) MarshalToSizedBuffer 

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

func (*MsgSubmitCorkResponse) ProtoMessage 

func (*MsgSubmitCorkResponse) ProtoMessage()

func (*MsgSubmitCorkResponse) Reset 

func (m *MsgSubmitCorkResponse) Reset()

func (*MsgSubmitCorkResponse) Size 

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

func (*MsgSubmitCorkResponse) String 

func (m *MsgSubmitCorkResponse) String() string

func (*MsgSubmitCorkResponse) Unmarshal 

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

func (*MsgSubmitCorkResponse) XXX_DiscardUnknown 

func (m *MsgSubmitCorkResponse) XXX_DiscardUnknown()

func (*MsgSubmitCorkResponse) XXX_Marshal 

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

func (*MsgSubmitCorkResponse) XXX_Merge 

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

func (*MsgSubmitCorkResponse) XXX_Size 

func (m *MsgSubmitCorkResponse) XXX_Size() int

func (*MsgSubmitCorkResponse) XXX_Unmarshal 

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

type Params 

type Params struct {
	// VotePeriod defines the number of blocks to wait for votes before attempting to tally
	VotePeriod int64 `protobuf:"varint,1,opt,name=vote_period,json=votePeriod,proto3" json:"vote_period,omitempty" yaml:"vote_period"`
	// VoteThreshold defines the percentage of bonded stake required to vote each period
	VoteThreshold github_com_cosmos_cosmos_sdk_types.Dec `` /* 162-byte string literal not displayed */
}

Params cork parameters

func DefaultParams 

func DefaultParams() Params

DefaultParams returns default oracle parameters

func (*Params) Descriptor 

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

func (*Params) GetVotePeriod 

func (m *Params) GetVotePeriod() int64

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ParamSetPairs 

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

ParamSetPairs returns the parameter set pairs.

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (*Params) ValidateBasic 

func (p *Params) ValidateBasic() error

ValidateBasic performs basic validation on oracle parameters.

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryCellarIDsRequest 

type QueryCellarIDsRequest struct {
}

QueryCellarIDsRequest is the request type for Query/QueryCellarIDs gRPC method.

func (*QueryCellarIDsRequest) Descriptor 

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

func (*QueryCellarIDsRequest) Marshal 

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

func (*QueryCellarIDsRequest) MarshalTo 

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

func (*QueryCellarIDsRequest) MarshalToSizedBuffer 

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

func (*QueryCellarIDsRequest) ProtoMessage 

func (*QueryCellarIDsRequest) ProtoMessage()

func (*QueryCellarIDsRequest) Reset 

func (m *QueryCellarIDsRequest) Reset()

func (*QueryCellarIDsRequest) Size 

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

func (*QueryCellarIDsRequest) String 

func (m *QueryCellarIDsRequest) String() string

func (*QueryCellarIDsRequest) Unmarshal 

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

func (*QueryCellarIDsRequest) XXX_DiscardUnknown 

func (m *QueryCellarIDsRequest) XXX_DiscardUnknown()

func (*QueryCellarIDsRequest) XXX_Marshal 

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

func (*QueryCellarIDsRequest) XXX_Merge 

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

func (*QueryCellarIDsRequest) XXX_Size 

func (m *QueryCellarIDsRequest) XXX_Size() int

func (*QueryCellarIDsRequest) XXX_Unmarshal 

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

type QueryCellarIDsResponse 

type QueryCellarIDsResponse struct {
	CellarIds []string `protobuf:"bytes,1,rep,name=cellar_ids,json=cellarIds,proto3" json:"cellar_ids,omitempty"`
}

QueryCellarIDsResponse is the response type for Query/QueryCellars gRPC method.

func (*QueryCellarIDsResponse) Descriptor 

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

func (*QueryCellarIDsResponse) GetCellarIds 

func (m *QueryCellarIDsResponse) GetCellarIds() []string

func (*QueryCellarIDsResponse) Marshal 

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

func (*QueryCellarIDsResponse) MarshalTo 

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

func (*QueryCellarIDsResponse) MarshalToSizedBuffer 

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

func (*QueryCellarIDsResponse) ProtoMessage 

func (*QueryCellarIDsResponse) ProtoMessage()

func (*QueryCellarIDsResponse) Reset 

func (m *QueryCellarIDsResponse) Reset()

func (*QueryCellarIDsResponse) Size 

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

func (*QueryCellarIDsResponse) String 

func (m *QueryCellarIDsResponse) String() string

func (*QueryCellarIDsResponse) Unmarshal 

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

func (*QueryCellarIDsResponse) XXX_DiscardUnknown 

func (m *QueryCellarIDsResponse) XXX_DiscardUnknown()

func (*QueryCellarIDsResponse) XXX_Marshal 

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

func (*QueryCellarIDsResponse) XXX_Merge 

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

func (*QueryCellarIDsResponse) XXX_Size 

func (m *QueryCellarIDsResponse) XXX_Size() int

func (*QueryCellarIDsResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// QueryParams queries the allocation module parameters.
	QueryParams(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// QuerySubmittedCorks queries the submitted corks awaiting vote
	QuerySubmittedCorks(ctx context.Context, in *QuerySubmittedCorksRequest, opts ...grpc.CallOption) (*QuerySubmittedCorksResponse, error)
	// QueryVotePeriod queries the heights for the current voting period (current, start and end)
	QueryCommitPeriod(ctx context.Context, in *QueryCommitPeriodRequest, opts ...grpc.CallOption) (*QueryCommitPeriodResponse, error)
	// QueryCellarIDs returns all cellars and current tick ranges
	QueryCellarIDs(ctx context.Context, in *QueryCellarIDsRequest, opts ...grpc.CallOption) (*QueryCellarIDsResponse, error)
	// QueryScheduledCorks returns all scheduled corks
	QueryScheduledCorks(ctx context.Context, in *QueryScheduledCorksRequest, opts ...grpc.CallOption) (*QueryScheduledCorksResponse, error)
	// QueryScheduledBlockHeights returns all scheduled block heights
	QueryScheduledBlockHeights(ctx context.Context, in *QueryScheduledBlockHeightsRequest, opts ...grpc.CallOption) (*QueryScheduledBlockHeightsResponse, error)
	// QueryScheduledCorks returns all scheduled corks at a block height
	QueryScheduledCorksByBlockHeight(ctx context.Context, in *QueryScheduledCorksByBlockHeightRequest, opts ...grpc.CallOption) (*QueryScheduledCorksByBlockHeightResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryCommitPeriodRequest 

type QueryCommitPeriodRequest struct {
}

QueryCommitPeriodRequest is the request type for the Query/QueryCommitPeriod gRPC method.

func (*QueryCommitPeriodRequest) Descriptor 

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

func (*QueryCommitPeriodRequest) Marshal 

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

func (*QueryCommitPeriodRequest) MarshalTo 

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

func (*QueryCommitPeriodRequest) MarshalToSizedBuffer 

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

func (*QueryCommitPeriodRequest) ProtoMessage 

func (*QueryCommitPeriodRequest) ProtoMessage()

func (*QueryCommitPeriodRequest) Reset 

func (m *QueryCommitPeriodRequest) Reset()

func (*QueryCommitPeriodRequest) Size 

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

func (*QueryCommitPeriodRequest) String 

func (m *QueryCommitPeriodRequest) String() string

func (*QueryCommitPeriodRequest) Unmarshal 

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

func (*QueryCommitPeriodRequest) XXX_DiscardUnknown 

func (m *QueryCommitPeriodRequest) XXX_DiscardUnknown()

func (*QueryCommitPeriodRequest) XXX_Marshal 

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

func (*QueryCommitPeriodRequest) XXX_Merge 

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

func (*QueryCommitPeriodRequest) XXX_Size 

func (m *QueryCommitPeriodRequest) XXX_Size() int

func (*QueryCommitPeriodRequest) XXX_Unmarshal 

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

type QueryCommitPeriodResponse 

type QueryCommitPeriodResponse struct {
	// block height at which the query was processed
	CurrentHeight int64 `protobuf:"varint,1,opt,name=current_height,json=currentHeight,proto3" json:"current_height,omitempty"`
	// latest vote period start block height
	VotePeriodStart int64 `protobuf:"varint,2,opt,name=vote_period_start,json=votePeriodStart,proto3" json:"vote_period_start,omitempty"`
	// block height at which the current voting period ends
	VotePeriodEnd int64 `protobuf:"varint,3,opt,name=vote_period_end,json=votePeriodEnd,proto3" json:"vote_period_end,omitempty"`
}

QueryCommitPeriodResponse is the response type for the Query/QueryCommitPeriod gRPC method.

func (*QueryCommitPeriodResponse) Descriptor 

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

func (*QueryCommitPeriodResponse) GetCurrentHeight 

func (m *QueryCommitPeriodResponse) GetCurrentHeight() int64

func (*QueryCommitPeriodResponse) GetVotePeriodEnd 

func (m *QueryCommitPeriodResponse) GetVotePeriodEnd() int64

func (*QueryCommitPeriodResponse) GetVotePeriodStart 

func (m *QueryCommitPeriodResponse) GetVotePeriodStart() int64

func (*QueryCommitPeriodResponse) Marshal 

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

func (*QueryCommitPeriodResponse) MarshalTo 

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

func (*QueryCommitPeriodResponse) MarshalToSizedBuffer 

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

func (*QueryCommitPeriodResponse) ProtoMessage 

func (*QueryCommitPeriodResponse) ProtoMessage()

func (*QueryCommitPeriodResponse) Reset 

func (m *QueryCommitPeriodResponse) Reset()

func (*QueryCommitPeriodResponse) Size 

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

func (*QueryCommitPeriodResponse) String 

func (m *QueryCommitPeriodResponse) String() string

func (*QueryCommitPeriodResponse) Unmarshal 

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

func (*QueryCommitPeriodResponse) XXX_DiscardUnknown 

func (m *QueryCommitPeriodResponse) XXX_DiscardUnknown()

func (*QueryCommitPeriodResponse) XXX_Marshal 

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

func (*QueryCommitPeriodResponse) XXX_Merge 

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

func (*QueryCommitPeriodResponse) XXX_Size 

func (m *QueryCommitPeriodResponse) XXX_Size() int

func (*QueryCommitPeriodResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// allocation parameters
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsRequest is the response type for the Query/Params gRPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryScheduledBlockHeightsRequest 

type QueryScheduledBlockHeightsRequest struct {
}

QueryScheduledBlockHeightsRequest

func (*QueryScheduledBlockHeightsRequest) Descriptor 

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

func (*QueryScheduledBlockHeightsRequest) Marshal 

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

func (*QueryScheduledBlockHeightsRequest) MarshalTo 

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

func (*QueryScheduledBlockHeightsRequest) MarshalToSizedBuffer 

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

func (*QueryScheduledBlockHeightsRequest) ProtoMessage 

func (*QueryScheduledBlockHeightsRequest) ProtoMessage()

func (*QueryScheduledBlockHeightsRequest) Reset 

func (m *QueryScheduledBlockHeightsRequest) Reset()

func (*QueryScheduledBlockHeightsRequest) Size 

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

func (*QueryScheduledBlockHeightsRequest) String 

func (m *QueryScheduledBlockHeightsRequest) String() string

func (*QueryScheduledBlockHeightsRequest) Unmarshal 

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

func (*QueryScheduledBlockHeightsRequest) XXX_DiscardUnknown 

func (m *QueryScheduledBlockHeightsRequest) XXX_DiscardUnknown()

func (*QueryScheduledBlockHeightsRequest) XXX_Marshal 

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

func (*QueryScheduledBlockHeightsRequest) XXX_Merge 

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

func (*QueryScheduledBlockHeightsRequest) XXX_Size 

func (m *QueryScheduledBlockHeightsRequest) XXX_Size() int

func (*QueryScheduledBlockHeightsRequest) XXX_Unmarshal 

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

type QueryScheduledBlockHeightsResponse 

type QueryScheduledBlockHeightsResponse struct {
	BlockHeights []uint64 `protobuf:"varint,1,rep,packed,name=block_heights,json=blockHeights,proto3" json:"block_heights,omitempty"`
}

QueryScheduledBlockHeightsResponse

func (*QueryScheduledBlockHeightsResponse) Descriptor 

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

func (*QueryScheduledBlockHeightsResponse) GetBlockHeights 

func (m *QueryScheduledBlockHeightsResponse) GetBlockHeights() []uint64

func (*QueryScheduledBlockHeightsResponse) Marshal 

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

func (*QueryScheduledBlockHeightsResponse) MarshalTo 

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

func (*QueryScheduledBlockHeightsResponse) MarshalToSizedBuffer 

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

func (*QueryScheduledBlockHeightsResponse) ProtoMessage 

func (*QueryScheduledBlockHeightsResponse) ProtoMessage()

func (*QueryScheduledBlockHeightsResponse) Reset 

func (m *QueryScheduledBlockHeightsResponse) Reset()

func (*QueryScheduledBlockHeightsResponse) Size 

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

func (*QueryScheduledBlockHeightsResponse) String 

func (m *QueryScheduledBlockHeightsResponse) String() string

func (*QueryScheduledBlockHeightsResponse) Unmarshal 

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

func (*QueryScheduledBlockHeightsResponse) XXX_DiscardUnknown 

func (m *QueryScheduledBlockHeightsResponse) XXX_DiscardUnknown()

func (*QueryScheduledBlockHeightsResponse) XXX_Marshal 

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

func (*QueryScheduledBlockHeightsResponse) XXX_Merge 

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

func (*QueryScheduledBlockHeightsResponse) XXX_Size 

func (m *QueryScheduledBlockHeightsResponse) XXX_Size() int

func (*QueryScheduledBlockHeightsResponse) XXX_Unmarshal 

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

type QueryScheduledCorksByBlockHeightRequest 

type QueryScheduledCorksByBlockHeightRequest struct {
	BlockHeight uint64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
}

QueryScheduledCorksByBlockHeightRequest

func (*QueryScheduledCorksByBlockHeightRequest) Descriptor 

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

func (*QueryScheduledCorksByBlockHeightRequest) GetBlockHeight 

func (m *QueryScheduledCorksByBlockHeightRequest) GetBlockHeight() uint64

func (*QueryScheduledCorksByBlockHeightRequest) Marshal 

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

func (*QueryScheduledCorksByBlockHeightRequest) MarshalTo 

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

func (*QueryScheduledCorksByBlockHeightRequest) MarshalToSizedBuffer 

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

func (*QueryScheduledCorksByBlockHeightRequest) ProtoMessage 

func (*QueryScheduledCorksByBlockHeightRequest) ProtoMessage()

func (*QueryScheduledCorksByBlockHeightRequest) Reset 

func (m *QueryScheduledCorksByBlockHeightRequest) Reset()

func (*QueryScheduledCorksByBlockHeightRequest) Size 

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

func (*QueryScheduledCorksByBlockHeightRequest) String 

func (m *QueryScheduledCorksByBlockHeightRequest) String() string

func (*QueryScheduledCorksByBlockHeightRequest) Unmarshal 

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

func (*QueryScheduledCorksByBlockHeightRequest) XXX_DiscardUnknown 

func (m *QueryScheduledCorksByBlockHeightRequest) XXX_DiscardUnknown()

func (*QueryScheduledCorksByBlockHeightRequest) XXX_Marshal 

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

func (*QueryScheduledCorksByBlockHeightRequest) XXX_Merge 

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

func (*QueryScheduledCorksByBlockHeightRequest) XXX_Size 

func (m *QueryScheduledCorksByBlockHeightRequest) XXX_Size() int

func (*QueryScheduledCorksByBlockHeightRequest) XXX_Unmarshal 

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

type QueryScheduledCorksByBlockHeightResponse 

type QueryScheduledCorksByBlockHeightResponse struct {
	Corks []*ScheduledCork `protobuf:"bytes,1,rep,name=corks,proto3" json:"corks,omitempty"`
}

QueryScheduledCorksByBlockHeightResponse

func (*QueryScheduledCorksByBlockHeightResponse) Descriptor 

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

func (*QueryScheduledCorksByBlockHeightResponse) GetCorks 

func (m *QueryScheduledCorksByBlockHeightResponse) GetCorks() []*ScheduledCork

func (*QueryScheduledCorksByBlockHeightResponse) Marshal 

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

func (*QueryScheduledCorksByBlockHeightResponse) MarshalTo 

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

func (*QueryScheduledCorksByBlockHeightResponse) MarshalToSizedBuffer 

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

func (*QueryScheduledCorksByBlockHeightResponse) ProtoMessage 

func (*QueryScheduledCorksByBlockHeightResponse) ProtoMessage()

func (*QueryScheduledCorksByBlockHeightResponse) Reset 

func (m *QueryScheduledCorksByBlockHeightResponse) Reset()

func (*QueryScheduledCorksByBlockHeightResponse) Size 

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

func (*QueryScheduledCorksByBlockHeightResponse) String 

func (m *QueryScheduledCorksByBlockHeightResponse) String() string

func (*QueryScheduledCorksByBlockHeightResponse) Unmarshal 

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

func (*QueryScheduledCorksByBlockHeightResponse) XXX_DiscardUnknown 

func (m *QueryScheduledCorksByBlockHeightResponse) XXX_DiscardUnknown()

func (*QueryScheduledCorksByBlockHeightResponse) XXX_Marshal 

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

func (*QueryScheduledCorksByBlockHeightResponse) XXX_Merge 

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

func (*QueryScheduledCorksByBlockHeightResponse) XXX_Size 

func (m *QueryScheduledCorksByBlockHeightResponse) XXX_Size() int

func (*QueryScheduledCorksByBlockHeightResponse) XXX_Unmarshal 

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

type QueryScheduledCorksRequest 

type QueryScheduledCorksRequest struct {
}

QueryScheduledCorksRequest

func (*QueryScheduledCorksRequest) Descriptor 

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

func (*QueryScheduledCorksRequest) Marshal 

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

func (*QueryScheduledCorksRequest) MarshalTo 

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

func (*QueryScheduledCorksRequest) MarshalToSizedBuffer 

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

func (*QueryScheduledCorksRequest) ProtoMessage 

func (*QueryScheduledCorksRequest) ProtoMessage()

func (*QueryScheduledCorksRequest) Reset 

func (m *QueryScheduledCorksRequest) Reset()

func (*QueryScheduledCorksRequest) Size 

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

func (*QueryScheduledCorksRequest) String 

func (m *QueryScheduledCorksRequest) String() string

func (*QueryScheduledCorksRequest) Unmarshal 

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

func (*QueryScheduledCorksRequest) XXX_DiscardUnknown 

func (m *QueryScheduledCorksRequest) XXX_DiscardUnknown()

func (*QueryScheduledCorksRequest) XXX_Marshal 

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

func (*QueryScheduledCorksRequest) XXX_Merge 

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

func (*QueryScheduledCorksRequest) XXX_Size 

func (m *QueryScheduledCorksRequest) XXX_Size() int

func (*QueryScheduledCorksRequest) XXX_Unmarshal 

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

type QueryScheduledCorksResponse 

type QueryScheduledCorksResponse struct {
	Corks []*ScheduledCork `protobuf:"bytes,1,rep,name=corks,proto3" json:"corks,omitempty"`
}

QueryScheduledCorksResponse

func (*QueryScheduledCorksResponse) Descriptor 

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

func (*QueryScheduledCorksResponse) GetCorks 

func (m *QueryScheduledCorksResponse) GetCorks() []*ScheduledCork

func (*QueryScheduledCorksResponse) Marshal 

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

func (*QueryScheduledCorksResponse) MarshalTo 

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

func (*QueryScheduledCorksResponse) MarshalToSizedBuffer 

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

func (*QueryScheduledCorksResponse) ProtoMessage 

func (*QueryScheduledCorksResponse) ProtoMessage()

func (*QueryScheduledCorksResponse) Reset 

func (m *QueryScheduledCorksResponse) Reset()

func (*QueryScheduledCorksResponse) Size 

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

func (*QueryScheduledCorksResponse) String 

func (m *QueryScheduledCorksResponse) String() string

func (*QueryScheduledCorksResponse) Unmarshal 

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

func (*QueryScheduledCorksResponse) XXX_DiscardUnknown 

func (m *QueryScheduledCorksResponse) XXX_DiscardUnknown()

func (*QueryScheduledCorksResponse) XXX_Marshal 

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

func (*QueryScheduledCorksResponse) XXX_Merge 

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

func (*QueryScheduledCorksResponse) XXX_Size 

func (m *QueryScheduledCorksResponse) XXX_Size() int

func (*QueryScheduledCorksResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// QueryParams queries the allocation module parameters.
	QueryParams(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// QuerySubmittedCorks queries the submitted corks awaiting vote
	QuerySubmittedCorks(context.Context, *QuerySubmittedCorksRequest) (*QuerySubmittedCorksResponse, error)
	// QueryVotePeriod queries the heights for the current voting period (current, start and end)
	QueryCommitPeriod(context.Context, *QueryCommitPeriodRequest) (*QueryCommitPeriodResponse, error)
	// QueryCellarIDs returns all cellars and current tick ranges
	QueryCellarIDs(context.Context, *QueryCellarIDsRequest) (*QueryCellarIDsResponse, error)
	// QueryScheduledCorks returns all scheduled corks
	QueryScheduledCorks(context.Context, *QueryScheduledCorksRequest) (*QueryScheduledCorksResponse, error)
	// QueryScheduledBlockHeights returns all scheduled block heights
	QueryScheduledBlockHeights(context.Context, *QueryScheduledBlockHeightsRequest) (*QueryScheduledBlockHeightsResponse, error)
	// QueryScheduledCorks returns all scheduled corks at a block height
	QueryScheduledCorksByBlockHeight(context.Context, *QueryScheduledCorksByBlockHeightRequest) (*QueryScheduledCorksByBlockHeightResponse, error)
}

QueryServer is the server API for Query service.

type QuerySubmittedCorksRequest 

type QuerySubmittedCorksRequest struct {
}

QuerySubmittedCorksRequest is the request type for the Query/QuerySubmittedCorks gRPC query method.

func (*QuerySubmittedCorksRequest) Descriptor 

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

func (*QuerySubmittedCorksRequest) Marshal 

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

func (*QuerySubmittedCorksRequest) MarshalTo 

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

func (*QuerySubmittedCorksRequest) MarshalToSizedBuffer 

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

func (*QuerySubmittedCorksRequest) ProtoMessage 

func (*QuerySubmittedCorksRequest) ProtoMessage()

func (*QuerySubmittedCorksRequest) Reset 

func (m *QuerySubmittedCorksRequest) Reset()

func (*QuerySubmittedCorksRequest) Size 

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

func (*QuerySubmittedCorksRequest) String 

func (m *QuerySubmittedCorksRequest) String() string

func (*QuerySubmittedCorksRequest) Unmarshal 

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

func (*QuerySubmittedCorksRequest) XXX_DiscardUnknown 

func (m *QuerySubmittedCorksRequest) XXX_DiscardUnknown()

func (*QuerySubmittedCorksRequest) XXX_Marshal 

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

func (*QuerySubmittedCorksRequest) XXX_Merge 

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

func (*QuerySubmittedCorksRequest) XXX_Size 

func (m *QuerySubmittedCorksRequest) XXX_Size() int

func (*QuerySubmittedCorksRequest) XXX_Unmarshal 

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

type QuerySubmittedCorksResponse 

type QuerySubmittedCorksResponse struct {
	// corks in keeper awaiting vote
	Corks []*Cork `protobuf:"bytes,1,rep,name=corks,proto3" json:"corks,omitempty"`
}

QuerySubmittedCorksResponse is the response type for the Query/QuerySubmittedCorks gRPC query method.

func (*QuerySubmittedCorksResponse) Descriptor 

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

func (*QuerySubmittedCorksResponse) GetCorks 

func (m *QuerySubmittedCorksResponse) GetCorks() []*Cork

func (*QuerySubmittedCorksResponse) Marshal 

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

func (*QuerySubmittedCorksResponse) MarshalTo 

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

func (*QuerySubmittedCorksResponse) MarshalToSizedBuffer 

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

func (*QuerySubmittedCorksResponse) ProtoMessage 

func (*QuerySubmittedCorksResponse) ProtoMessage()

func (*QuerySubmittedCorksResponse) Reset 

func (m *QuerySubmittedCorksResponse) Reset()

func (*QuerySubmittedCorksResponse) Size 

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

func (*QuerySubmittedCorksResponse) String 

func (m *QuerySubmittedCorksResponse) String() string

func (*QuerySubmittedCorksResponse) Unmarshal 

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

func (*QuerySubmittedCorksResponse) XXX_DiscardUnknown 

func (m *QuerySubmittedCorksResponse) XXX_DiscardUnknown()

func (*QuerySubmittedCorksResponse) XXX_Marshal 

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

func (*QuerySubmittedCorksResponse) XXX_Merge 

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

func (*QuerySubmittedCorksResponse) XXX_Size 

func (m *QuerySubmittedCorksResponse) XXX_Size() int

func (*QuerySubmittedCorksResponse) XXX_Unmarshal 

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

type RemoveManagedCellarIDsProposal 

type RemoveManagedCellarIDsProposal struct {
	Title       string       `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string       `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	CellarIds   *CellarIDSet `protobuf:"bytes,3,opt,name=cellar_ids,json=cellarIds,proto3" json:"cellar_ids,omitempty"`
}

func NewRemoveManagedCellarIDsProposal 

func NewRemoveManagedCellarIDsProposal(title string, description string, cellarIds *CellarIDSet) *RemoveManagedCellarIDsProposal

func (*RemoveManagedCellarIDsProposal) Descriptor 

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

func (*RemoveManagedCellarIDsProposal) GetCellarIds 

func (m *RemoveManagedCellarIDsProposal) GetCellarIds() *CellarIDSet

func (*RemoveManagedCellarIDsProposal) GetDescription 

func (m *RemoveManagedCellarIDsProposal) GetDescription() string

func (*RemoveManagedCellarIDsProposal) GetTitle 

func (m *RemoveManagedCellarIDsProposal) GetTitle() string

func (*RemoveManagedCellarIDsProposal) Marshal 

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

func (*RemoveManagedCellarIDsProposal) MarshalTo 

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

func (*RemoveManagedCellarIDsProposal) MarshalToSizedBuffer 

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

func (*RemoveManagedCellarIDsProposal) ProposalRoute 

func (m *RemoveManagedCellarIDsProposal) ProposalRoute() string

func (*RemoveManagedCellarIDsProposal) ProposalType 

func (m *RemoveManagedCellarIDsProposal) ProposalType() string

func (*RemoveManagedCellarIDsProposal) ProtoMessage 

func (*RemoveManagedCellarIDsProposal) ProtoMessage()

func (*RemoveManagedCellarIDsProposal) Reset 

func (m *RemoveManagedCellarIDsProposal) Reset()

func (*RemoveManagedCellarIDsProposal) Size 

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

func (*RemoveManagedCellarIDsProposal) String 

func (m *RemoveManagedCellarIDsProposal) String() string

func (*RemoveManagedCellarIDsProposal) Unmarshal 

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

func (*RemoveManagedCellarIDsProposal) ValidateBasic 

func (m *RemoveManagedCellarIDsProposal) ValidateBasic() error

func (*RemoveManagedCellarIDsProposal) XXX_DiscardUnknown 

func (m *RemoveManagedCellarIDsProposal) XXX_DiscardUnknown()

func (*RemoveManagedCellarIDsProposal) XXX_Marshal 

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

func (*RemoveManagedCellarIDsProposal) XXX_Merge 

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

func (*RemoveManagedCellarIDsProposal) XXX_Size 

func (m *RemoveManagedCellarIDsProposal) XXX_Size() int

func (*RemoveManagedCellarIDsProposal) XXX_Unmarshal 

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

type RemoveManagedCellarIDsProposalWithDeposit 

type RemoveManagedCellarIDsProposalWithDeposit struct {
	Title       string   `protobuf:"bytes,1,opt,name=title,proto3" json:"title,omitempty"`
	Description string   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	CellarIds   []string `protobuf:"bytes,3,rep,name=cellar_ids,json=cellarIds,proto3" json:"cellar_ids,omitempty"`
	Deposit     string   `protobuf:"bytes,4,opt,name=deposit,proto3" json:"deposit,omitempty"`
}

RemoveManagedCellarIDsProposalWithDeposit is a specific definition for CLI commands

func (*RemoveManagedCellarIDsProposalWithDeposit) Descriptor 

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

func (*RemoveManagedCellarIDsProposalWithDeposit) GetCellarIds 

func (m *RemoveManagedCellarIDsProposalWithDeposit) GetCellarIds() []string

func (*RemoveManagedCellarIDsProposalWithDeposit) GetDeposit 

func (m *RemoveManagedCellarIDsProposalWithDeposit) GetDeposit() string

func (*RemoveManagedCellarIDsProposalWithDeposit) GetDescription 

func (m *RemoveManagedCellarIDsProposalWithDeposit) GetDescription() string

func (*RemoveManagedCellarIDsProposalWithDeposit) GetTitle 

func (m *RemoveManagedCellarIDsProposalWithDeposit) GetTitle() string

func (*RemoveManagedCellarIDsProposalWithDeposit) Marshal 

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

func (*RemoveManagedCellarIDsProposalWithDeposit) MarshalTo 

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

func (*RemoveManagedCellarIDsProposalWithDeposit) MarshalToSizedBuffer 

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

func (*RemoveManagedCellarIDsProposalWithDeposit) ProtoMessage 

func (*RemoveManagedCellarIDsProposalWithDeposit) ProtoMessage()

func (*RemoveManagedCellarIDsProposalWithDeposit) Reset 

func (m *RemoveManagedCellarIDsProposalWithDeposit) Reset()

func (*RemoveManagedCellarIDsProposalWithDeposit) Size 

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

func (*RemoveManagedCellarIDsProposalWithDeposit) String 

func (m *RemoveManagedCellarIDsProposalWithDeposit) String() string

func (*RemoveManagedCellarIDsProposalWithDeposit) Unmarshal 

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

func (*RemoveManagedCellarIDsProposalWithDeposit) XXX_DiscardUnknown 

func (m *RemoveManagedCellarIDsProposalWithDeposit) XXX_DiscardUnknown()

func (*RemoveManagedCellarIDsProposalWithDeposit) XXX_Marshal 

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

func (*RemoveManagedCellarIDsProposalWithDeposit) XXX_Merge 

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

func (*RemoveManagedCellarIDsProposalWithDeposit) XXX_Size 

func (m *RemoveManagedCellarIDsProposalWithDeposit) XXX_Size() int

func (*RemoveManagedCellarIDsProposalWithDeposit) XXX_Unmarshal 

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

type ScheduledCork 

type ScheduledCork struct {
	Cork        *Cork  `protobuf:"bytes,1,opt,name=cork,proto3" json:"cork,omitempty"`
	BlockHeight uint64 `protobuf:"varint,2,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	Validator   string `protobuf:"bytes,3,opt,name=validator,proto3" json:"validator,omitempty"`
}

func (*ScheduledCork) Descriptor 

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

func (*ScheduledCork) GetBlockHeight 

func (m *ScheduledCork) GetBlockHeight() uint64

func (*ScheduledCork) GetCork 

func (m *ScheduledCork) GetCork() *Cork

func (*ScheduledCork) GetValidator 

func (m *ScheduledCork) GetValidator() string

func (*ScheduledCork) Marshal 

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

func (*ScheduledCork) MarshalTo 

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

func (*ScheduledCork) MarshalToSizedBuffer 

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

func (*ScheduledCork) ProtoMessage 

func (*ScheduledCork) ProtoMessage()

func (*ScheduledCork) Reset 

func (m *ScheduledCork) Reset()

func (*ScheduledCork) Size 

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

func (*ScheduledCork) String 

func (m *ScheduledCork) String() string

func (*ScheduledCork) Unmarshal 

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

func (*ScheduledCork) XXX_DiscardUnknown 

func (m *ScheduledCork) XXX_DiscardUnknown()

func (*ScheduledCork) XXX_Marshal 

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

func (*ScheduledCork) XXX_Merge 

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

func (*ScheduledCork) XXX_Size 

func (m *ScheduledCork) XXX_Size() int

func (*ScheduledCork) XXX_Unmarshal 

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

type StakingKeeper 

type StakingKeeper interface {
	GetBondedValidatorsByPower(ctx sdk.Context) []stakingtypes.Validator
	GetLastValidatorPower(ctx sdk.Context, operator sdk.ValAddress) int64
	GetLastTotalPower(ctx sdk.Context) (power sdk.Int)
	IterateValidators(sdk.Context, func(index int64, validator stakingtypes.ValidatorI) (stop bool))
	IterateBondedValidatorsByPower(sdk.Context, func(index int64, validator stakingtypes.ValidatorI) (stop bool))
	IterateLastValidators(sdk.Context, func(index int64, validator stakingtypes.ValidatorI) (stop bool))
	Validator(sdk.Context, sdk.ValAddress) stakingtypes.ValidatorI
	ValidatorByConsAddr(sdk.Context, sdk.ConsAddress) stakingtypes.ValidatorI
	Slash(sdk.Context, sdk.ConsAddress, int64, int64, sdk.Dec)
	Jail(sdk.Context, sdk.ConsAddress)
	PowerReduction(ctx sdk.Context) sdk.Int
}

StakingKeeper defines the expected staking keeper methods

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) ScheduleCork 

func (*UnimplementedMsgServer) ScheduleCork(ctx context.Context, req *MsgScheduleCorkRequest) (*MsgScheduleCorkResponse, error)

func (*UnimplementedMsgServer) SubmitCork 

func (*UnimplementedMsgServer) SubmitCork(ctx context.Context, req *MsgSubmitCorkRequest) (*MsgSubmitCorkResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) QueryCellarIDs 

func (*UnimplementedQueryServer) QueryCellarIDs(ctx context.Context, req *QueryCellarIDsRequest) (*QueryCellarIDsResponse, error)

func (*UnimplementedQueryServer) QueryCommitPeriod 

func (*UnimplementedQueryServer) QueryCommitPeriod(ctx context.Context, req *QueryCommitPeriodRequest) (*QueryCommitPeriodResponse, error)

func (*UnimplementedQueryServer) QueryParams 

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

func (*UnimplementedQueryServer) QueryScheduledBlockHeights 

func (*UnimplementedQueryServer) QueryScheduledBlockHeights(ctx context.Context, req *QueryScheduledBlockHeightsRequest) (*QueryScheduledBlockHeightsResponse, error)

func (*UnimplementedQueryServer) QueryScheduledCorks 

func (*UnimplementedQueryServer) QueryScheduledCorks(ctx context.Context, req *QueryScheduledCorksRequest) (*QueryScheduledCorksResponse, error)

func (*UnimplementedQueryServer) QueryScheduledCorksByBlockHeight 

func (*UnimplementedQueryServer) QueryScheduledCorksByBlockHeight(ctx context.Context, req *QueryScheduledCorksByBlockHeightRequest) (*QueryScheduledCorksByBlockHeightResponse, error)

func (*UnimplementedQueryServer) QuerySubmittedCorks 

func (*UnimplementedQueryServer) QuerySubmittedCorks(ctx context.Context, req *QuerySubmittedCorksRequest) (*QuerySubmittedCorksResponse, error)

type ValidatorCork 

type ValidatorCork struct {
	Cork      *Cork  `protobuf:"bytes,1,opt,name=cork,proto3" json:"cork,omitempty"`
	Validator string `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator,omitempty"`
}

func (*ValidatorCork) Descriptor 

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

func (*ValidatorCork) GetCork 

func (m *ValidatorCork) GetCork() *Cork

func (*ValidatorCork) GetValidator 

func (m *ValidatorCork) GetValidator() string

func (*ValidatorCork) Marshal 

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

func (*ValidatorCork) MarshalTo 

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

func (*ValidatorCork) MarshalToSizedBuffer 

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

func (*ValidatorCork) ProtoMessage 

func (*ValidatorCork) ProtoMessage()

func (*ValidatorCork) Reset 

func (m *ValidatorCork) Reset()

func (*ValidatorCork) Size 

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

func (*ValidatorCork) String 

func (m *ValidatorCork) String() string

func (*ValidatorCork) Unmarshal 

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

func (*ValidatorCork) XXX_DiscardUnknown 

func (m *ValidatorCork) XXX_DiscardUnknown()

func (*ValidatorCork) XXX_Marshal 

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

func (*ValidatorCork) XXX_Merge 

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

func (*ValidatorCork) XXX_Size 

func (m *ValidatorCork) XXX_Size() int

func (*ValidatorCork) XXX_Unmarshal 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.