types

package
v1.0.3 Latest Latest
Warning

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

 Go to latest Published: Sep 1, 2021 License: Apache-2.0 Imports: 36 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

	// AllocationDelegateKeyPrefix - <prefix><val_address> -> <delegate_address>
	AllocationDelegateKeyPrefix // key for validator allocation delegation

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

	// CellarUpdateKey - <prefix><invalidationNonce> -> Cellar
	CellarUpdateKey
)

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

View Source 
const (
	TypeMsgDelegateAllocations = "delegate_allocations"
	TypeMsgAllocationPrecommit = "allocation_precommit"
	TypeMsgAllocationCommit    = "allocation_commit"
)
View Source 
const (
	ProposalTypeAddManagedCellars    = "AddManagedCellars"
	ProposalTypeRemoveManagedCellars = "RemoveManagedCellars"
)

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 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 GetAllocationDelegateKey 

func GetAllocationDelegateKey(del sdk.AccAddress) []byte

GetAllocationDelegateKey returns the validator for a given delegate key

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 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 {
	Cellar *Cellar `protobuf:"bytes,1,opt,name=cellar,proto3" json:"cellar,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) GetCellar 

func (m *Allocation) GetCellar() *Cellar

func (*Allocation) GetSalt 

func (m *Allocation) GetSalt() string

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 {
	Hash     github_com_tendermint_tendermint_libs_bytes.HexBytes `protobuf:"bytes,1,opt,name=hash,proto3,casttype=github.com/tendermint/tendermint/libs/bytes.HexBytes" 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() github_com_tendermint_tendermint_libs_bytes.HexBytes

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

func (c Cellar) GetCheckpoint() []byte

GetCheckpoint gets the checkpoint signature from the given outgoing tx batch

func (*Cellar) GetId 

func (m *Cellar) GetId() string

func (*Cellar) GetTickRanges 

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

func (*Cellar) InvalidationScope 

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

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"`
	Cellar            *Cellar `protobuf:"bytes,2,opt,name=cellar,proto3" json:"cellar,omitempty"`
}

func (*CellarUpdate) Descriptor 

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

func (*CellarUpdate) GetCellar 

func (m *CellarUpdate) GetCellar() *Cellar

func (*CellarUpdate) GetInvalidationNonce 

func (m *CellarUpdate) GetInvalidationNonce() uint64

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"`
	FeederDelegations []MsgDelegateAllocations `protobuf:"bytes,2,rep,name=feeder_delegations,json=feederDelegations,proto3" json:"feeder_delegations"`
}

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

