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: 38 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	EventTypeDelegateAllocations = "delegate_allocations"
	EventTypeAllocationPrecommit = "allocation_precommit"
	EventTypeAllocationCommit    = "allocation_commit"
	EventTypeCommitPeriod        = "commit_period"

	AttributeKeySigner            = "signer"
	AttributeKeyDeleagate         = "delegate"
	AttributeKeyValidator         = "validator"
	AttributeKeyPrevoteHash       = "hash"
	AttributeKeyCellar            = "cellar"
	AttributePoolAllocations      = "pool_allocations"
	AttributeKeyCommitPeriodStart = "commit_period_start"
	AttributeKeyCommitPeriodEnd   = "commit_period_end"

	AttributeValueCategory = ModuleName
)

allocation module event types

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

	// 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 (

	// CellarKeyPrefix - <prefix><cellar_id> -> Cellar
	CellarKeyPrefix

	// AllocationPrecommitKeyPrefix - <prefix><val_address><cel_address> -> <hash>
	AllocationPrecommitKeyPrefix // key for allocation precommits

	// AllocationCommitForCellarKeyPrefix - <prefix><val_address><cel_address> -> <allocation_commit>
	AllocationCommitForCellarKeyPrefix // key for allocation commits

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

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

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

View Source 
const (
	TypeMsgAllocationPrecommit = "allocation_precommit"
	TypeMsgAllocationCommit    = "allocation_commit"
)
View Source 
const (
	ProposalTypeAddManagedCellars    = "AddManagedCellars"
	ProposalTypeRemoveManagedCellars = "RemoveManagedCellars"
)
View Source 
const CellarABI = `` /* 21066-byte string literal not displayed */
View Source 
const DefaultParamspace = ModuleName

Variables

View Source 
var (
	ErrInvalidLengthAllocation        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAllocation          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAllocation = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidPrevote         = sdkerrors.Register(ModuleName, 2, "invalid prevote hashes")
	ErrInvalidOracleData      = sdkerrors.Register(ModuleName, 3, "invalid oracle data")
	ErrNoPrecommit            = sdkerrors.Register(ModuleName, 4, "no precommit for validator")
	ErrHashMismatch           = sdkerrors.Register(ModuleName, 6, "precommit hash doesn't match commit hash")
	ErrUnsupportedDataType    = sdkerrors.Register(ModuleName, 8, "unsupported data type")
	ErrDuplicatedOracleData   = sdkerrors.Register(ModuleName, 10, "duplicated oracle data")
	ErrAlreadyCommitted       = sdkerrors.Register(ModuleName, 11, "allocation commit already provided")
	ErrInvalidOracleVote      = sdkerrors.Register(ModuleName, 12, "invalid oracle vote")
	ErrAggregatedDataNotFound = sdkerrors.Register(ModuleName, 13, "aggregated oracle data not found")
)

x/oracle 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 (
	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 ABIEncodedCellarTickInfoBytes 

func ABIEncodedCellarTickInfoBytes(index uint) []byte

func DataHash 

func DataHash(salt, jsonData string, signer sdk.ValAddress) []byte

DataHash returns the hash for a precommit given the proper args

func GetAllocationCommitForCellarKey 

func GetAllocationCommitForCellarKey(val sdk.ValAddress, cel common.Address) []byte

GetAllocationCommitForCellarKey returns the key for a validators vote for a given cellar

func GetAllocationCommitKeyPrefix 

func GetAllocationCommitKeyPrefix(val sdk.ValAddress) []byte

GetAllocationCommitKeyPrefix returns the key prefix for allocation commits for a validator

func GetAllocationPrecommitKey 

func GetAllocationPrecommitKey(val sdk.ValAddress, cel common.Address) []byte

GetAllocationPrecommitKey returns the key for a validators prevote for a cellar

func GetCellarKey 

func GetCellarKey(address common.Address) []byte

GetCellarKey - the cellar by id

func GetCellarUpdateKey 

func GetCellarUpdateKey(invalidationNonce uint64) []byte

GetCellarUpdateKey - the pending cellar update by invalidation nonce

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)

func TruncateDec 

func TruncateDec(decStr string) (sdk.Dec, error)

TruncateDec splits a decimal into the integer and decimal components and then truncates the decimals in case it has a precision larger than the max allowed one (18).

Types

type ABIEncodedTickRange 

type ABIEncodedTickRange struct {
	TokenID *big.Int `abi:"tokenId"`
	Upper   *big.Int `abi:"tickUpper"`
	Lower   *big.Int `abi:"tickLower"`
	Weight  *big.Int `abi:"weight"`
}

type AddManagedCellarsProposal 

type AddManagedCellarsProposal 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"`
}

func NewAddManagedCellarsProposal 

func NewAddManagedCellarsProposal(title string, description string, cellarIds []string) *AddManagedCellarsProposal

func (*AddManagedCellarsProposal) Descriptor 

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

func (*AddManagedCellarsProposal) GetCellarIds 

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

func (*AddManagedCellarsProposal) GetDescription 

func (m *AddManagedCellarsProposal) GetDescription() string

func (*AddManagedCellarsProposal) GetTitle 

func (m *AddManagedCellarsProposal) GetTitle() string

func (*AddManagedCellarsProposal) Marshal 

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

func (*AddManagedCellarsProposal) MarshalTo 

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

func (*AddManagedCellarsProposal) MarshalToSizedBuffer 

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

func (*AddManagedCellarsProposal) ProposalRoute 

func (m *AddManagedCellarsProposal) ProposalRoute() string

func (*AddManagedCellarsProposal) ProposalType 

func (m *AddManagedCellarsProposal) ProposalType() string

func (*AddManagedCellarsProposal) ProtoMessage 

func (*AddManagedCellarsProposal) ProtoMessage()

func (*AddManagedCellarsProposal) Reset 

func (m *AddManagedCellarsProposal) Reset()

func (*AddManagedCellarsProposal) Size 

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

func (*AddManagedCellarsProposal) String 

func (m *AddManagedCellarsProposal) String() string

func (*AddManagedCellarsProposal) Unmarshal 

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

func (*AddManagedCellarsProposal) ValidateBasic 

func (m *AddManagedCellarsProposal) ValidateBasic() error

func (*AddManagedCellarsProposal) XXX_DiscardUnknown 

func (m *AddManagedCellarsProposal) XXX_DiscardUnknown()

func (*AddManagedCellarsProposal) XXX_Marshal 

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

func (*AddManagedCellarsProposal) XXX_Merge 

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

func (*AddManagedCellarsProposal) XXX_Size 

func (m *AddManagedCellarsProposal) XXX_Size() int

func (*AddManagedCellarsProposal) XXX_Unmarshal 

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

type Allocation 

type Allocation struct {
	Vote *RebalanceVote `protobuf:"bytes,1,opt,name=vote,proto3" json:"vote,omitempty"`
	Salt string         `protobuf:"bytes,2,opt,name=salt,proto3" json:"salt,omitempty"`
}

Allocation is the commit for all allocations for a cellar by a validator

func (*Allocation) Descriptor 

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

func (*Allocation) GetSalt 

func (m *Allocation) GetSalt() string

func (*Allocation) GetVote 

func (m *Allocation) GetVote() *RebalanceVote

func (*Allocation) Marshal 

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

func (*Allocation) MarshalTo 

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

func (*Allocation) MarshalToSizedBuffer 

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

func (*Allocation) ProtoMessage 

func (*Allocation) ProtoMessage()

func (*Allocation) Reset 

func (m *Allocation) Reset()

func (*Allocation) Size 

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

func (*Allocation) String 

func (m *Allocation) String() string

func (*Allocation) Unmarshal 

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

func (*Allocation) ValidateBasic 

func (ac *Allocation) ValidateBasic() error

func (*Allocation) XXX_DiscardUnknown 

func (m *Allocation) XXX_DiscardUnknown()

func (*Allocation) XXX_Marshal 

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

func (*Allocation) XXX_Merge 

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

func (*Allocation) XXX_Size 

func (m *Allocation) XXX_Size() int

func (*Allocation) XXX_Unmarshal 

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

type AllocationPrecommit 

type AllocationPrecommit struct {
	//  bytes  hash = 1 [(gogoproto.casttype) = "github.com/tendermint/tendermint/libs/bytes.HexBytes"];
	Hash     []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	CellarId string `protobuf:"bytes,2,opt,name=cellar_id,json=cellarId,proto3" json:"cellar_id,omitempty"`
}

AllocationPrecommit defines an array of hashed data to be used for the precommit phase of allocation

func (*AllocationPrecommit) Descriptor 

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

func (*AllocationPrecommit) GetCellarId 

func (m *AllocationPrecommit) GetCellarId() string

func (*AllocationPrecommit) GetHash 

func (m *AllocationPrecommit) GetHash() []byte

func (*AllocationPrecommit) Marshal 

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

func (*AllocationPrecommit) MarshalTo 

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

func (*AllocationPrecommit) MarshalToSizedBuffer 

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

func (*AllocationPrecommit) ProtoMessage 

func (*AllocationPrecommit) ProtoMessage()

func (*AllocationPrecommit) Reset 

func (m *AllocationPrecommit) Reset()

func (*AllocationPrecommit) Size 

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

func (*AllocationPrecommit) String 

func (m *AllocationPrecommit) String() string

func (*AllocationPrecommit) Unmarshal 

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

func (*AllocationPrecommit) XXX_DiscardUnknown 

func (m *AllocationPrecommit) XXX_DiscardUnknown()

func (*AllocationPrecommit) XXX_Marshal 

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

func (*AllocationPrecommit) XXX_Merge 

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

func (*AllocationPrecommit) XXX_Size 

func (m *AllocationPrecommit) XXX_Size() int

func (*AllocationPrecommit) XXX_Unmarshal 

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

type Cellar 

type Cellar struct {
	Id         string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	TickRanges []*TickRange `protobuf:"bytes,2,rep,name=tick_ranges,json=tickRanges,proto3" json:"tick_ranges,omitempty"`
}

Cellar is a collection of pools for a token pair

func (*Cellar) Address 

func (c *Cellar) Address() common.Address

func (*Cellar) Descriptor 

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

func (*Cellar) Equals 

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

func (*Cellar) GetId 

func (m *Cellar) GetId() string

func (*Cellar) GetTickRanges 

func (m *Cellar) GetTickRanges() []*TickRange

func (*Cellar) Hash 

func (c *Cellar) Hash(salt string, val sdk.ValAddress) ([]byte, error)

func (*Cellar) Marshal 

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

func (*Cellar) MarshalTo 

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

func (*Cellar) MarshalToSizedBuffer 

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

func (*Cellar) ProtoMessage 

func (*Cellar) ProtoMessage()

func (*Cellar) Reset 

func (m *Cellar) Reset()

func (*Cellar) Size 

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

func (*Cellar) String 

func (m *Cellar) String() string

func (*Cellar) Unmarshal 

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

func (*Cellar) ValidateBasic 

func (c *Cellar) ValidateBasic() error

func (*Cellar) XXX_DiscardUnknown 

func (m *Cellar) XXX_DiscardUnknown()

func (*Cellar) XXX_Marshal 

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

func (*Cellar) XXX_Merge 

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

func (*Cellar) XXX_Size 

func (m *Cellar) XXX_Size() int

func (*Cellar) XXX_Unmarshal 

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

type CellarUpdate 

type CellarUpdate struct {
	InvalidationNonce uint64         `protobuf:"varint,1,opt,name=invalidation_nonce,json=invalidationNonce,proto3" json:"invalidation_nonce,omitempty"`
	Vote              *RebalanceVote `protobuf:"bytes,2,opt,name=vote,proto3" json:"vote,omitempty"`
}

func (*CellarUpdate) Descriptor 

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

func (*CellarUpdate) GetInvalidationNonce 

func (m *CellarUpdate) GetInvalidationNonce() uint64

func (*CellarUpdate) GetVote 

func (m *CellarUpdate) GetVote() *RebalanceVote

func (*CellarUpdate) Marshal 

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

func (*CellarUpdate) MarshalTo 

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

func (*CellarUpdate) MarshalToSizedBuffer 

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

func (*CellarUpdate) ProtoMessage 

func (*CellarUpdate) ProtoMessage()

func (*CellarUpdate) Reset 

func (m *CellarUpdate) Reset()

func (*CellarUpdate) Size 

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

func (*CellarUpdate) String 

func (m *CellarUpdate) String() string