func (m *GenesisState) GetFeederDelegations() []MsgDelegateAllocations

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

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(hash tmbytes.HexBytes, signer sdk.AccAddress) *MsgAllocationPrecommit

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 {
	// DelegateAllocations defines a message that delegates the allocating to an account address.
	DelegateAllocations(ctx context.Context, in *MsgDelegateAllocations, opts ...grpc.CallOption) (*MsgDelegateAllocationsResponse, error)
	// OracleDataPrevote defines a message that commits a hash of a oracle data feed before the data is actually submitted.
	AllocationPrecommit(ctx context.Context, in *MsgAllocationPrecommit, opts ...grpc.CallOption) (*MsgAllocationPrecommitResponse, error)
	// OracleDataVote defines a message to submit the actual oracle data that was committed by the feeder through the prevote.
	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 MsgDelegateAllocations 

type MsgDelegateAllocations struct {
	// delegate account address
	Delegate string `protobuf:"bytes,1,opt,name=delegate,proto3" json:"delegate,omitempty"`
	// validator operator address
	Validator string `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator,omitempty"`
}

MsgDelegateAllocations defines sdk.Msg for delegating allocation rights from a validator to another address, must be signed by an active validator

func NewMsgDelegateAllocations 

func NewMsgDelegateAllocations(del sdk.AccAddress, val sdk.ValAddress) *MsgDelegateAllocations

NewMsgDelegateAllocations returns a new MsgDelegateAllocations

func (*MsgDelegateAllocations) Descriptor 

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

func (*MsgDelegateAllocations) GetDelegate 

func (m *MsgDelegateAllocations) GetDelegate() string

func (*MsgDelegateAllocations) GetSignBytes 

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

GetSignBytes implements sdk.Msg

func (*MsgDelegateAllocations) GetSigners 

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

GetSigners implements sdk.Msg

func (*MsgDelegateAllocations) GetValidator 

func (m *MsgDelegateAllocations) GetValidator() string

func (*MsgDelegateAllocations) Marshal 

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

func (*MsgDelegateAllocations) MarshalTo 

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

func (*MsgDelegateAllocations) MarshalToSizedBuffer 

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

func (*MsgDelegateAllocations) MustGetDelegate 

func (m *MsgDelegateAllocations) MustGetDelegate() sdk.AccAddress

MustGetDelegate returns the sdk.AccAddress for the delegate

func (*MsgDelegateAllocations) MustGetValidator 

func (m *MsgDelegateAllocations) MustGetValidator() sdk.ValAddress

MustGetValidator returns the sdk.ValAddress for the validator

func (*MsgDelegateAllocations) ProtoMessage 

func (*MsgDelegateAllocations) ProtoMessage()

func (*MsgDelegateAllocations) Reset 

func (m *MsgDelegateAllocations) Reset()

func (*MsgDelegateAllocations) Route 

func (m *MsgDelegateAllocations) Route() string

Route implements sdk.Msg

func (*MsgDelegateAllocations) Size 

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

func (*MsgDelegateAllocations) String 

func (m *MsgDelegateAllocations) String() string

func (*MsgDelegateAllocations) Type 

func (m *MsgDelegateAllocations) Type() string

Type implements sdk.Msg

func (*MsgDelegateAllocations) Unmarshal 

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

func (*MsgDelegateAllocations) ValidateBasic 

func (m *MsgDelegateAllocations) ValidateBasic() error

ValidateBasic implements sdk.Msg

func (*MsgDelegateAllocations) XXX_DiscardUnknown 

func (m *MsgDelegateAllocations) XXX_DiscardUnknown()

func (*MsgDelegateAllocations) XXX_Marshal 

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

func (*MsgDelegateAllocations) XXX_Merge 

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

func (*MsgDelegateAllocations) XXX_Size 

func (m *MsgDelegateAllocations) XXX_Size() int

func (*MsgDelegateAllocations) XXX_Unmarshal 

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

type MsgDelegateAllocationsResponse 

type MsgDelegateAllocationsResponse struct {
}

MsgDelegateAllocationsResponse is the response type for the Msg/DelegateAllocations gRPC method.

func (*MsgDelegateAllocationsResponse) Descriptor 

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

func (*MsgDelegateAllocationsResponse) Marshal 

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

func (*MsgDelegateAllocationsResponse) MarshalTo 

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

func (*MsgDelegateAllocationsResponse) MarshalToSizedBuffer 

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

func (*MsgDelegateAllocationsResponse) ProtoMessage 

func (*MsgDelegateAllocationsResponse) ProtoMessage()

func (*MsgDelegateAllocationsResponse) Reset 

func (m *MsgDelegateAllocationsResponse) Reset()

func (*MsgDelegateAllocationsResponse) Size 

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

func (*MsgDelegateAllocationsResponse) String 

func (m *MsgDelegateAllocationsResponse) String() string

func (*MsgDelegateAllocationsResponse) Unmarshal 

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

func (*MsgDelegateAllocationsResponse) XXX_DiscardUnknown 

func (m *MsgDelegateAllocationsResponse) XXX_DiscardUnknown()

func (*MsgDelegateAllocationsResponse) XXX_Marshal 

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

func (*MsgDelegateAllocationsResponse) XXX_Merge 

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

func (*MsgDelegateAllocationsResponse) XXX_Size 

func (m *MsgDelegateAllocationsResponse) XXX_Size() int

func (*MsgDelegateAllocationsResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	// DelegateAllocations defines a message that delegates the allocating to an account address.
	DelegateAllocations(context.Context, *MsgDelegateAllocations) (*MsgDelegateAllocationsResponse, error)
	// OracleDataPrevote defines a message that commits a hash of a oracle data feed before the data is actually submitted.
	AllocationPrecommit(context.Context, *MsgAllocationPrecommit) (*MsgAllocationPrecommitResponse, error)
	// OracleDataVote defines a message to submit the actual oracle data that was committed by the feeder through the prevote.
	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 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/QueryallocationDataPrevote 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 QueryClient 

type QueryClient interface {
	// QueryParams queries the allocation module parameters.
	QueryParams(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	// QueryDelegateAddress queries the delegate account address of a validator
	QueryDelegateAddress(ctx context.Context, in *QueryDelegateAddressRequest, opts ...grpc.CallOption) (*QueryDelegateAddressResponse, error)
	// QueryValidatorAddress returns the validator address of a given delegate
	QueryValidatorAddress(ctx context.Context, in *QueryValidatorAddressRequest, opts ...grpc.CallOption) (*QueryValidatorAddressResponse, error)
	// QueryAllocationPrecommit queries the validator prevote in the current voting period
	QueryAllocationPrecommit(ctx context.Context, in *QueryAllocationPrecommitRequest, opts ...grpc.CallOption) (*QueryAllocationPrecommitResponse, error)
	// QueryAllocationCommit queries the validator vote in the current voting period
	QueryAllocationCommit(ctx context.Context, in *QueryAllocationCommitRequest, opts ...grpc.CallOption) (*QueryAllocationCommitResponse, 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)
}

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/VotePeriod 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/VotePeriod 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 QueryDelegateAddressRequest 

type QueryDelegateAddressRequest struct {
	// validator operator address
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
}

QueryDelegateAddressRequest is the request type for the Query/QueryDelegateAddress gRPC method.

func (*QueryDelegateAddressRequest) Descriptor 

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

func (*QueryDelegateAddressRequest) GetValidator 

func (m *QueryDelegateAddressRequest) GetValidator() string

func (*QueryDelegateAddressRequest) Marshal 

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

func (*QueryDelegateAddressRequest) MarshalTo 

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

func (*QueryDelegateAddressRequest) MarshalToSizedBuffer 

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

func (*QueryDelegateAddressRequest) ProtoMessage 

func (*QueryDelegateAddressRequest) ProtoMessage()

func (*QueryDelegateAddressRequest) Reset 

func (m *QueryDelegateAddressRequest) Reset()

func (*QueryDelegateAddressRequest) Size 

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

func (*QueryDelegateAddressRequest) String 

func (m *QueryDelegateAddressRequest) String() string

func (*QueryDelegateAddressRequest) Unmarshal 

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

func (*QueryDelegateAddressRequest) XXX_DiscardUnknown 

func (m *QueryDelegateAddressRequest) XXX_DiscardUnknown()

func (*QueryDelegateAddressRequest) XXX_Marshal 

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

func (*QueryDelegateAddressRequest) XXX_Merge 

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

func (*QueryDelegateAddressRequest) XXX_Size 

func (m *QueryDelegateAddressRequest) XXX_Size() int

func (*QueryDelegateAddressRequest) XXX_Unmarshal 

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

type QueryDelegateAddressResponse 

type QueryDelegateAddressResponse struct {
	// delegate account address
	Delegate string `protobuf:"bytes,2,opt,name=delegate,proto3" json:"delegate,omitempty"`
}

QueryDelegateAddressResponse is the response type for the Query/QueryDelegateAddress gRPC method.

func (*QueryDelegateAddressResponse) Descriptor 

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

func (*QueryDelegateAddressResponse) GetDelegate 

func (m *QueryDelegateAddressResponse) GetDelegate() string

func (*QueryDelegateAddressResponse) Marshal 

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

func (*QueryDelegateAddressResponse) MarshalTo 

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

func (*QueryDelegateAddressResponse) MarshalToSizedBuffer 

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

func (*QueryDelegateAddressResponse) ProtoMessage 

func (*QueryDelegateAddressResponse) ProtoMessage()

func (*QueryDelegateAddressResponse) Reset 

func (m *QueryDelegateAddressResponse) Reset()

func (*QueryDelegateAddressResponse) Size 

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

func (*QueryDelegateAddressResponse) String 

func (m *QueryDelegateAddressResponse) String() string

func (*QueryDelegateAddressResponse) Unmarshal 

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

func (*QueryDelegateAddressResponse) XXX_DiscardUnknown 

func (m *QueryDelegateAddressResponse) XXX_DiscardUnknown()

func (*QueryDelegateAddressResponse) XXX_Marshal 

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

func (*QueryDelegateAddressResponse) XXX_Merge 

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

func (*QueryDelegateAddressResponse) XXX_Size 

func (m *QueryDelegateAddressResponse) XXX_Size() int

func (*QueryDelegateAddressResponse) XXX_Unmarshal 

func (m *QueryDelegateAddressResponse) 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)
	// QueryDelegateAddress queries the delegate account address of a validator
	QueryDelegateAddress(context.Context, *QueryDelegateAddressRequest) (*QueryDelegateAddressResponse, error)
	// QueryValidatorAddress returns the validator address of a given delegate
	QueryValidatorAddress(context.Context, *QueryValidatorAddressRequest) (*QueryValidatorAddressResponse, error)
	// QueryAllocationPrecommit queries the validator prevote in the current voting period
	QueryAllocationPrecommit(context.Context, *QueryAllocationPrecommitRequest) (*QueryAllocationPrecommitResponse, error)
	// QueryAllocationCommit queries the validator vote in the current voting period
	QueryAllocationCommit(context.Context, *QueryAllocationCommitRequest) (*QueryAllocationCommitResponse, error)
	// QueryVotePeriod queries the heights for the current voting period (current, start and end)
	QueryCommitPeriod(context.Context, *QueryCommitPeriodRequest) (*QueryCommitPeriodResponse, error)
}

QueryServer is the server API for Query service.

type QueryValidatorAddressRequest 

type QueryValidatorAddressRequest struct {
	// delegate account address
	Delegate string `protobuf:"bytes,1,opt,name=delegate,proto3" json:"delegate,omitempty"`
}

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

func (*QueryValidatorAddressRequest) Descriptor 

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

func (*QueryValidatorAddressRequest) GetDelegate 

func (m *QueryValidatorAddressRequest) GetDelegate() string

func (*QueryValidatorAddressRequest) Marshal 

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

func (*QueryValidatorAddressRequest) MarshalTo 

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

func (*QueryValidatorAddressRequest) MarshalToSizedBuffer 

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

func (*QueryValidatorAddressRequest) ProtoMessage 

func (*QueryValidatorAddressRequest) ProtoMessage()

func (*QueryValidatorAddressRequest) Reset 

func (m *QueryValidatorAddressRequest) Reset()

func (*QueryValidatorAddressRequest) Size 

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

func (*QueryValidatorAddressRequest) String 

func (m *QueryValidatorAddressRequest) String() string

func (*QueryValidatorAddressRequest) Unmarshal 

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

func (*QueryValidatorAddressRequest) XXX_DiscardUnknown 

func (m *QueryValidatorAddressRequest) XXX_DiscardUnknown()

func (*QueryValidatorAddressRequest) XXX_Marshal 

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

func (*QueryValidatorAddressRequest) XXX_Merge 

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

func (*QueryValidatorAddressRequest) XXX_Size 

func (m *QueryValidatorAddressRequest) XXX_Size() int

func (*QueryValidatorAddressRequest) XXX_Unmarshal 

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

type QueryValidatorAddressResponse 

type QueryValidatorAddressResponse struct {
	// validator operator address
	Validator string `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator,omitempty"`
}

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

func (*QueryValidatorAddressResponse) Descriptor 

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

func (*QueryValidatorAddressResponse) GetValidator 

func (m *QueryValidatorAddressResponse) GetValidator() string

func (*QueryValidatorAddressResponse) Marshal 

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

func (*QueryValidatorAddressResponse) MarshalTo 

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

func (*QueryValidatorAddressResponse) MarshalToSizedBuffer 

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

func (*QueryValidatorAddressResponse) ProtoMessage 

func (*QueryValidatorAddressResponse) ProtoMessage()

func (*QueryValidatorAddressResponse) Reset 

func (m *QueryValidatorAddressResponse) Reset()

func (*QueryValidatorAddressResponse) Size 

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

func (*QueryValidatorAddressResponse) String 

func (m *QueryValidatorAddressResponse) String() string

func (*QueryValidatorAddressResponse) Unmarshal 

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

func (*QueryValidatorAddressResponse) XXX_DiscardUnknown 

func (m *QueryValidatorAddressResponse) XXX_DiscardUnknown()

func (*QueryValidatorAddressResponse) XXX_Marshal 

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

func (*QueryValidatorAddressResponse) XXX_Merge 

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

func (*QueryValidatorAddressResponse) XXX_Size 

func (m *QueryValidatorAddressResponse) XXX_Size() int

func (*QueryValidatorAddressResponse) XXX_Unmarshal 

func (m *QueryValidatorAddressResponse) 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  uint64 `protobuf:"varint,1,opt,name=upper,proto3" json:"upper,omitempty"`
	Lower  uint64 `protobuf:"varint,2,opt,name=lower,proto3" json:"lower,omitempty"`
	Weight uint64 `protobuf:"varint,3,opt,name=weight,proto3" json:"weight,omitempty"`
}

func (*TickRange) Descriptor 

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

func (*TickRange) GetLower 

func (m *TickRange) GetLower() uint64

func (*TickRange) GetUpper 

func (m *TickRange) GetUpper() uint64

func (*TickRange) GetWeight 

func (m *TickRange) GetWeight() uint64

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)

func (*UnimplementedMsgServer) DelegateAllocations 

func (*UnimplementedMsgServer) DelegateAllocations(ctx context.Context, req *MsgDelegateAllocations) (*MsgDelegateAllocationsResponse, 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) QueryAllocationPrecommit 

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

func (*UnimplementedQueryServer) QueryCommitPeriod 

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

func (*UnimplementedQueryServer) QueryDelegateAddress 

func (*UnimplementedQueryServer) QueryDelegateAddress(ctx context.Context, req *QueryDelegateAddressRequest) (*QueryDelegateAddressResponse, error)

func (*UnimplementedQueryServer) QueryParams 

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

func (*UnimplementedQueryServer) QueryValidatorAddress 

func (*UnimplementedQueryServer) QueryValidatorAddress(ctx context.Context, req *QueryValidatorAddressRequest) (*QueryValidatorAddressResponse, 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.