func (*CellarUpdate) Unmarshal 

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

func (*CellarUpdate) XXX_DiscardUnknown 

func (m *CellarUpdate) XXX_DiscardUnknown()

func (*CellarUpdate) XXX_Marshal 

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

func (*CellarUpdate) XXX_Merge 

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

func (*CellarUpdate) XXX_Size 

func (m *CellarUpdate) XXX_Size() int

func (*CellarUpdate) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	Params  Params    `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
	Cellars []*Cellar `protobuf:"bytes,2,rep,name=cellars,proto3" json:"cellars,omitempty"`
}

GenesisState - all allocation 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) GetCellars 

func (m *GenesisState) GetCellars() []*Cellar

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

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 MsgAllocationCommit 

type MsgAllocationCommit struct {
	// vote containing the oracle data feed
	Commit []*Allocation `protobuf:"bytes,1,rep,name=commit,proto3" json:"commit,omitempty"`
	// signer (i.e feeder) account address
	Signer string `protobuf:"bytes,2,opt,name=signer,proto3" json:"signer,omitempty"`
}

MsgAllocationCommit - sdk.Msg for submitting arbitrary oracle data that has been prevoted on

func NewMsgAllocationCommit 

func NewMsgAllocationCommit(commits []*Allocation, signer sdk.AccAddress) *MsgAllocationCommit

NewMsgAllocationCommit return a new MsgAllocationPrecommit

func (*MsgAllocationCommit) Descriptor 

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

func (*MsgAllocationCommit) GetCommit 

func (m *MsgAllocationCommit) GetCommit() []*Allocation

func (*MsgAllocationCommit) GetSignBytes 

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

GetSignBytes implements sdk.Msg

func (*MsgAllocationCommit) GetSigner 

func (m *MsgAllocationCommit) GetSigner() string

func (*MsgAllocationCommit) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgAllocationCommit) Marshal 

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

func (*MsgAllocationCommit) MarshalTo 

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

func (*MsgAllocationCommit) MarshalToSizedBuffer 

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

func (*MsgAllocationCommit) MustGetSigner 

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

MustGetSigner returns the signer address

func (*MsgAllocationCommit) ProtoMessage 

func (*MsgAllocationCommit) ProtoMessage()

func (*MsgAllocationCommit) Reset 

func (m *MsgAllocationCommit) Reset()

func (*MsgAllocationCommit) Route 

func (m *MsgAllocationCommit) Route() string

Route implements sdk.Msg

func (*MsgAllocationCommit) Size 

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

func (*MsgAllocationCommit) String 

func (m *MsgAllocationCommit) String() string

func (*MsgAllocationCommit) Type 

func (m *MsgAllocationCommit) Type() string

Type implements sdk.Msg

func (*MsgAllocationCommit) Unmarshal 

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

func (*MsgAllocationCommit) ValidateBasic 

func (m *MsgAllocationCommit) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgAllocationCommit) XXX_DiscardUnknown 

func (m *MsgAllocationCommit) XXX_DiscardUnknown()

func (*MsgAllocationCommit) XXX_Marshal 

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

func (*MsgAllocationCommit) XXX_Merge 

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

func (*MsgAllocationCommit) XXX_Size 

func (m *MsgAllocationCommit) XXX_Size() int

func (*MsgAllocationCommit) XXX_Unmarshal 

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

type MsgAllocationCommitResponse 

type MsgAllocationCommitResponse struct {
}

MsgAllocationCommitResponse is the response type for the Msg/AllocationCommit gRPC method.

func (*MsgAllocationCommitResponse) Descriptor 

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

func (*MsgAllocationCommitResponse) Marshal 

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

func (*MsgAllocationCommitResponse) MarshalTo 

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

func (*MsgAllocationCommitResponse) MarshalToSizedBuffer 

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

func (*MsgAllocationCommitResponse) ProtoMessage 

func (*MsgAllocationCommitResponse) ProtoMessage()

func (*MsgAllocationCommitResponse) Reset 

func (m *MsgAllocationCommitResponse) Reset()

func (*MsgAllocationCommitResponse) Size 

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

func (*MsgAllocationCommitResponse) String 

func (m *MsgAllocationCommitResponse) String() string

func (*MsgAllocationCommitResponse) Unmarshal 

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

func (*MsgAllocationCommitResponse) XXX_DiscardUnknown 

func (m *MsgAllocationCommitResponse) XXX_DiscardUnknown()

func (*MsgAllocationCommitResponse) XXX_Marshal 

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

func (*MsgAllocationCommitResponse) XXX_Merge 

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

func (*MsgAllocationCommitResponse) XXX_Size 

func (m *MsgAllocationCommitResponse) XXX_Size() int

func (*MsgAllocationCommitResponse) XXX_Unmarshal 

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

type MsgAllocationPrecommit 

type MsgAllocationPrecommit struct {
	// precommit containing the hash of the allocation precommit contents
	Precommit []*AllocationPrecommit `protobuf:"bytes,1,rep,name=precommit,proto3" json:"precommit,omitempty"`
	// signer (i.e feeder) account address
	Signer string `protobuf:"bytes,2,opt,name=signer,proto3" json:"signer,omitempty"`
}

MsgAllocationPrecommit - sdk.Msg for prevoting on an array of oracle data types. The purpose of the prevote is to hide vote for data with hashes formatted as hex string: SHA256("{salt}:{data_cannonical_json}:{voter}")

func NewMsgAllocationPrecommit 

func NewMsgAllocationPrecommit(vote RebalanceVote, salt string, signer sdk.AccAddress, val sdk.ValAddress) (*MsgAllocationPrecommit, error)

NewMsgAllocationPrecommit return a new MsgAllocationPrecommit

func (*MsgAllocationPrecommit) Descriptor 

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

func (*MsgAllocationPrecommit) GetPrecommit 

func (m *MsgAllocationPrecommit) GetPrecommit() []*AllocationPrecommit

func (*MsgAllocationPrecommit) GetSignBytes 

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

GetSignBytes implements sdk.Msg

func (*MsgAllocationPrecommit) GetSigner 

func (m *MsgAllocationPrecommit) GetSigner() string

func (*MsgAllocationPrecommit) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgAllocationPrecommit) Marshal 

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

func (*MsgAllocationPrecommit) MarshalTo 

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

func (*MsgAllocationPrecommit) MarshalToSizedBuffer 

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

func (*MsgAllocationPrecommit) MustGetSigner 

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

MustGetSigner returns the signer address

func (*MsgAllocationPrecommit) ProtoMessage 

func (*MsgAllocationPrecommit) ProtoMessage()

func (*MsgAllocationPrecommit) Reset 

func (m *MsgAllocationPrecommit) Reset()

func (*MsgAllocationPrecommit) Route 

func (m *MsgAllocationPrecommit) Route() string

Route implements sdk.Msg

func (*MsgAllocationPrecommit) Size 

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

func (*MsgAllocationPrecommit) String 

func (m *MsgAllocationPrecommit) String() string

func (*MsgAllocationPrecommit) Type 

func (m *MsgAllocationPrecommit) Type() string

Type implements sdk.Msg

func (*MsgAllocationPrecommit) Unmarshal 

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

func (*MsgAllocationPrecommit) ValidateBasic 

func (m *MsgAllocationPrecommit) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgAllocationPrecommit) XXX_DiscardUnknown 

func (m *MsgAllocationPrecommit) XXX_DiscardUnknown()

func (*MsgAllocationPrecommit) XXX_Marshal 

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

func (*MsgAllocationPrecommit) XXX_Merge 

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

func (*MsgAllocationPrecommit) XXX_Size 

func (m *MsgAllocationPrecommit) XXX_Size() int

func (*MsgAllocationPrecommit) XXX_Unmarshal 

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

type MsgAllocationPrecommitResponse 

type MsgAllocationPrecommitResponse struct {
}

MsgAllocationPrecommitResponse is the response type for the Msg/AllocationPrecommitResponse gRPC method.

func (*MsgAllocationPrecommitResponse) Descriptor 

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

func (*MsgAllocationPrecommitResponse) Marshal 

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

func (*MsgAllocationPrecommitResponse) MarshalTo 

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

func (*MsgAllocationPrecommitResponse) MarshalToSizedBuffer 

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

func (*MsgAllocationPrecommitResponse) ProtoMessage 

func (*MsgAllocationPrecommitResponse) ProtoMessage()

func (*MsgAllocationPrecommitResponse) Reset 

func (m *MsgAllocationPrecommitResponse) Reset()

func (*MsgAllocationPrecommitResponse) Size 

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

func (*MsgAllocationPrecommitResponse) String 

func (m *MsgAllocationPrecommitResponse) String() string

func (*MsgAllocationPrecommitResponse) Unmarshal 

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

func (*MsgAllocationPrecommitResponse) XXX_DiscardUnknown 

func (m *MsgAllocationPrecommitResponse) XXX_DiscardUnknown()

func (*MsgAllocationPrecommitResponse) XXX_Marshal 

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

func (*MsgAllocationPrecommitResponse) XXX_Merge 

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

func (*MsgAllocationPrecommitResponse) XXX_Size 

func (m *MsgAllocationPrecommitResponse) XXX_Size() int

func (*MsgAllocationPrecommitResponse) XXX_Unmarshal 

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

type MsgClient 

type MsgClient interface {
	// AllocationPrecommit defines a message that commits a hash of allocation data feed before the data is actually submitted.
	AllocationPrecommit(ctx context.Context, in *MsgAllocationPrecommit, opts ...grpc.CallOption) (*MsgAllocationPrecommitResponse, error)
	// AllocationCommit defines a message to submit the actual allocation data that was committed by the feeder through the pre-commit.
	AllocationCommit(ctx context.Context, in *MsgAllocationCommit, opts ...grpc.CallOption) (*MsgAllocationCommitResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgServer 

type MsgServer interface {
	// AllocationPrecommit defines a message that commits a hash of allocation data feed before the data is actually submitted.
	AllocationPrecommit(context.Context, *MsgAllocationPrecommit) (*MsgAllocationPrecommitResponse, error)
	// AllocationCommit defines a message to submit the actual allocation data that was committed by the feeder through the pre-commit.
	AllocationCommit(context.Context, *MsgAllocationCommit) (*MsgAllocationCommitResponse, error)
}

MsgServer is the server API for Msg service.

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 allocation 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 QueryAllocationCommitRequest 

type QueryAllocationCommitRequest struct {
	// validator operator address
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	// cellar contract address
	Cellar string `protobuf:"bytes,2,opt,name=cellar,proto3" json:"cellar,omitempty"`
}

QueryAllocationCommitRequest is the request type for the Query/QueryallocationDataVote gRPC method.

func (*QueryAllocationCommitRequest) Descriptor 

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

func (*QueryAllocationCommitRequest) GetCellar 

func (m *QueryAllocationCommitRequest) GetCellar() string

func (*QueryAllocationCommitRequest) GetValidator 

func (m *QueryAllocationCommitRequest) GetValidator() string

func (*QueryAllocationCommitRequest) Marshal 

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

func (*QueryAllocationCommitRequest) MarshalTo 

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

func (*QueryAllocationCommitRequest) MarshalToSizedBuffer 

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

func (*QueryAllocationCommitRequest) ProtoMessage 

func (*QueryAllocationCommitRequest) ProtoMessage()

func (*QueryAllocationCommitRequest) Reset 

func (m *QueryAllocationCommitRequest) Reset()

func (*QueryAllocationCommitRequest) Size 

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

func (*QueryAllocationCommitRequest) String 

func (m *QueryAllocationCommitRequest) String() string

func (*QueryAllocationCommitRequest) Unmarshal 

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

func (*QueryAllocationCommitRequest) XXX_DiscardUnknown 

func (m *QueryAllocationCommitRequest) XXX_DiscardUnknown()

func (*QueryAllocationCommitRequest) XXX_Marshal 

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

func (*QueryAllocationCommitRequest) XXX_Merge 

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

func (*QueryAllocationCommitRequest) XXX_Size 

func (m *QueryAllocationCommitRequest) XXX_Size() int

func (*QueryAllocationCommitRequest) XXX_Unmarshal 

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

type QueryAllocationCommitResponse 

type QueryAllocationCommitResponse struct {
	// vote containing the allocation feed submitted within the latest voting period
	Commit *Allocation `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"`
}

QueryAllocationCommitResponse is the response type for the Query/QueryallocationDataVote gRPC method.

func (*QueryAllocationCommitResponse) Descriptor 

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

func (*QueryAllocationCommitResponse) GetCommit 

func (m *QueryAllocationCommitResponse) GetCommit() *Allocation

func (*QueryAllocationCommitResponse) Marshal 

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

func (*QueryAllocationCommitResponse) MarshalTo 

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

func (*QueryAllocationCommitResponse) MarshalToSizedBuffer 

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

func (*QueryAllocationCommitResponse) ProtoMessage 

func (*QueryAllocationCommitResponse) ProtoMessage()

func (*QueryAllocationCommitResponse) Reset 

func (m *QueryAllocationCommitResponse) Reset()

func (*QueryAllocationCommitResponse) Size 

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

func (*QueryAllocationCommitResponse) String 

func (m *QueryAllocationCommitResponse) String() string

func (*QueryAllocationCommitResponse) Unmarshal 

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

func (*QueryAllocationCommitResponse) XXX_DiscardUnknown 

func (m *QueryAllocationCommitResponse) XXX_DiscardUnknown()

func (*QueryAllocationCommitResponse) XXX_Marshal 

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

func (*QueryAllocationCommitResponse) XXX_Merge 

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

func (*QueryAllocationCommitResponse) XXX_Size 

func (m *QueryAllocationCommitResponse) XXX_Size() int

func (*QueryAllocationCommitResponse) XXX_Unmarshal 

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

type QueryAllocationCommitsRequest 

type QueryAllocationCommitsRequest struct {
}

QueryAllocationCommitsRequest is the request type for the Query/QueryAllocationCommits gRPC method.

func (*QueryAllocationCommitsRequest) Descriptor 

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

func (*QueryAllocationCommitsRequest) Marshal 

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

func (*QueryAllocationCommitsRequest) MarshalTo 

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

func (*QueryAllocationCommitsRequest) MarshalToSizedBuffer 

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

func (*QueryAllocationCommitsRequest) ProtoMessage 

func (*QueryAllocationCommitsRequest) ProtoMessage()

func (*QueryAllocationCommitsRequest) Reset 

func (m *QueryAllocationCommitsRequest) Reset()

func (*QueryAllocationCommitsRequest) Size 

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

func (*QueryAllocationCommitsRequest) String 

func (m *QueryAllocationCommitsRequest) String() string

func (*QueryAllocationCommitsRequest) Unmarshal 

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

func (*QueryAllocationCommitsRequest) XXX_DiscardUnknown 

func (m *QueryAllocationCommitsRequest) XXX_DiscardUnknown()

func (*QueryAllocationCommitsRequest) XXX_Marshal 

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

func (*QueryAllocationCommitsRequest) XXX_Merge 

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

func (*QueryAllocationCommitsRequest) XXX_Size 

func (m *QueryAllocationCommitsRequest) XXX_Size() int

func (*QueryAllocationCommitsRequest) XXX_Unmarshal 

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

type QueryAllocationCommitsResponse 

type QueryAllocationCommitsResponse struct {
	// votes containing the allocation feed submitted within the latest voting period
	Commits []*Allocation `protobuf:"bytes,1,rep,name=commits,proto3" json:"commits,omitempty"`
}

QueryAllocationCommitsResponse is the response type for the Query/QueryAllocationCommits gRPC method.

func (*QueryAllocationCommitsResponse) Descriptor 

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

func (*QueryAllocationCommitsResponse) GetCommits 

func (m *QueryAllocationCommitsResponse) GetCommits() []*Allocation

func (*QueryAllocationCommitsResponse) Marshal 

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

func (*QueryAllocationCommitsResponse) MarshalTo 

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

func (*QueryAllocationCommitsResponse) MarshalToSizedBuffer 

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

func (*QueryAllocationCommitsResponse) ProtoMessage 

func (*QueryAllocationCommitsResponse) ProtoMessage()

func (*QueryAllocationCommitsResponse) Reset 

func (m *QueryAllocationCommitsResponse) Reset()

func (*QueryAllocationCommitsResponse) Size 

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

func (*QueryAllocationCommitsResponse) String 

func (m *QueryAllocationCommitsResponse) String() string

func (*QueryAllocationCommitsResponse) Unmarshal 

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

func (*QueryAllocationCommitsResponse) XXX_DiscardUnknown 

func (m *QueryAllocationCommitsResponse) XXX_DiscardUnknown()

func (*QueryAllocationCommitsResponse) XXX_Marshal 

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

func (*QueryAllocationCommitsResponse) XXX_Merge 

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

func (*QueryAllocationCommitsResponse) XXX_Size 

func (m *QueryAllocationCommitsResponse) XXX_Size() int

func (*QueryAllocationCommitsResponse) XXX_Unmarshal 

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

type QueryAllocationPrecommitRequest 

type QueryAllocationPrecommitRequest struct {
	// validator operator address
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
	// cellar contract address
	Cellar string `protobuf:"bytes,2,opt,name=cellar,proto3" json:"cellar,omitempty"`
}

QueryAllocationPrecommitRequest is the request type for the Query/AllocationPrecommit gRPC method.

func (*QueryAllocationPrecommitRequest) Descriptor 

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

func (*QueryAllocationPrecommitRequest) GetCellar 

func (m *QueryAllocationPrecommitRequest) GetCellar() string

func (*QueryAllocationPrecommitRequest) GetValidator 

func (m *QueryAllocationPrecommitRequest) GetValidator() string

func (*QueryAllocationPrecommitRequest) Marshal 

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

func (*QueryAllocationPrecommitRequest) MarshalTo 

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

func (*QueryAllocationPrecommitRequest) MarshalToSizedBuffer 

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

func (*QueryAllocationPrecommitRequest) ProtoMessage 

func (*QueryAllocationPrecommitRequest) ProtoMessage()

func (*QueryAllocationPrecommitRequest) Reset 

func (m *QueryAllocationPrecommitRequest) Reset()

func (*QueryAllocationPrecommitRequest) Size 

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

func (*QueryAllocationPrecommitRequest) String 

func (m *QueryAllocationPrecommitRequest) String() string

func (*QueryAllocationPrecommitRequest) Unmarshal 

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

func (*QueryAllocationPrecommitRequest) XXX_DiscardUnknown 

func (m *QueryAllocationPrecommitRequest) XXX_DiscardUnknown()

func (*QueryAllocationPrecommitRequest) XXX_Marshal 

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

func (*QueryAllocationPrecommitRequest) XXX_Merge 

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

func (*QueryAllocationPrecommitRequest) XXX_Size 

func (m *QueryAllocationPrecommitRequest) XXX_Size() int

func (*QueryAllocationPrecommitRequest) XXX_Unmarshal 

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

type QueryAllocationPrecommitResponse 

type QueryAllocationPrecommitResponse struct {
	// prevote submitted within the latest voting period
	Precommit *AllocationPrecommit `protobuf:"bytes,1,opt,name=precommit,proto3" json:"precommit,omitempty"`
}

QueryAllocationPrecommitResponse is the response type for the Query/AllocationPrecommit gRPC method.

func (*QueryAllocationPrecommitResponse) Descriptor 

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

func (*QueryAllocationPrecommitResponse) GetPrecommit 

func (m *QueryAllocationPrecommitResponse) GetPrecommit() *AllocationPrecommit

func (*QueryAllocationPrecommitResponse) Marshal 

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

func (*QueryAllocationPrecommitResponse) MarshalTo 

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

func (*QueryAllocationPrecommitResponse) MarshalToSizedBuffer 

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

func (*QueryAllocationPrecommitResponse) ProtoMessage 

func (*QueryAllocationPrecommitResponse) ProtoMessage()

func (*QueryAllocationPrecommitResponse) Reset 

func (m *QueryAllocationPrecommitResponse) Reset()

func (*QueryAllocationPrecommitResponse) Size 

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

func (*QueryAllocationPrecommitResponse) String 

func (m *QueryAllocationPrecommitResponse) String() string

func (*QueryAllocationPrecommitResponse) Unmarshal 

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

func (*QueryAllocationPrecommitResponse) XXX_DiscardUnknown 

func (m *QueryAllocationPrecommitResponse) XXX_DiscardUnknown()

func (*QueryAllocationPrecommitResponse) XXX_Marshal 

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

func (*QueryAllocationPrecommitResponse) XXX_Merge 

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

func (*QueryAllocationPrecommitResponse) XXX_Size 

func (m *QueryAllocationPrecommitResponse) XXX_Size() int

func (*QueryAllocationPrecommitResponse) XXX_Unmarshal 

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

type QueryAllocationPrecommitsRequest 

type QueryAllocationPrecommitsRequest struct {
}

QueryAllocationPrecommitsRequest is the request type for the Query/AllocationPrecommits gRPC method.

func (*QueryAllocationPrecommitsRequest) Descriptor 

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

func (*QueryAllocationPrecommitsRequest) Marshal 

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

func (*QueryAllocationPrecommitsRequest) MarshalTo 

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

func (*QueryAllocationPrecommitsRequest) MarshalToSizedBuffer 

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

func (*QueryAllocationPrecommitsRequest) ProtoMessage 

func (*QueryAllocationPrecommitsRequest) ProtoMessage()

func (*QueryAllocationPrecommitsRequest) Reset 

func (m *QueryAllocationPrecommitsRequest) Reset()

func (*QueryAllocationPrecommitsRequest) Size 

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

func (*QueryAllocationPrecommitsRequest) String 

func (m *QueryAllocationPrecommitsRequest) String() string

func (*QueryAllocationPrecommitsRequest) Unmarshal 

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

func (*QueryAllocationPrecommitsRequest) XXX_DiscardUnknown 

func (m *QueryAllocationPrecommitsRequest) XXX_DiscardUnknown()

func (*QueryAllocationPrecommitsRequest) XXX_Marshal 

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

func (*QueryAllocationPrecommitsRequest) XXX_Merge 

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

func (*QueryAllocationPrecommitsRequest) XXX_Size 

func (m *QueryAllocationPrecommitsRequest) XXX_Size() int

func (*QueryAllocationPrecommitsRequest) XXX_Unmarshal 

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

type QueryAllocationPrecommitsResponse 

type QueryAllocationPrecommitsResponse struct {
	// prevote submitted within the latest voting period
	Precommits []*AllocationPrecommit `protobuf:"bytes,1,rep,name=precommits,proto3" json:"precommits,omitempty"`
}

QueryAllocationPrecommitResponse is the response type for the Query/AllocationPrecommits gRPC method.

func (*QueryAllocationPrecommitsResponse) Descriptor 

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

func (*QueryAllocationPrecommitsResponse) GetPrecommits 

func (m *QueryAllocationPrecommitsResponse) GetPrecommits() []*AllocationPrecommit

func (*QueryAllocationPrecommitsResponse) Marshal 

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

func (*QueryAllocationPrecommitsResponse) MarshalTo 

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

func (*QueryAllocationPrecommitsResponse) MarshalToSizedBuffer 

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

func (*QueryAllocationPrecommitsResponse) ProtoMessage 

func (*QueryAllocationPrecommitsResponse) ProtoMessage()

func (*QueryAllocationPrecommitsResponse) Reset 

func (m *QueryAllocationPrecommitsResponse) Reset()

func (*QueryAllocationPrecommitsResponse) Size 

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

func (*QueryAllocationPrecommitsResponse) String 

func (m *QueryAllocationPrecommitsResponse) String() string

func (*QueryAllocationPrecommitsResponse) Unmarshal 

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

func (*QueryAllocationPrecommitsResponse) XXX_DiscardUnknown 

func (m *QueryAllocationPrecommitsResponse) XXX_DiscardUnknown()

func (*QueryAllocationPrecommitsResponse) XXX_Marshal 

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

func (*QueryAllocationPrecommitsResponse) XXX_Merge 

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

func (*QueryAllocationPrecommitsResponse) XXX_Size 

func (m *QueryAllocationPrecommitsResponse) XXX_Size() int

func (*QueryAllocationPrecommitsResponse) XXX_Unmarshal 

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

type QueryCellarsRequest 

type QueryCellarsRequest struct {
}

QueryCellarsRequest is the request type for Query/QueryCellars gRPC method.

func (*QueryCellarsRequest) Descriptor 

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

func (*QueryCellarsRequest) Marshal 

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

func (*QueryCellarsRequest) MarshalTo 

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

func (*QueryCellarsRequest) MarshalToSizedBuffer 

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

func (*QueryCellarsRequest) ProtoMessage 

func (*QueryCellarsRequest) ProtoMessage()

func (*QueryCellarsRequest) Reset 

func (m *QueryCellarsRequest) Reset()

func (*QueryCellarsRequest) Size 

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

func (*QueryCellarsRequest) String 

func (m *QueryCellarsRequest) String() string

func (*QueryCellarsRequest) Unmarshal 

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

func (*QueryCellarsRequest) XXX_DiscardUnknown 

func (m *QueryCellarsRequest) XXX_DiscardUnknown()

func (*QueryCellarsRequest) XXX_Marshal 

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

func (*QueryCellarsRequest) XXX_Merge 

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

func (*QueryCellarsRequest) XXX_Size 

func (m *QueryCellarsRequest) XXX_Size() int

func (*QueryCellarsRequest) XXX_Unmarshal 

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

type QueryCellarsResponse 

type QueryCellarsResponse struct {
	Cellars []*Cellar `protobuf:"bytes,1,rep,name=cellars,proto3" json:"cellars,omitempty"`
}

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

func (*QueryCellarsResponse) Descriptor 

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

func (*QueryCellarsResponse) GetCellars 

func (m *QueryCellarsResponse) GetCellars() []*Cellar

func (*QueryCellarsResponse) Marshal 

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

func (*QueryCellarsResponse) MarshalTo 

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

func (*QueryCellarsResponse) MarshalToSizedBuffer 

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

func (*QueryCellarsResponse) ProtoMessage 

func (*QueryCellarsResponse) ProtoMessage()

func (*QueryCellarsResponse) Reset 

func (m *QueryCellarsResponse) Reset()

func (*QueryCellarsResponse) Size 

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

func (*QueryCellarsResponse) String 

func (m *QueryCellarsResponse) String() string

func (*QueryCellarsResponse) Unmarshal 

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

func (*QueryCellarsResponse) XXX_DiscardUnknown 

func (m *QueryCellarsResponse) XXX_DiscardUnknown()

func (*QueryCellarsResponse) XXX_Marshal 

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

func (*QueryCellarsResponse) XXX_Merge 

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

func (*QueryCellarsResponse) XXX_Size 

func (m *QueryCellarsResponse) XXX_Size() int

func (*QueryCellarsResponse) XXX_Unmarshal 

func (m *QueryCellarsResponse) 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)
	// QueryAllocationPrecommit queries the validator prevote in the current voting period
	QueryAllocationPrecommit(ctx context.Context, in *QueryAllocationPrecommitRequest, opts ...grpc.CallOption) (*QueryAllocationPrecommitResponse, error)
	// QueryAllocationPrecommits queries all allocation precommits in the voting period
	QueryAllocationPrecommits(ctx context.Context, in *QueryAllocationPrecommitsRequest, opts ...grpc.CallOption) (*QueryAllocationPrecommitsResponse, error)
	// QueryAllocationCommit queries the validator vote in the current voting period
	QueryAllocationCommit(ctx context.Context, in *QueryAllocationCommitRequest, opts ...grpc.CallOption) (*QueryAllocationCommitResponse, error)
	// QueryAllocationCommits queries all validator allocation commits
	QueryAllocationCommits(ctx context.Context, in *QueryAllocationCommitsRequest, opts ...grpc.CallOption) (*QueryAllocationCommitsResponse, 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)
	// QueryCellars returns all cellars and current tick ranges
	QueryCellars(ctx context.Context, in *QueryCellarsRequest, opts ...grpc.CallOption) (*QueryCellarsResponse, 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 QueryServer 

type QueryServer interface {
	// QueryParams queries the allocation module parameters.
	QueryParams(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	// QueryAllocationPrecommit queries the validator prevote in the current voting period
	QueryAllocationPrecommit(context.Context, *QueryAllocationPrecommitRequest) (*QueryAllocationPrecommitResponse, error)
	// QueryAllocationPrecommits queries all allocation precommits in the voting period
	QueryAllocationPrecommits(context.Context, *QueryAllocationPrecommitsRequest) (*QueryAllocationPrecommitsResponse, error)
	// QueryAllocationCommit queries the validator vote in the current voting period
	QueryAllocationCommit(context.Context, *QueryAllocationCommitRequest) (*QueryAllocationCommitResponse, error)
	// QueryAllocationCommits queries all validator allocation commits
	QueryAllocationCommits(context.Context, *QueryAllocationCommitsRequest) (*QueryAllocationCommitsResponse, error)
	// QueryVotePeriod queries the heights for the current voting period (current, start and end)
	QueryCommitPeriod(context.Context, *QueryCommitPeriodRequest) (*QueryCommitPeriodResponse, error)
	// QueryCellars returns all cellars and current tick ranges
	QueryCellars(context.Context, *QueryCellarsRequest) (*QueryCellarsResponse, error)
}

QueryServer is the server API for Query service.

type RebalanceVote 

type RebalanceVote struct {
	Cellar       *Cellar `protobuf:"bytes,1,opt,name=cellar,proto3" json:"cellar,omitempty"`
	CurrentPrice uint64  `protobuf:"varint,2,opt,name=current_price,json=currentPrice,proto3" json:"current_price,omitempty"`
}

func (RebalanceVote) ABIEncodedRebalanceBytes 

func (rv RebalanceVote) ABIEncodedRebalanceBytes() []byte

ABIEncodedRebalanceBytes gets the checkpoint signature from the given outgoing tx batch

func (*RebalanceVote) Descriptor 

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

func (*RebalanceVote) Equals 

func (rv *RebalanceVote) Equals(other RebalanceVote) bool

func (*RebalanceVote) GetCellar 

func (m *RebalanceVote) GetCellar() *Cellar

func (*RebalanceVote) GetCurrentPrice 

func (m *RebalanceVote) GetCurrentPrice() uint64

func (*RebalanceVote) Hash 

func (rv *RebalanceVote) Hash(salt string, val sdk.ValAddress) ([]byte, error)

func (*RebalanceVote) InvalidationScope 

func (rv *RebalanceVote) InvalidationScope() tmbytes.HexBytes

func (*RebalanceVote) Marshal 

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

func (*RebalanceVote) MarshalTo 

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

func (*RebalanceVote) MarshalToSizedBuffer 

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

func (*RebalanceVote) ProtoMessage 

func (*RebalanceVote) ProtoMessage()

func (*RebalanceVote) Reset 

func (m *RebalanceVote) Reset()

func (*RebalanceVote) Size 

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

func (*RebalanceVote) String 

func (m *RebalanceVote) String() string

func (*RebalanceVote) Unmarshal 

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

func (*RebalanceVote) XXX_DiscardUnknown 

func (m *RebalanceVote) XXX_DiscardUnknown()

func (*RebalanceVote) XXX_Marshal 

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

func (*RebalanceVote) XXX_Merge 

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

func (*RebalanceVote) XXX_Size 

func (m *RebalanceVote) XXX_Size() int

func (*RebalanceVote) XXX_Unmarshal 

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

type RemoveManagedCellarsProposal 

type RemoveManagedCellarsProposal 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"`
}

func NewRemoveManagedCellarsProposal 

func NewRemoveManagedCellarsProposal(title string, description string, cellarIds []string) *RemoveManagedCellarsProposal

func (*RemoveManagedCellarsProposal) Descriptor 

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

func (*RemoveManagedCellarsProposal) GetCellarIds 

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

func (*RemoveManagedCellarsProposal) GetDescription 

func (m *RemoveManagedCellarsProposal) GetDescription() string

func (*RemoveManagedCellarsProposal) GetTitle 

func (m *RemoveManagedCellarsProposal) GetTitle() string

func (*RemoveManagedCellarsProposal) Marshal 

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

func (*RemoveManagedCellarsProposal) MarshalTo 

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

func (*RemoveManagedCellarsProposal) MarshalToSizedBuffer 

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

func (*RemoveManagedCellarsProposal) ProposalRoute 

func (m *RemoveManagedCellarsProposal) ProposalRoute() string

func (*RemoveManagedCellarsProposal) ProposalType 

func (m *RemoveManagedCellarsProposal) ProposalType() string

func (*RemoveManagedCellarsProposal) ProtoMessage 

func (*RemoveManagedCellarsProposal) ProtoMessage()

func (*RemoveManagedCellarsProposal) Reset 

func (m *RemoveManagedCellarsProposal) Reset()

func (*RemoveManagedCellarsProposal) Size 

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

func (*RemoveManagedCellarsProposal) String 

func (m *RemoveManagedCellarsProposal) String() string

func (*RemoveManagedCellarsProposal) Unmarshal 

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

func (*RemoveManagedCellarsProposal) ValidateBasic 

func (m *RemoveManagedCellarsProposal) ValidateBasic() error

func (*RemoveManagedCellarsProposal) XXX_DiscardUnknown 

func (m *RemoveManagedCellarsProposal) XXX_DiscardUnknown()

func (*RemoveManagedCellarsProposal) XXX_Marshal 

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

func (*RemoveManagedCellarsProposal) XXX_Merge 

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

func (*RemoveManagedCellarsProposal) XXX_Size 

func (m *RemoveManagedCellarsProposal) XXX_Size() int

func (*RemoveManagedCellarsProposal) XXX_Unmarshal 

func (m *RemoveManagedCellarsProposal) 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 TickRange 

type TickRange struct {
	Upper  int32  `protobuf:"varint,1,opt,name=upper,proto3" json:"upper,omitempty"`
	Lower  int32  `protobuf:"varint,2,opt,name=lower,proto3" json:"lower,omitempty"`
	Weight uint32 `protobuf:"varint,3,opt,name=weight,proto3" json:"weight,omitempty"`
}

func BytesToABIEncodedTickRange 

func BytesToABIEncodedTickRange(bz []byte) (*TickRange, error)

func (*TickRange) Descriptor 

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

func (*TickRange) Equals 

func (tr *TickRange) Equals(other TickRange) bool

func (*TickRange) GetLower 

func (m *TickRange) GetLower() int32

func (*TickRange) GetUpper 

func (m *TickRange) GetUpper() int32

func (*TickRange) GetWeight 

func (m *TickRange) GetWeight() uint32

func (*TickRange) Marshal 

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

func (*TickRange) MarshalTo 

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

func (*TickRange) MarshalToSizedBuffer 

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

func (*TickRange) ProtoMessage 

func (*TickRange) ProtoMessage()

func (*TickRange) Reset 

func (m *TickRange) Reset()

func (*TickRange) Size 

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

func (*TickRange) String 

func (m *TickRange) String() string

func (*TickRange) Unmarshal 

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

func (*TickRange) XXX_DiscardUnknown 

func (m *TickRange) XXX_DiscardUnknown()

func (*TickRange) XXX_Marshal 

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

func (*TickRange) XXX_Merge 

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

func (*TickRange) XXX_Size 

func (m *TickRange) XXX_Size() int

func (*TickRange) XXX_Unmarshal 

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

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AllocationCommit 

func (*UnimplementedMsgServer) AllocationCommit(ctx context.Context, req *MsgAllocationCommit) (*MsgAllocationCommitResponse, error)

func (*UnimplementedMsgServer) AllocationPrecommit 

func (*UnimplementedMsgServer) AllocationPrecommit(ctx context.Context, req *MsgAllocationPrecommit) (*MsgAllocationPrecommitResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) QueryAllocationCommit 

func (*UnimplementedQueryServer) QueryAllocationCommit(ctx context.Context, req *QueryAllocationCommitRequest) (*QueryAllocationCommitResponse, error)

func (*UnimplementedQueryServer) QueryAllocationCommits 

func (*UnimplementedQueryServer) QueryAllocationCommits(ctx context.Context, req *QueryAllocationCommitsRequest) (*QueryAllocationCommitsResponse, error)

func (*UnimplementedQueryServer) QueryAllocationPrecommit 

func (*UnimplementedQueryServer) QueryAllocationPrecommit(ctx context.Context, req *QueryAllocationPrecommitRequest) (*QueryAllocationPrecommitResponse, error)

func (*UnimplementedQueryServer) QueryAllocationPrecommits 

func (*UnimplementedQueryServer) QueryAllocationPrecommits(ctx context.Context, req *QueryAllocationPrecommitsRequest) (*QueryAllocationPrecommitsResponse, error)

func (*UnimplementedQueryServer) QueryCellars 

func (*UnimplementedQueryServer) QueryCellars(ctx context.Context, req *QueryCellarsRequest) (*QueryCellarsResponse, 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)

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.