types

package
v1.0.0-rc1 Latest Latest
Warning

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

Go to latest
Published: Mar 7, 2023 License: MIT Imports: 30 Imported by: 8

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source
const (
	// ModuleName defines the module name
	ModuleName = "query"

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

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

	// MemStoreKey defines the in-memory store key
	MemStoreKey = "mem_query"
)

Variables

View Source
var (
	ErrInvalidLengthAccount        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowAccount          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupAccount = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthBundles        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBundles          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBundles = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthDelegation        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDelegation          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDelegation = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthParams        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowParams          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupParams = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthPools        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPools          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupPools = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source
var (
	ErrInvalidLengthStakers        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStakers          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStakers = fmt.Errorf("proto: unexpected end of group")
)
View Source
var StakerStatus_name = map[int32]string{
	0: "STAKER_STATUS_UNSPECIFIED",
	1: "STAKER_STATUS_ACTIVE",
	2: "STAKER_STATUS_INACTIVE",
}
View Source
var StakerStatus_value = map[string]int32{
	"STAKER_STATUS_UNSPECIFIED": 0,
	"STAKER_STATUS_ACTIVE":      1,
	"STAKER_STATUS_INACTIVE":    2,
}

Functions

func KeyPrefix

func KeyPrefix(p string) []byte

func RegisterQueryAccountHandler

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

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

func RegisterQueryAccountHandlerClient

func RegisterQueryAccountHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryAccountClient) error

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

func RegisterQueryAccountHandlerFromEndpoint

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

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

func RegisterQueryAccountHandlerServer

func RegisterQueryAccountHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryAccountServer) error

RegisterQueryAccountHandlerServer registers the http handlers for service QueryAccount to "mux". UnaryRPC :call QueryAccountServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryAccountHandlerFromEndpoint instead.

func RegisterQueryAccountServer

func RegisterQueryAccountServer(s grpc1.Server, srv QueryAccountServer)

func RegisterQueryBundlesHandler

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

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

func RegisterQueryBundlesHandlerClient

func RegisterQueryBundlesHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryBundlesClient) error

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

func RegisterQueryBundlesHandlerFromEndpoint

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

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

func RegisterQueryBundlesHandlerServer

func RegisterQueryBundlesHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryBundlesServer) error

RegisterQueryBundlesHandlerServer registers the http handlers for service QueryBundles to "mux". UnaryRPC :call QueryBundlesServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryBundlesHandlerFromEndpoint instead.

func RegisterQueryBundlesServer

func RegisterQueryBundlesServer(s grpc1.Server, srv QueryBundlesServer)

func RegisterQueryDelegationHandler

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

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

func RegisterQueryDelegationHandlerClient

func RegisterQueryDelegationHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryDelegationClient) error

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

func RegisterQueryDelegationHandlerFromEndpoint

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

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

func RegisterQueryDelegationHandlerServer

func RegisterQueryDelegationHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryDelegationServer) error

RegisterQueryDelegationHandlerServer registers the http handlers for service QueryDelegation to "mux". UnaryRPC :call QueryDelegationServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryDelegationHandlerFromEndpoint instead.

func RegisterQueryDelegationServer

func RegisterQueryDelegationServer(s grpc1.Server, srv QueryDelegationServer)

func RegisterQueryParamsHandler

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

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

func RegisterQueryParamsHandlerClient

func RegisterQueryParamsHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryParamsClient) error

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

func RegisterQueryParamsHandlerFromEndpoint

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

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

func RegisterQueryParamsHandlerServer

func RegisterQueryParamsHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryParamsServer) error

RegisterQueryParamsHandlerServer registers the http handlers for service QueryParams to "mux". UnaryRPC :call QueryParamsServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryParamsHandlerFromEndpoint instead.

func RegisterQueryParamsServer

func RegisterQueryParamsServer(s grpc1.Server, srv QueryParamsServer)

func RegisterQueryPoolHandler

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

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

func RegisterQueryPoolHandlerClient

func RegisterQueryPoolHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryPoolClient) error

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

func RegisterQueryPoolHandlerFromEndpoint

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

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

func RegisterQueryPoolHandlerServer

func RegisterQueryPoolHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryPoolServer) error

RegisterQueryPoolHandlerServer registers the http handlers for service QueryPool to "mux". UnaryRPC :call QueryPoolServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryPoolHandlerFromEndpoint instead.

func RegisterQueryPoolServer

func RegisterQueryPoolServer(s grpc1.Server, srv QueryPoolServer)

func RegisterQueryStakersHandler

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

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

func RegisterQueryStakersHandlerClient

func RegisterQueryStakersHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryStakersClient) error

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

func RegisterQueryStakersHandlerFromEndpoint

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

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

func RegisterQueryStakersHandlerServer

func RegisterQueryStakersHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryStakersServer) error

RegisterQueryStakersHandlerServer registers the http handlers for service QueryStakers to "mux". UnaryRPC :call QueryStakersServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryStakersHandlerFromEndpoint instead.

func RegisterQueryStakersServer

func RegisterQueryStakersServer(s grpc1.Server, srv QueryStakersServer)

Types

type AccountKeeper

type AccountKeeper interface {
	GetAccount(ctx sdk.Context, addr sdk.AccAddress) types.AccountI
}

AccountKeeper defines the expected account keeper used for simulations (noalias)

type BankKeeper

type BankKeeper interface {
	SpendableCoins(ctx sdk.Context, addr sdk.AccAddress) sdk.Coins
}

BankKeeper defines the expected interface needed to retrieve account balances.

type BasicPool

type BasicPool struct {
	// id is the ID of the pool
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// name of the pool
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// runtime for the protocol nodes
	// like evm, bitcoin, etc.
	Runtime string `protobuf:"bytes,3,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Logo string `protobuf:"bytes,4,opt,name=logo,proto3" json:"logo,omitempty"`
	// operating_cost is the base payout for each bundle reward
	OperatingCost uint64 `protobuf:"varint,5,opt,name=operating_cost,json=operatingCost,proto3" json:"operating_cost,omitempty"`
	// upload_interval is the interval bundles get created
	UploadInterval uint64 `protobuf:"varint,6,opt,name=upload_interval,json=uploadInterval,proto3" json:"upload_interval,omitempty"`
	// total_funds of the pool. If the pool runs
	// out of funds no more bundles will be produced
	TotalFunds uint64 `protobuf:"varint,7,opt,name=total_funds,json=totalFunds,proto3" json:"total_funds,omitempty"`
	// total_delegation of the pool
	TotalDelegation uint64 `protobuf:"varint,8,opt,name=total_delegation,json=totalDelegation,proto3" json:"total_delegation,omitempty"`
	// status of the pool if pool is able
	// to produce bundles, etc.
	Status types.PoolStatus `protobuf:"varint,9,opt,name=status,proto3,enum=kyve.pool.v1beta1.PoolStatus" json:"status,omitempty"`
}

BasicPool contains the necessary properties need for a pool to be displayed in the UI

func (*BasicPool) Descriptor

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

func (*BasicPool) GetId

func (m *BasicPool) GetId() uint64
func (m *BasicPool) GetLogo() string

func (*BasicPool) GetName

func (m *BasicPool) GetName() string

func (*BasicPool) GetOperatingCost

func (m *BasicPool) GetOperatingCost() uint64

func (*BasicPool) GetRuntime

func (m *BasicPool) GetRuntime() string

func (*BasicPool) GetStatus

func (m *BasicPool) GetStatus() types.PoolStatus

func (*BasicPool) GetTotalDelegation

func (m *BasicPool) GetTotalDelegation() uint64

func (*BasicPool) GetTotalFunds

func (m *BasicPool) GetTotalFunds() uint64

func (*BasicPool) GetUploadInterval

func (m *BasicPool) GetUploadInterval() uint64

func (*BasicPool) Marshal

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

func (*BasicPool) MarshalTo

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

func (*BasicPool) MarshalToSizedBuffer

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

func (*BasicPool) ProtoMessage

func (*BasicPool) ProtoMessage()

func (*BasicPool) Reset

func (m *BasicPool) Reset()

func (*BasicPool) Size

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

func (*BasicPool) String

func (m *BasicPool) String() string

func (*BasicPool) Unmarshal

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

func (*BasicPool) XXX_DiscardUnknown

func (m *BasicPool) XXX_DiscardUnknown()

func (*BasicPool) XXX_Marshal

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

func (*BasicPool) XXX_Merge

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

func (*BasicPool) XXX_Size

func (m *BasicPool) XXX_Size() int

func (*BasicPool) XXX_Unmarshal

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

type CommissionChangeEntry

type CommissionChangeEntry struct {
	// commission is the new commission that will
	// become active once the change-time is over
	Commission string `protobuf:"bytes,1,opt,name=commission,proto3" json:"commission,omitempty"`
	// creation_date is the UNIX-timestamp (in seconds)
	// of when the entry was created.
	CreationDate int64 `protobuf:"varint,2,opt,name=creation_date,json=creationDate,proto3" json:"creation_date,omitempty"`
}

CommissionChangeEntry shows when the old commission of a staker will change to the new commission

func (*CommissionChangeEntry) Descriptor

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

func (*CommissionChangeEntry) GetCommission

func (m *CommissionChangeEntry) GetCommission() string

func (*CommissionChangeEntry) GetCreationDate

func (m *CommissionChangeEntry) GetCreationDate() int64

func (*CommissionChangeEntry) Marshal

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

func (*CommissionChangeEntry) MarshalTo

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

func (*CommissionChangeEntry) MarshalToSizedBuffer

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

func (*CommissionChangeEntry) ProtoMessage

func (*CommissionChangeEntry) ProtoMessage()

func (*CommissionChangeEntry) Reset

func (m *CommissionChangeEntry) Reset()

func (*CommissionChangeEntry) Size

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

func (*CommissionChangeEntry) String

func (m *CommissionChangeEntry) String() string

func (*CommissionChangeEntry) Unmarshal

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

func (*CommissionChangeEntry) XXX_DiscardUnknown

func (m *CommissionChangeEntry) XXX_DiscardUnknown()

func (*CommissionChangeEntry) XXX_Marshal

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

func (*CommissionChangeEntry) XXX_Merge

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

func (*CommissionChangeEntry) XXX_Size

func (m *CommissionChangeEntry) XXX_Size() int

func (*CommissionChangeEntry) XXX_Unmarshal

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

type DelegationForStakerResponse

type DelegationForStakerResponse struct {
	// staker ...
	Staker *FullStaker `protobuf:"bytes,1,opt,name=staker,proto3" json:"staker,omitempty"`
	// current_reward ...
	CurrentReward uint64 `protobuf:"varint,2,opt,name=current_reward,json=currentReward,proto3" json:"current_reward,omitempty"`
	// delegation_amount ...
	DelegationAmount uint64 `protobuf:"varint,3,opt,name=delegation_amount,json=delegationAmount,proto3" json:"delegation_amount,omitempty"`
}

DelegationForStakerResponse ...

func (*DelegationForStakerResponse) Descriptor

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

func (*DelegationForStakerResponse) GetCurrentReward

func (m *DelegationForStakerResponse) GetCurrentReward() uint64

func (*DelegationForStakerResponse) GetDelegationAmount

func (m *DelegationForStakerResponse) GetDelegationAmount() uint64

func (*DelegationForStakerResponse) GetStaker

func (m *DelegationForStakerResponse) GetStaker() *FullStaker

func (*DelegationForStakerResponse) Marshal

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

func (*DelegationForStakerResponse) MarshalTo

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

func (*DelegationForStakerResponse) MarshalToSizedBuffer

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

func (*DelegationForStakerResponse) ProtoMessage

func (*DelegationForStakerResponse) ProtoMessage()

func (*DelegationForStakerResponse) Reset

func (m *DelegationForStakerResponse) Reset()

func (*DelegationForStakerResponse) Size

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

func (*DelegationForStakerResponse) String

func (m *DelegationForStakerResponse) String() string

func (*DelegationForStakerResponse) Unmarshal

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

func (*DelegationForStakerResponse) XXX_DiscardUnknown

func (m *DelegationForStakerResponse) XXX_DiscardUnknown()

func (*DelegationForStakerResponse) XXX_Marshal

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

func (*DelegationForStakerResponse) XXX_Merge

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

func (*DelegationForStakerResponse) XXX_Size

func (m *DelegationForStakerResponse) XXX_Size() int

func (*DelegationForStakerResponse) XXX_Unmarshal

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

type DelegationUnbonding

type DelegationUnbonding struct {
	// amount
	Amount uint64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"`
	// creation_time
	CreationTime uint64 `protobuf:"varint,2,opt,name=creation_time,json=creationTime,proto3" json:"creation_time,omitempty"`
	// staker
	Staker *FullStaker `protobuf:"bytes,3,opt,name=staker,proto3" json:"staker,omitempty"`
}

QueryAccountAssetsResponse is the response type for the Query/AccountAssets RPC method.

func (*DelegationUnbonding) Descriptor

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

func (*DelegationUnbonding) GetAmount

func (m *DelegationUnbonding) GetAmount() uint64

func (*DelegationUnbonding) GetCreationTime

func (m *DelegationUnbonding) GetCreationTime() uint64

func (*DelegationUnbonding) GetStaker

func (m *DelegationUnbonding) GetStaker() *FullStaker

func (*DelegationUnbonding) Marshal

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

func (*DelegationUnbonding) MarshalTo

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

func (*DelegationUnbonding) MarshalToSizedBuffer

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

func (*DelegationUnbonding) ProtoMessage

func (*DelegationUnbonding) ProtoMessage()

func (*DelegationUnbonding) Reset

func (m *DelegationUnbonding) Reset()

func (*DelegationUnbonding) Size

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

func (*DelegationUnbonding) String

func (m *DelegationUnbonding) String() string

func (*DelegationUnbonding) Unmarshal

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

func (*DelegationUnbonding) XXX_DiscardUnknown

func (m *DelegationUnbonding) XXX_DiscardUnknown()

func (*DelegationUnbonding) XXX_Marshal

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

func (*DelegationUnbonding) XXX_Merge

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

func (*DelegationUnbonding) XXX_Size

func (m *DelegationUnbonding) XXX_Size() int

func (*DelegationUnbonding) XXX_Unmarshal

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

type FullStaker

type FullStaker struct {
	// address of the staker
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// metadata as logo, moniker, etc.
	Metadata *StakerMetadata `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// amount the staker has delegated to himself
	SelfDelegation uint64 `protobuf:"varint,3,opt,name=self_delegation,json=selfDelegation,proto3" json:"self_delegation,omitempty"`
	// unbonding_amount is the amount the staker is currently unbonding
	// from the self-delegation.
	// This amount can be larger than `amount` when the staker
	// got slashed during unbonding. However, at the end of
	// the unbonding period this amount is double checked with the
	// remaining amount.
	SelfDelegationUnbonding uint64 `` /* 133-byte string literal not displayed */
	// total_delegation returns the sum of all $KYVE users
	// have delegated to this staker
	TotalDelegation uint64 `protobuf:"varint,5,opt,name=total_delegation,json=totalDelegation,proto3" json:"total_delegation,omitempty"`
	// delegator_count is the total number of individual
	// delegator addresses for that user.
	DelegatorCount uint64 `protobuf:"varint,6,opt,name=delegator_count,json=delegatorCount,proto3" json:"delegator_count,omitempty"`
	// pools is a list of all pools the staker is currently
	// participating, i.e. allowed to vote and upload data.
	Pools []*PoolMembership `protobuf:"bytes,7,rep,name=pools,proto3" json:"pools,omitempty"`
}

FullStaker aggregates information from the staker and its delegators as well as pending queue entries into one object. It contains almost all needed information for a convenient usage

func (*FullStaker) Descriptor

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

func (*FullStaker) GetAddress

func (m *FullStaker) GetAddress() string

func (*FullStaker) GetDelegatorCount

func (m *FullStaker) GetDelegatorCount() uint64

func (*FullStaker) GetMetadata

func (m *FullStaker) GetMetadata() *StakerMetadata

func (*FullStaker) GetPools

func (m *FullStaker) GetPools() []*PoolMembership

func (*FullStaker) GetSelfDelegation

func (m *FullStaker) GetSelfDelegation() uint64

func (*FullStaker) GetSelfDelegationUnbonding

func (m *FullStaker) GetSelfDelegationUnbonding() uint64

func (*FullStaker) GetTotalDelegation

func (m *FullStaker) GetTotalDelegation() uint64

func (*FullStaker) Marshal

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

func (*FullStaker) MarshalTo

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

func (*FullStaker) MarshalToSizedBuffer

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

func (*FullStaker) ProtoMessage

func (*FullStaker) ProtoMessage()

func (*FullStaker) Reset

func (m *FullStaker) Reset()

func (*FullStaker) Size

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

func (*FullStaker) String

func (m *FullStaker) String() string

func (*FullStaker) Unmarshal

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

func (*FullStaker) XXX_DiscardUnknown

func (m *FullStaker) XXX_DiscardUnknown()

func (*FullStaker) XXX_Marshal

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

func (*FullStaker) XXX_Merge

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

func (*FullStaker) XXX_Size

func (m *FullStaker) XXX_Size() int

func (*FullStaker) XXX_Unmarshal

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

type Funded

type Funded struct {
	// amount ...
	Amount uint64 `protobuf:"varint,1,opt,name=amount,proto3" json:"amount,omitempty"`
	// pool ...
	Pool *BasicPool `protobuf:"bytes,2,opt,name=pool,proto3" json:"pool,omitempty"`
}

Funded ...

func (*Funded) Descriptor

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

func (*Funded) GetAmount

func (m *Funded) GetAmount() uint64

func (*Funded) GetPool

func (m *Funded) GetPool() *BasicPool

func (*Funded) Marshal

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

func (*Funded) MarshalTo

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

func (*Funded) MarshalToSizedBuffer

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

func (*Funded) ProtoMessage

func (*Funded) ProtoMessage()

func (*Funded) Reset

func (m *Funded) Reset()

func (*Funded) Size

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

func (*Funded) String

func (m *Funded) String() string

func (*Funded) Unmarshal

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

func (*Funded) XXX_DiscardUnknown

func (m *Funded) XXX_DiscardUnknown()

func (*Funded) XXX_Marshal

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

func (*Funded) XXX_Merge

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

func (*Funded) XXX_Size

func (m *Funded) XXX_Size() int

func (*Funded) XXX_Unmarshal

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

type PoolMembership

type PoolMembership struct {
	// pool contains useful information about the pool
	Pool *BasicPool `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool,omitempty"`
	// points indicates if the staker is inactive
	// If the staker misses a vote, a point is added.
	// After 5 points the staker is removed from
	// the stakers set.
	Points uint64 `protobuf:"varint,2,opt,name=points,proto3" json:"points,omitempty"`
	// is_leaving indicates if a user has scheduled a
	// a PoolLeave entry. After the leave-time is over
	// the staker will no longer participate in that pool
	IsLeaving bool `protobuf:"varint,3,opt,name=is_leaving,json=isLeaving,proto3" json:"is_leaving,omitempty"`
	// Valaddress is the address which is authorized to vote
	// and submit bundles. If the server gets compromised
	// the staker can just change the valaddress.
	Valaddress string `protobuf:"bytes,4,opt,name=valaddress,proto3" json:"valaddress,omitempty"`
	// balance is the valaddress account balance and indicates
	// whether or not the valaccount needs additional funds to
	// pay for gas fees
	Balance uint64 `protobuf:"varint,5,opt,name=balance,proto3" json:"balance,omitempty"`
}

PoolMembership shows in which pool the staker is participating

func (*PoolMembership) Descriptor

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

func (*PoolMembership) GetBalance

func (m *PoolMembership) GetBalance() uint64

func (*PoolMembership) GetIsLeaving

func (m *PoolMembership) GetIsLeaving() bool

func (*PoolMembership) GetPoints

func (m *PoolMembership) GetPoints() uint64

func (*PoolMembership) GetPool

func (m *PoolMembership) GetPool() *BasicPool

func (*PoolMembership) GetValaddress

func (m *PoolMembership) GetValaddress() string

func (*PoolMembership) Marshal

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

func (*PoolMembership) MarshalTo

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

func (*PoolMembership) MarshalToSizedBuffer

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

func (*PoolMembership) ProtoMessage

func (*PoolMembership) ProtoMessage()

func (*PoolMembership) Reset

func (m *PoolMembership) Reset()

func (*PoolMembership) Size

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

func (*PoolMembership) String

func (m *PoolMembership) String() string

func (*PoolMembership) Unmarshal

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

func (*PoolMembership) XXX_DiscardUnknown

func (m *PoolMembership) XXX_DiscardUnknown()

func (*PoolMembership) XXX_Marshal

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

func (*PoolMembership) XXX_Merge

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

func (*PoolMembership) XXX_Size

func (m *PoolMembership) XXX_Size() int

func (*PoolMembership) XXX_Unmarshal

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

type PoolResponse

type PoolResponse struct {
	// id ...
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// data ...
	Data *types.Pool `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// bundle_proposal ...
	BundleProposal *types1.BundleProposal `protobuf:"bytes,3,opt,name=bundle_proposal,json=bundleProposal,proto3" json:"bundle_proposal,omitempty"`
	// stakers ...
	Stakers []string `protobuf:"bytes,4,rep,name=stakers,proto3" json:"stakers,omitempty"`
	// total_stake ...
	TotalSelfDelegation uint64 `protobuf:"varint,5,opt,name=total_self_delegation,json=totalSelfDelegation,proto3" json:"total_self_delegation,omitempty"`
	// total_delegation ...
	TotalDelegation uint64 `protobuf:"varint,6,opt,name=total_delegation,json=totalDelegation,proto3" json:"total_delegation,omitempty"`
	// status ...
	Status types.PoolStatus `protobuf:"varint,7,opt,name=status,proto3,enum=kyve.pool.v1beta1.PoolStatus" json:"status,omitempty"`
}

PoolResponse ...

func (*PoolResponse) Descriptor

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

func (*PoolResponse) GetBundleProposal

func (m *PoolResponse) GetBundleProposal() *types1.BundleProposal

func (*PoolResponse) GetData

func (m *PoolResponse) GetData() *types.Pool

func (*PoolResponse) GetId

func (m *PoolResponse) GetId() uint64

func (*PoolResponse) GetStakers

func (m *PoolResponse) GetStakers() []string

func (*PoolResponse) GetStatus

func (m *PoolResponse) GetStatus() types.PoolStatus

func (*PoolResponse) GetTotalDelegation

func (m *PoolResponse) GetTotalDelegation() uint64

func (*PoolResponse) GetTotalSelfDelegation

func (m *PoolResponse) GetTotalSelfDelegation() uint64

func (*PoolResponse) Marshal

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

func (*PoolResponse) MarshalTo

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

func (*PoolResponse) MarshalToSizedBuffer

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

func (*PoolResponse) ProtoMessage

func (*PoolResponse) ProtoMessage()

func (*PoolResponse) Reset

func (m *PoolResponse) Reset()

func (*PoolResponse) Size

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

func (*PoolResponse) String

func (m *PoolResponse) String() string

func (*PoolResponse) Unmarshal

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

func (*PoolResponse) XXX_DiscardUnknown

func (m *PoolResponse) XXX_DiscardUnknown()

func (*PoolResponse) XXX_Marshal

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

func (*PoolResponse) XXX_Merge

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

func (*PoolResponse) XXX_Size

func (m *PoolResponse) XXX_Size() int

func (*PoolResponse) XXX_Unmarshal

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

type QueryAccountAssetsRequest

type QueryAccountAssetsRequest struct {
	// address ...
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

QueryAccountAssetsRequest is the request type for the Query/AccountAssets RPC method.

func (*QueryAccountAssetsRequest) Descriptor

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

func (*QueryAccountAssetsRequest) GetAddress

func (m *QueryAccountAssetsRequest) GetAddress() string

func (*QueryAccountAssetsRequest) Marshal

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

func (*QueryAccountAssetsRequest) MarshalTo

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

func (*QueryAccountAssetsRequest) MarshalToSizedBuffer

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

func (*QueryAccountAssetsRequest) ProtoMessage

func (*QueryAccountAssetsRequest) ProtoMessage()

func (*QueryAccountAssetsRequest) Reset

func (m *QueryAccountAssetsRequest) Reset()

func (*QueryAccountAssetsRequest) Size

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

func (*QueryAccountAssetsRequest) String

func (m *QueryAccountAssetsRequest) String() string

func (*QueryAccountAssetsRequest) Unmarshal

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

func (*QueryAccountAssetsRequest) XXX_DiscardUnknown

func (m *QueryAccountAssetsRequest) XXX_DiscardUnknown()

func (*QueryAccountAssetsRequest) XXX_Marshal

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

func (*QueryAccountAssetsRequest) XXX_Merge

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

func (*QueryAccountAssetsRequest) XXX_Size

func (m *QueryAccountAssetsRequest) XXX_Size() int

func (*QueryAccountAssetsRequest) XXX_Unmarshal

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

type QueryAccountAssetsResponse

type QueryAccountAssetsResponse struct {
	// balance ...
	Balance uint64 `protobuf:"varint,1,opt,name=balance,proto3" json:"balance,omitempty"`
	// protocol_staking ...
	ProtocolSelfDelegation uint64 `` /* 130-byte string literal not displayed */
	// protocol_staking_unbonding
	ProtocolSelfDelegationUnbonding uint64 `` /* 159-byte string literal not displayed */
	// protocol_delegation ...
	ProtocolDelegation uint64 `protobuf:"varint,4,opt,name=protocol_delegation,json=protocolDelegation,proto3" json:"protocol_delegation,omitempty"`
	// protocol_delegation_unbonding
	ProtocolDelegationUnbonding uint64 `` /* 145-byte string literal not displayed */
	// protocol_rewards ...
	ProtocolRewards uint64 `protobuf:"varint,6,opt,name=protocol_rewards,json=protocolRewards,proto3" json:"protocol_rewards,omitempty"`
	// protocol_funding ...
	ProtocolFunding uint64 `protobuf:"varint,7,opt,name=protocol_funding,json=protocolFunding,proto3" json:"protocol_funding,omitempty"`
}

QueryAccountAssetsResponse is the response type for the Query/AccountAssets RPC method.

func (*QueryAccountAssetsResponse) Descriptor

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

func (*QueryAccountAssetsResponse) GetBalance

func (m *QueryAccountAssetsResponse) GetBalance() uint64

func (*QueryAccountAssetsResponse) GetProtocolDelegation

func (m *QueryAccountAssetsResponse) GetProtocolDelegation() uint64

func (*QueryAccountAssetsResponse) GetProtocolDelegationUnbonding

func (m *QueryAccountAssetsResponse) GetProtocolDelegationUnbonding() uint64

func (*QueryAccountAssetsResponse) GetProtocolFunding

func (m *QueryAccountAssetsResponse) GetProtocolFunding() uint64

func (*QueryAccountAssetsResponse) GetProtocolRewards

func (m *QueryAccountAssetsResponse) GetProtocolRewards() uint64

func (*QueryAccountAssetsResponse) GetProtocolSelfDelegation

func (m *QueryAccountAssetsResponse) GetProtocolSelfDelegation() uint64

func (*QueryAccountAssetsResponse) GetProtocolSelfDelegationUnbonding

func (m *QueryAccountAssetsResponse) GetProtocolSelfDelegationUnbonding() uint64

func (*QueryAccountAssetsResponse) Marshal

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

func (*QueryAccountAssetsResponse) MarshalTo

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

func (*QueryAccountAssetsResponse) MarshalToSizedBuffer

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

func (*QueryAccountAssetsResponse) ProtoMessage

func (*QueryAccountAssetsResponse) ProtoMessage()

func (*QueryAccountAssetsResponse) Reset

func (m *QueryAccountAssetsResponse) Reset()

func (*QueryAccountAssetsResponse) Size

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

func (*QueryAccountAssetsResponse) String

func (m *QueryAccountAssetsResponse) String() string

func (*QueryAccountAssetsResponse) Unmarshal

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

func (*QueryAccountAssetsResponse) XXX_DiscardUnknown

func (m *QueryAccountAssetsResponse) XXX_DiscardUnknown()

func (*QueryAccountAssetsResponse) XXX_Marshal

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

func (*QueryAccountAssetsResponse) XXX_Merge

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

func (*QueryAccountAssetsResponse) XXX_Size

func (m *QueryAccountAssetsResponse) XXX_Size() int

func (*QueryAccountAssetsResponse) XXX_Unmarshal

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

type QueryAccountClient

type QueryAccountClient interface {
	// AccountAssets returns an overview of the sum of all balances for a given user. e.g. balance, staking, funding, etc.
	AccountAssets(ctx context.Context, in *QueryAccountAssetsRequest, opts ...grpc.CallOption) (*QueryAccountAssetsResponse, error)
	// AccountDelegationUnbondings ...
	AccountDelegationUnbondings(ctx context.Context, in *QueryAccountDelegationUnbondingsRequest, opts ...grpc.CallOption) (*QueryAccountDelegationUnbondingsResponse, error)
	// AccountFundedList returns all pools the given user has funded into.
	AccountFundedList(ctx context.Context, in *QueryAccountFundedListRequest, opts ...grpc.CallOption) (*QueryAccountFundedListResponse, error)
	// AccountRedelegation ...
	AccountRedelegation(ctx context.Context, in *QueryAccountRedelegationRequest, opts ...grpc.CallOption) (*QueryAccountRedelegationResponse, error)
}

QueryAccountClient is the client API for QueryAccount service.

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

func NewQueryAccountClient

func NewQueryAccountClient(cc grpc1.ClientConn) QueryAccountClient

type QueryAccountDelegationUnbondingsRequest

type QueryAccountDelegationUnbondingsRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// address ...
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
}

QueryAccountFundedListRequest ...

func (*QueryAccountDelegationUnbondingsRequest) Descriptor

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

func (*QueryAccountDelegationUnbondingsRequest) GetAddress

func (*QueryAccountDelegationUnbondingsRequest) GetPagination

func (*QueryAccountDelegationUnbondingsRequest) Marshal

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

func (*QueryAccountDelegationUnbondingsRequest) MarshalTo

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

func (*QueryAccountDelegationUnbondingsRequest) MarshalToSizedBuffer

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

func (*QueryAccountDelegationUnbondingsRequest) ProtoMessage

func (*QueryAccountDelegationUnbondingsRequest) Reset

func (*QueryAccountDelegationUnbondingsRequest) Size

func (*QueryAccountDelegationUnbondingsRequest) String

func (*QueryAccountDelegationUnbondingsRequest) Unmarshal

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

func (*QueryAccountDelegationUnbondingsRequest) XXX_DiscardUnknown

func (m *QueryAccountDelegationUnbondingsRequest) XXX_DiscardUnknown()

func (*QueryAccountDelegationUnbondingsRequest) XXX_Marshal

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

func (*QueryAccountDelegationUnbondingsRequest) XXX_Merge

func (*QueryAccountDelegationUnbondingsRequest) XXX_Size

func (*QueryAccountDelegationUnbondingsRequest) XXX_Unmarshal

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

type QueryAccountDelegationUnbondingsResponse

type QueryAccountDelegationUnbondingsResponse struct {
	// balance ...
	Unbondings []DelegationUnbonding `protobuf:"bytes,1,rep,name=unbondings,proto3" json:"unbondings"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryAccountAssetsResponse is the response type for the Query/AccountAssets RPC method.

func (*QueryAccountDelegationUnbondingsResponse) Descriptor

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

func (*QueryAccountDelegationUnbondingsResponse) GetPagination

func (*QueryAccountDelegationUnbondingsResponse) GetUnbondings

func (*QueryAccountDelegationUnbondingsResponse) Marshal

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

func (*QueryAccountDelegationUnbondingsResponse) MarshalTo

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

func (*QueryAccountDelegationUnbondingsResponse) MarshalToSizedBuffer

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

func (*QueryAccountDelegationUnbondingsResponse) ProtoMessage

func (*QueryAccountDelegationUnbondingsResponse) Reset

func (*QueryAccountDelegationUnbondingsResponse) Size

func (*QueryAccountDelegationUnbondingsResponse) String

func (*QueryAccountDelegationUnbondingsResponse) Unmarshal

func (*QueryAccountDelegationUnbondingsResponse) XXX_DiscardUnknown

func (m *QueryAccountDelegationUnbondingsResponse) XXX_DiscardUnknown()

func (*QueryAccountDelegationUnbondingsResponse) XXX_Marshal

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

func (*QueryAccountDelegationUnbondingsResponse) XXX_Merge

func (*QueryAccountDelegationUnbondingsResponse) XXX_Size

func (*QueryAccountDelegationUnbondingsResponse) XXX_Unmarshal

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

type QueryAccountFundedListRequest

type QueryAccountFundedListRequest struct {
	// address ...
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

QueryAccountFundedListRequest is the request type for the account queries with pagination

func (*QueryAccountFundedListRequest) Descriptor

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

func (*QueryAccountFundedListRequest) GetAddress

func (m *QueryAccountFundedListRequest) GetAddress() string

func (*QueryAccountFundedListRequest) Marshal

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

func (*QueryAccountFundedListRequest) MarshalTo

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

func (*QueryAccountFundedListRequest) MarshalToSizedBuffer

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

func (*QueryAccountFundedListRequest) ProtoMessage

func (*QueryAccountFundedListRequest) ProtoMessage()

func (*QueryAccountFundedListRequest) Reset

func (m *QueryAccountFundedListRequest) Reset()

func (*QueryAccountFundedListRequest) Size

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

func (*QueryAccountFundedListRequest) String

func (*QueryAccountFundedListRequest) Unmarshal

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

func (*QueryAccountFundedListRequest) XXX_DiscardUnknown

func (m *QueryAccountFundedListRequest) XXX_DiscardUnknown()

func (*QueryAccountFundedListRequest) XXX_Marshal

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

func (*QueryAccountFundedListRequest) XXX_Merge

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

func (*QueryAccountFundedListRequest) XXX_Size

func (m *QueryAccountFundedListRequest) XXX_Size() int

func (*QueryAccountFundedListRequest) XXX_Unmarshal

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

type QueryAccountFundedListResponse

type QueryAccountFundedListResponse struct {
	// funded ...
	Funded []Funded `protobuf:"bytes,1,rep,name=funded,proto3" json:"funded"`
}

QueryAccountFundedListResponse is the response type for the Query/AccountFundedList RPC method.

func (*QueryAccountFundedListResponse) Descriptor

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

func (*QueryAccountFundedListResponse) GetFunded

func (m *QueryAccountFundedListResponse) GetFunded() []Funded

func (*QueryAccountFundedListResponse) Marshal

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

func (*QueryAccountFundedListResponse) MarshalTo

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

func (*QueryAccountFundedListResponse) MarshalToSizedBuffer

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

func (*QueryAccountFundedListResponse) ProtoMessage

func (*QueryAccountFundedListResponse) ProtoMessage()

func (*QueryAccountFundedListResponse) Reset

func (m *QueryAccountFundedListResponse) Reset()

func (*QueryAccountFundedListResponse) Size

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

func (*QueryAccountFundedListResponse) String

func (*QueryAccountFundedListResponse) Unmarshal

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

func (*QueryAccountFundedListResponse) XXX_DiscardUnknown

func (m *QueryAccountFundedListResponse) XXX_DiscardUnknown()

func (*QueryAccountFundedListResponse) XXX_Marshal

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

func (*QueryAccountFundedListResponse) XXX_Merge

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

func (*QueryAccountFundedListResponse) XXX_Size

func (m *QueryAccountFundedListResponse) XXX_Size() int

func (*QueryAccountFundedListResponse) XXX_Unmarshal

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

type QueryAccountRedelegationRequest

type QueryAccountRedelegationRequest struct {
	// address ...
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

QueryAccountDelegationListRequest ...

func (*QueryAccountRedelegationRequest) Descriptor

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

func (*QueryAccountRedelegationRequest) GetAddress

func (m *QueryAccountRedelegationRequest) GetAddress() string

func (*QueryAccountRedelegationRequest) Marshal

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

func (*QueryAccountRedelegationRequest) MarshalTo

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

func (*QueryAccountRedelegationRequest) MarshalToSizedBuffer

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

func (*QueryAccountRedelegationRequest) ProtoMessage

func (*QueryAccountRedelegationRequest) ProtoMessage()

func (*QueryAccountRedelegationRequest) Reset

func (*QueryAccountRedelegationRequest) Size

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

func (*QueryAccountRedelegationRequest) String

func (*QueryAccountRedelegationRequest) Unmarshal

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

func (*QueryAccountRedelegationRequest) XXX_DiscardUnknown

func (m *QueryAccountRedelegationRequest) XXX_DiscardUnknown()

func (*QueryAccountRedelegationRequest) XXX_Marshal

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

func (*QueryAccountRedelegationRequest) XXX_Merge

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

func (*QueryAccountRedelegationRequest) XXX_Size

func (m *QueryAccountRedelegationRequest) XXX_Size() int

func (*QueryAccountRedelegationRequest) XXX_Unmarshal

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

type QueryAccountRedelegationResponse

type QueryAccountRedelegationResponse struct {
	// redelegation_cooldown_entries ...
	RedelegationCooldownEntries []RedelegationEntry `` /* 134-byte string literal not displayed */
	// availableSlots ...
	AvailableSlots uint64 `protobuf:"varint,2,opt,name=available_slots,json=availableSlots,proto3" json:"available_slots,omitempty"`
}

QueryAccountDelegationListRequest is the response type for the Query/AccountDelegationList RPC method.

func (*QueryAccountRedelegationResponse) Descriptor

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

func (*QueryAccountRedelegationResponse) GetAvailableSlots

func (m *QueryAccountRedelegationResponse) GetAvailableSlots() uint64

func (*QueryAccountRedelegationResponse) GetRedelegationCooldownEntries

func (m *QueryAccountRedelegationResponse) GetRedelegationCooldownEntries() []RedelegationEntry

func (*QueryAccountRedelegationResponse) Marshal

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

func (*QueryAccountRedelegationResponse) MarshalTo

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

func (*QueryAccountRedelegationResponse) MarshalToSizedBuffer

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

func (*QueryAccountRedelegationResponse) ProtoMessage

func (*QueryAccountRedelegationResponse) ProtoMessage()

func (*QueryAccountRedelegationResponse) Reset

func (*QueryAccountRedelegationResponse) Size

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

func (*QueryAccountRedelegationResponse) String

func (*QueryAccountRedelegationResponse) Unmarshal

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

func (*QueryAccountRedelegationResponse) XXX_DiscardUnknown

func (m *QueryAccountRedelegationResponse) XXX_DiscardUnknown()

func (*QueryAccountRedelegationResponse) XXX_Marshal

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

func (*QueryAccountRedelegationResponse) XXX_Merge

func (*QueryAccountRedelegationResponse) XXX_Size

func (m *QueryAccountRedelegationResponse) XXX_Size() int

func (*QueryAccountRedelegationResponse) XXX_Unmarshal

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

type QueryAccountServer

type QueryAccountServer interface {
	// AccountAssets returns an overview of the sum of all balances for a given user. e.g. balance, staking, funding, etc.
	AccountAssets(context.Context, *QueryAccountAssetsRequest) (*QueryAccountAssetsResponse, error)
	// AccountDelegationUnbondings ...
	AccountDelegationUnbondings(context.Context, *QueryAccountDelegationUnbondingsRequest) (*QueryAccountDelegationUnbondingsResponse, error)
	// AccountFundedList returns all pools the given user has funded into.
	AccountFundedList(context.Context, *QueryAccountFundedListRequest) (*QueryAccountFundedListResponse, error)
	// AccountRedelegation ...
	AccountRedelegation(context.Context, *QueryAccountRedelegationRequest) (*QueryAccountRedelegationResponse, error)
}

QueryAccountServer is the server API for QueryAccount service.

type QueryBundlesClient

type QueryBundlesClient interface {
	// FinalizedBundles ...
	FinalizedBundles(ctx context.Context, in *QueryFinalizedBundlesRequest, opts ...grpc.CallOption) (*QueryFinalizedBundlesResponse, error)
	// FinalizedBundle ...
	FinalizedBundle(ctx context.Context, in *QueryFinalizedBundleRequest, opts ...grpc.CallOption) (*QueryFinalizedBundleResponse, error)
	// Queries the bundle which contains the data given height
	FinalizedBundlesByHeight(ctx context.Context, in *QueryFinalizedBundlesByHeightRequest, opts ...grpc.CallOption) (*QueryFinalizedBundlesByHeightResponse, error)
	// CurrentVoteStatus ...
	CurrentVoteStatus(ctx context.Context, in *QueryCurrentVoteStatusRequest, opts ...grpc.CallOption) (*QueryCurrentVoteStatusResponse, error)
	// CanValidate ...
	CanValidate(ctx context.Context, in *QueryCanValidateRequest, opts ...grpc.CallOption) (*QueryCanValidateResponse, error)
	// CanPropose ...
	CanPropose(ctx context.Context, in *QueryCanProposeRequest, opts ...grpc.CallOption) (*QueryCanProposeResponse, error)
	// CanVote checks if voter on pool can still vote for the given bundle
	CanVote(ctx context.Context, in *QueryCanVoteRequest, opts ...grpc.CallOption) (*QueryCanVoteResponse, error)
}

QueryBundlesClient is the client API for QueryBundles service.

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

func NewQueryBundlesClient

func NewQueryBundlesClient(cc grpc1.ClientConn) QueryBundlesClient

type QueryBundlesServer

type QueryBundlesServer interface {
	// FinalizedBundles ...
	FinalizedBundles(context.Context, *QueryFinalizedBundlesRequest) (*QueryFinalizedBundlesResponse, error)
	// FinalizedBundle ...
	FinalizedBundle(context.Context, *QueryFinalizedBundleRequest) (*QueryFinalizedBundleResponse, error)
	// Queries the bundle which contains the data given height
	FinalizedBundlesByHeight(context.Context, *QueryFinalizedBundlesByHeightRequest) (*QueryFinalizedBundlesByHeightResponse, error)
	// CurrentVoteStatus ...
	CurrentVoteStatus(context.Context, *QueryCurrentVoteStatusRequest) (*QueryCurrentVoteStatusResponse, error)
	// CanValidate ...
	CanValidate(context.Context, *QueryCanValidateRequest) (*QueryCanValidateResponse, error)
	// CanPropose ...
	CanPropose(context.Context, *QueryCanProposeRequest) (*QueryCanProposeResponse, error)
	// CanVote checks if voter on pool can still vote for the given bundle
	CanVote(context.Context, *QueryCanVoteRequest) (*QueryCanVoteResponse, error)
}

QueryBundlesServer is the server API for QueryBundles service.

type QueryCanProposeRequest

type QueryCanProposeRequest struct {
	// pool_id defines the unique ID of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// staker ...
	Staker string `protobuf:"bytes,2,opt,name=staker,proto3" json:"staker,omitempty"`
	// proposer ...
	Proposer string `protobuf:"bytes,3,opt,name=proposer,proto3" json:"proposer,omitempty"`
	// from_index ...
	FromIndex uint64 `protobuf:"varint,4,opt,name=from_index,json=fromIndex,proto3" json:"from_index,omitempty"`
}

QueryCanProposeRequest is the request type for the Query/CanPropose RPC method.

func (*QueryCanProposeRequest) Descriptor

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

func (*QueryCanProposeRequest) GetFromIndex

func (m *QueryCanProposeRequest) GetFromIndex() uint64

func (*QueryCanProposeRequest) GetPoolId

func (m *QueryCanProposeRequest) GetPoolId() uint64

func (*QueryCanProposeRequest) GetProposer

func (m *QueryCanProposeRequest) GetProposer() string

func (*QueryCanProposeRequest) GetStaker

func (m *QueryCanProposeRequest) GetStaker() string

func (*QueryCanProposeRequest) Marshal

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

func (*QueryCanProposeRequest) MarshalTo

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

func (*QueryCanProposeRequest) MarshalToSizedBuffer

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

func (*QueryCanProposeRequest) ProtoMessage

func (*QueryCanProposeRequest) ProtoMessage()

func (*QueryCanProposeRequest) Reset

func (m *QueryCanProposeRequest) Reset()

func (*QueryCanProposeRequest) Size

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

func (*QueryCanProposeRequest) String

func (m *QueryCanProposeRequest) String() string

func (*QueryCanProposeRequest) Unmarshal

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

func (*QueryCanProposeRequest) XXX_DiscardUnknown

func (m *QueryCanProposeRequest) XXX_DiscardUnknown()

func (*QueryCanProposeRequest) XXX_Marshal

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

func (*QueryCanProposeRequest) XXX_Merge

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

func (*QueryCanProposeRequest) XXX_Size

func (m *QueryCanProposeRequest) XXX_Size() int

func (*QueryCanProposeRequest) XXX_Unmarshal

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

type QueryCanProposeResponse

type QueryCanProposeResponse struct {
	// possible ...
	Possible bool `protobuf:"varint,1,opt,name=possible,proto3" json:"possible,omitempty"`
	// reason ...
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
}

QueryCanProposeResponse is the response type for the Query/CanPropose RPC method.

func (*QueryCanProposeResponse) Descriptor

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

func (*QueryCanProposeResponse) GetPossible

func (m *QueryCanProposeResponse) GetPossible() bool

func (*QueryCanProposeResponse) GetReason

func (m *QueryCanProposeResponse) GetReason() string

func (*QueryCanProposeResponse) Marshal

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

func (*QueryCanProposeResponse) MarshalTo

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

func (*QueryCanProposeResponse) MarshalToSizedBuffer

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

func (*QueryCanProposeResponse) ProtoMessage

func (*QueryCanProposeResponse) ProtoMessage()

func (*QueryCanProposeResponse) Reset

func (m *QueryCanProposeResponse) Reset()

func (*QueryCanProposeResponse) Size

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

func (*QueryCanProposeResponse) String

func (m *QueryCanProposeResponse) String() string

func (*QueryCanProposeResponse) Unmarshal

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

func (*QueryCanProposeResponse) XXX_DiscardUnknown

func (m *QueryCanProposeResponse) XXX_DiscardUnknown()

func (*QueryCanProposeResponse) XXX_Marshal

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

func (*QueryCanProposeResponse) XXX_Merge

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

func (*QueryCanProposeResponse) XXX_Size

func (m *QueryCanProposeResponse) XXX_Size() int

func (*QueryCanProposeResponse) XXX_Unmarshal

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

type QueryCanValidateRequest

type QueryCanValidateRequest struct {
	// pool_id defines the unique ID of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// valaddress ...
	Valaddress string `protobuf:"bytes,2,opt,name=valaddress,proto3" json:"valaddress,omitempty"`
}

QueryCanProposeRequest is the request type for the Query/CanPropose RPC method.

func (*QueryCanValidateRequest) Descriptor

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

func (*QueryCanValidateRequest) GetPoolId

func (m *QueryCanValidateRequest) GetPoolId() uint64

func (*QueryCanValidateRequest) GetValaddress

func (m *QueryCanValidateRequest) GetValaddress() string

func (*QueryCanValidateRequest) Marshal

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

func (*QueryCanValidateRequest) MarshalTo

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

func (*QueryCanValidateRequest) MarshalToSizedBuffer

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

func (*QueryCanValidateRequest) ProtoMessage

func (*QueryCanValidateRequest) ProtoMessage()

func (*QueryCanValidateRequest) Reset

func (m *QueryCanValidateRequest) Reset()

func (*QueryCanValidateRequest) Size

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

func (*QueryCanValidateRequest) String

func (m *QueryCanValidateRequest) String() string

func (*QueryCanValidateRequest) Unmarshal

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

func (*QueryCanValidateRequest) XXX_DiscardUnknown

func (m *QueryCanValidateRequest) XXX_DiscardUnknown()

func (*QueryCanValidateRequest) XXX_Marshal

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

func (*QueryCanValidateRequest) XXX_Merge

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

func (*QueryCanValidateRequest) XXX_Size

func (m *QueryCanValidateRequest) XXX_Size() int

func (*QueryCanValidateRequest) XXX_Unmarshal

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

type QueryCanValidateResponse

type QueryCanValidateResponse struct {
	// possible ...
	Possible bool `protobuf:"varint,1,opt,name=possible,proto3" json:"possible,omitempty"`
	// reason ...
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
}

QueryCanProposeResponse is the response type for the Query/CanPropose RPC method.

func (*QueryCanValidateResponse) Descriptor

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

func (*QueryCanValidateResponse) GetPossible

func (m *QueryCanValidateResponse) GetPossible() bool

func (*QueryCanValidateResponse) GetReason

func (m *QueryCanValidateResponse) GetReason() string

func (*QueryCanValidateResponse) Marshal

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

func (*QueryCanValidateResponse) MarshalTo

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

func (*QueryCanValidateResponse) MarshalToSizedBuffer

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

func (*QueryCanValidateResponse) ProtoMessage

func (*QueryCanValidateResponse) ProtoMessage()

func (*QueryCanValidateResponse) Reset

func (m *QueryCanValidateResponse) Reset()

func (*QueryCanValidateResponse) Size

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

func (*QueryCanValidateResponse) String

func (m *QueryCanValidateResponse) String() string

func (*QueryCanValidateResponse) Unmarshal

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

func (*QueryCanValidateResponse) XXX_DiscardUnknown

func (m *QueryCanValidateResponse) XXX_DiscardUnknown()

func (*QueryCanValidateResponse) XXX_Marshal

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

func (*QueryCanValidateResponse) XXX_Merge

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

func (*QueryCanValidateResponse) XXX_Size

func (m *QueryCanValidateResponse) XXX_Size() int

func (*QueryCanValidateResponse) XXX_Unmarshal

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

type QueryCanVoteRequest

type QueryCanVoteRequest struct {
	// pool_id defines the unique ID of the pool.
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// staker ...
	Staker string `protobuf:"bytes,2,opt,name=staker,proto3" json:"staker,omitempty"`
	// voter ...
	Voter string `protobuf:"bytes,3,opt,name=voter,proto3" json:"voter,omitempty"`
	// storage_id ...
	StorageId string `protobuf:"bytes,4,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
}

QueryCanVoteRequest is the request type for the Query/CanVote RPC method.

func (*QueryCanVoteRequest) Descriptor

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

func (*QueryCanVoteRequest) GetPoolId

func (m *QueryCanVoteRequest) GetPoolId() uint64

func (*QueryCanVoteRequest) GetStaker

func (m *QueryCanVoteRequest) GetStaker() string

func (*QueryCanVoteRequest) GetStorageId

func (m *QueryCanVoteRequest) GetStorageId() string

func (*QueryCanVoteRequest) GetVoter

func (m *QueryCanVoteRequest) GetVoter() string

func (*QueryCanVoteRequest) Marshal

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

func (*QueryCanVoteRequest) MarshalTo

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

func (*QueryCanVoteRequest) MarshalToSizedBuffer

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

func (*QueryCanVoteRequest) ProtoMessage

func (*QueryCanVoteRequest) ProtoMessage()

func (*QueryCanVoteRequest) Reset

func (m *QueryCanVoteRequest) Reset()

func (*QueryCanVoteRequest) Size

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

func (*QueryCanVoteRequest) String

func (m *QueryCanVoteRequest) String() string

func (*QueryCanVoteRequest) Unmarshal

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

func (*QueryCanVoteRequest) XXX_DiscardUnknown

func (m *QueryCanVoteRequest) XXX_DiscardUnknown()

func (*QueryCanVoteRequest) XXX_Marshal

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

func (*QueryCanVoteRequest) XXX_Merge

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

func (*QueryCanVoteRequest) XXX_Size

func (m *QueryCanVoteRequest) XXX_Size() int

func (*QueryCanVoteRequest) XXX_Unmarshal

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

type QueryCanVoteResponse

type QueryCanVoteResponse struct {
	// possible ...
	Possible bool `protobuf:"varint,1,opt,name=possible,proto3" json:"possible,omitempty"`
	// reason ...
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
}

QueryCanVoteResponse is the response type for the Query/CanVote RPC method.

func (*QueryCanVoteResponse) Descriptor

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

func (*QueryCanVoteResponse) GetPossible

func (m *QueryCanVoteResponse) GetPossible() bool

func (*QueryCanVoteResponse) GetReason

func (m *QueryCanVoteResponse) GetReason() string

func (*QueryCanVoteResponse) Marshal

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

func (*QueryCanVoteResponse) MarshalTo

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

func (*QueryCanVoteResponse) MarshalToSizedBuffer

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

func (*QueryCanVoteResponse) ProtoMessage

func (*QueryCanVoteResponse) ProtoMessage()

func (*QueryCanVoteResponse) Reset

func (m *QueryCanVoteResponse) Reset()

func (*QueryCanVoteResponse) Size

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

func (*QueryCanVoteResponse) String

func (m *QueryCanVoteResponse) String() string

func (*QueryCanVoteResponse) Unmarshal

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

func (*QueryCanVoteResponse) XXX_DiscardUnknown

func (m *QueryCanVoteResponse) XXX_DiscardUnknown()

func (*QueryCanVoteResponse) XXX_Marshal

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

func (*QueryCanVoteResponse) XXX_Merge

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

func (*QueryCanVoteResponse) XXX_Size

func (m *QueryCanVoteResponse) XXX_Size() int

func (*QueryCanVoteResponse) XXX_Unmarshal

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

type QueryCurrentVoteStatusRequest

type QueryCurrentVoteStatusRequest struct {
	// pool_id ...
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

QueryCurrentVoteStatusRequest is the request type for the Query/Staker RPC method.

func (*QueryCurrentVoteStatusRequest) Descriptor

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

func (*QueryCurrentVoteStatusRequest) GetPoolId

func (m *QueryCurrentVoteStatusRequest) GetPoolId() uint64

func (*QueryCurrentVoteStatusRequest) Marshal

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

func (*QueryCurrentVoteStatusRequest) MarshalTo

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

func (*QueryCurrentVoteStatusRequest) MarshalToSizedBuffer

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

func (*QueryCurrentVoteStatusRequest) ProtoMessage

func (*QueryCurrentVoteStatusRequest) ProtoMessage()

func (*QueryCurrentVoteStatusRequest) Reset

func (m *QueryCurrentVoteStatusRequest) Reset()

func (*QueryCurrentVoteStatusRequest) Size

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

func (*QueryCurrentVoteStatusRequest) String

func (*QueryCurrentVoteStatusRequest) Unmarshal

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

func (*QueryCurrentVoteStatusRequest) XXX_DiscardUnknown

func (m *QueryCurrentVoteStatusRequest) XXX_DiscardUnknown()

func (*QueryCurrentVoteStatusRequest) XXX_Marshal

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

func (*QueryCurrentVoteStatusRequest) XXX_Merge

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

func (*QueryCurrentVoteStatusRequest) XXX_Size

func (m *QueryCurrentVoteStatusRequest) XXX_Size() int

func (*QueryCurrentVoteStatusRequest) XXX_Unmarshal

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

type QueryCurrentVoteStatusResponse

type QueryCurrentVoteStatusResponse struct {
	// valid ...
	Valid uint64 `protobuf:"varint,1,opt,name=valid,proto3" json:"valid,omitempty"`
	// invalid ...
	Invalid uint64 `protobuf:"varint,2,opt,name=invalid,proto3" json:"invalid,omitempty"`
	// abstain ...
	Abstain uint64 `protobuf:"varint,3,opt,name=abstain,proto3" json:"abstain,omitempty"`
	// total ...
	Total uint64 `protobuf:"varint,4,opt,name=total,proto3" json:"total,omitempty"`
}

QueryCurrentVoteStatusResponse is the response type for the Query/Staker RPC method.

func (*QueryCurrentVoteStatusResponse) Descriptor

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

func (*QueryCurrentVoteStatusResponse) GetAbstain

func (m *QueryCurrentVoteStatusResponse) GetAbstain() uint64

func (*QueryCurrentVoteStatusResponse) GetInvalid

func (m *QueryCurrentVoteStatusResponse) GetInvalid() uint64

func (*QueryCurrentVoteStatusResponse) GetTotal

func (m *QueryCurrentVoteStatusResponse) GetTotal() uint64

func (*QueryCurrentVoteStatusResponse) GetValid

func (m *QueryCurrentVoteStatusResponse) GetValid() uint64

func (*QueryCurrentVoteStatusResponse) Marshal

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

func (*QueryCurrentVoteStatusResponse) MarshalTo

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

func (*QueryCurrentVoteStatusResponse) MarshalToSizedBuffer

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

func (*QueryCurrentVoteStatusResponse) ProtoMessage

func (*QueryCurrentVoteStatusResponse) ProtoMessage()

func (*QueryCurrentVoteStatusResponse) Reset

func (m *QueryCurrentVoteStatusResponse) Reset()

func (*QueryCurrentVoteStatusResponse) Size

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

func (*QueryCurrentVoteStatusResponse) String

func (*QueryCurrentVoteStatusResponse) Unmarshal

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

func (*QueryCurrentVoteStatusResponse) XXX_DiscardUnknown

func (m *QueryCurrentVoteStatusResponse) XXX_DiscardUnknown()

func (*QueryCurrentVoteStatusResponse) XXX_Marshal

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

func (*QueryCurrentVoteStatusResponse) XXX_Merge

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

func (*QueryCurrentVoteStatusResponse) XXX_Size

func (m *QueryCurrentVoteStatusResponse) XXX_Size() int

func (*QueryCurrentVoteStatusResponse) XXX_Unmarshal

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

type QueryDelegationClient

type QueryDelegationClient interface {
	// Delegator returns delegation information for a specific delegator of a specific staker.
	Delegator(ctx context.Context, in *QueryDelegatorRequest, opts ...grpc.CallOption) (*QueryDelegatorResponse, error)
	// DelegatorsByStaker returns all delegators that have delegated to the given staker
	// This query is paginated.
	DelegatorsByStaker(ctx context.Context, in *QueryDelegatorsByStakerRequest, opts ...grpc.CallOption) (*QueryDelegatorsByStakerResponse, error)
	// StakersByPoolAndDelegator returns all stakers the given delegator has delegated to.
	// This query is paginated.
	StakersByDelegator(ctx context.Context, in *QueryStakersByDelegatorRequest, opts ...grpc.CallOption) (*QueryStakersByDelegatorResponse, error)
}

QueryDelegationClient is the client API for QueryDelegation service.

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

func NewQueryDelegationClient

func NewQueryDelegationClient(cc grpc1.ClientConn) QueryDelegationClient

type QueryDelegationServer

type QueryDelegationServer interface {
	// Delegator returns delegation information for a specific delegator of a specific staker.
	Delegator(context.Context, *QueryDelegatorRequest) (*QueryDelegatorResponse, error)
	// DelegatorsByStaker returns all delegators that have delegated to the given staker
	// This query is paginated.
	DelegatorsByStaker(context.Context, *QueryDelegatorsByStakerRequest) (*QueryDelegatorsByStakerResponse, error)
	// StakersByPoolAndDelegator returns all stakers the given delegator has delegated to.
	// This query is paginated.
	StakersByDelegator(context.Context, *QueryStakersByDelegatorRequest) (*QueryStakersByDelegatorResponse, error)
}

QueryDelegationServer is the server API for QueryDelegation service.

type QueryDelegatorRequest

type QueryDelegatorRequest struct {
	// staker ...
	Staker string `protobuf:"bytes,1,opt,name=staker,proto3" json:"staker,omitempty"`
	// delegator ...
	Delegator string `protobuf:"bytes,2,opt,name=delegator,proto3" json:"delegator,omitempty"`
}

QueryDelegatorRequest is the request type for the Query/Delegator RPC method.

func (*QueryDelegatorRequest) Descriptor

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

func (*QueryDelegatorRequest) GetDelegator

func (m *QueryDelegatorRequest) GetDelegator() string

func (*QueryDelegatorRequest) GetStaker

func (m *QueryDelegatorRequest) GetStaker() string

func (*QueryDelegatorRequest) Marshal

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

func (*QueryDelegatorRequest) MarshalTo

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

func (*QueryDelegatorRequest) MarshalToSizedBuffer

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

func (*QueryDelegatorRequest) ProtoMessage

func (*QueryDelegatorRequest) ProtoMessage()

func (*QueryDelegatorRequest) Reset

func (m *QueryDelegatorRequest) Reset()

func (*QueryDelegatorRequest) Size

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

func (*QueryDelegatorRequest) String

func (m *QueryDelegatorRequest) String() string

func (*QueryDelegatorRequest) Unmarshal

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

func (*QueryDelegatorRequest) XXX_DiscardUnknown

func (m *QueryDelegatorRequest) XXX_DiscardUnknown()

func (*QueryDelegatorRequest) XXX_Marshal

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

func (*QueryDelegatorRequest) XXX_Merge

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

func (*QueryDelegatorRequest) XXX_Size

func (m *QueryDelegatorRequest) XXX_Size() int

func (*QueryDelegatorRequest) XXX_Unmarshal

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

type QueryDelegatorResponse

type QueryDelegatorResponse struct {
	// delegator ...
	Delegator *StakerDelegatorResponse `protobuf:"bytes,1,opt,name=delegator,proto3" json:"delegator,omitempty"`
}

QueryDelegatorResponse is the response type for the Query/Delegator RPC method.

func (*QueryDelegatorResponse) Descriptor

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

func (*QueryDelegatorResponse) GetDelegator

func (*QueryDelegatorResponse) Marshal

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

func (*QueryDelegatorResponse) MarshalTo

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

func (*QueryDelegatorResponse) MarshalToSizedBuffer

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

func (*QueryDelegatorResponse) ProtoMessage

func (*QueryDelegatorResponse) ProtoMessage()

func (*QueryDelegatorResponse) Reset

func (m *QueryDelegatorResponse) Reset()

func (*QueryDelegatorResponse) Size

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

func (*QueryDelegatorResponse) String

func (m *QueryDelegatorResponse) String() string

func (*QueryDelegatorResponse) Unmarshal

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

func (*QueryDelegatorResponse) XXX_DiscardUnknown

func (m *QueryDelegatorResponse) XXX_DiscardUnknown()

func (*QueryDelegatorResponse) XXX_Marshal

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

func (*QueryDelegatorResponse) XXX_Merge

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

func (*QueryDelegatorResponse) XXX_Size

func (m *QueryDelegatorResponse) XXX_Size() int

func (*QueryDelegatorResponse) XXX_Unmarshal

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

type QueryDelegatorsByStakerRequest

type QueryDelegatorsByStakerRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// staker ...
	Staker string `protobuf:"bytes,2,opt,name=staker,proto3" json:"staker,omitempty"`
}

QueryDelegatorsByStakerRequest ...

func (*QueryDelegatorsByStakerRequest) Descriptor

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

func (*QueryDelegatorsByStakerRequest) GetPagination

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

func (*QueryDelegatorsByStakerRequest) GetStaker

func (m *QueryDelegatorsByStakerRequest) GetStaker() string

func (*QueryDelegatorsByStakerRequest) Marshal

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

func (*QueryDelegatorsByStakerRequest) MarshalTo

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

func (*QueryDelegatorsByStakerRequest) MarshalToSizedBuffer

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

func (*QueryDelegatorsByStakerRequest) ProtoMessage

func (*QueryDelegatorsByStakerRequest) ProtoMessage()

func (*QueryDelegatorsByStakerRequest) Reset

func (m *QueryDelegatorsByStakerRequest) Reset()

func (*QueryDelegatorsByStakerRequest) Size

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

func (*QueryDelegatorsByStakerRequest) String

func (*QueryDelegatorsByStakerRequest) Unmarshal

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

func (*QueryDelegatorsByStakerRequest) XXX_DiscardUnknown

func (m *QueryDelegatorsByStakerRequest) XXX_DiscardUnknown()

func (*QueryDelegatorsByStakerRequest) XXX_Marshal

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

func (*QueryDelegatorsByStakerRequest) XXX_Merge

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

func (*QueryDelegatorsByStakerRequest) XXX_Size

func (m *QueryDelegatorsByStakerRequest) XXX_Size() int

func (*QueryDelegatorsByStakerRequest) XXX_Unmarshal

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

type QueryDelegatorsByStakerResponse

type QueryDelegatorsByStakerResponse struct {
	// delegators ...
	Delegators []StakerDelegatorResponse `protobuf:"bytes,1,rep,name=delegators,proto3" json:"delegators"`
	// total_delegation ... (consider metadata object)
	TotalDelegation uint64 `protobuf:"varint,2,opt,name=total_delegation,json=totalDelegation,proto3" json:"total_delegation,omitempty"`
	// total_delegation ...
	TotalDelegatorCount uint64 `protobuf:"varint,3,opt,name=total_delegator_count,json=totalDelegatorCount,proto3" json:"total_delegator_count,omitempty"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,4,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryDelegatorsByStakerResponse ...

func (*QueryDelegatorsByStakerResponse) Descriptor

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

func (*QueryDelegatorsByStakerResponse) GetDelegators

func (*QueryDelegatorsByStakerResponse) GetPagination

func (*QueryDelegatorsByStakerResponse) GetTotalDelegation

func (m *QueryDelegatorsByStakerResponse) GetTotalDelegation() uint64

func (*QueryDelegatorsByStakerResponse) GetTotalDelegatorCount

func (m *QueryDelegatorsByStakerResponse) GetTotalDelegatorCount() uint64

func (*QueryDelegatorsByStakerResponse) Marshal

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

func (*QueryDelegatorsByStakerResponse) MarshalTo

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

func (*QueryDelegatorsByStakerResponse) MarshalToSizedBuffer

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

func (*QueryDelegatorsByStakerResponse) ProtoMessage

func (*QueryDelegatorsByStakerResponse) ProtoMessage()

func (*QueryDelegatorsByStakerResponse) Reset

func (*QueryDelegatorsByStakerResponse) Size

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

func (*QueryDelegatorsByStakerResponse) String

func (*QueryDelegatorsByStakerResponse) Unmarshal

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

func (*QueryDelegatorsByStakerResponse) XXX_DiscardUnknown

func (m *QueryDelegatorsByStakerResponse) XXX_DiscardUnknown()

func (*QueryDelegatorsByStakerResponse) XXX_Marshal

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

func (*QueryDelegatorsByStakerResponse) XXX_Merge

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

func (*QueryDelegatorsByStakerResponse) XXX_Size

func (m *QueryDelegatorsByStakerResponse) XXX_Size() int

func (*QueryDelegatorsByStakerResponse) XXX_Unmarshal

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

type QueryFinalizedBundleRequest

type QueryFinalizedBundleRequest struct {
	// pool_id ...
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// id ...
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
}

QueryFinalizedBundleRequest is the request type for the Query/Staker RPC method.

func (*QueryFinalizedBundleRequest) Descriptor

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

func (*QueryFinalizedBundleRequest) GetId

func (*QueryFinalizedBundleRequest) GetPoolId

func (m *QueryFinalizedBundleRequest) GetPoolId() uint64

func (*QueryFinalizedBundleRequest) Marshal

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

func (*QueryFinalizedBundleRequest) MarshalTo

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

func (*QueryFinalizedBundleRequest) MarshalToSizedBuffer

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

func (*QueryFinalizedBundleRequest) ProtoMessage

func (*QueryFinalizedBundleRequest) ProtoMessage()

func (*QueryFinalizedBundleRequest) Reset

func (m *QueryFinalizedBundleRequest) Reset()

func (*QueryFinalizedBundleRequest) Size

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

func (*QueryFinalizedBundleRequest) String

func (m *QueryFinalizedBundleRequest) String() string

func (*QueryFinalizedBundleRequest) Unmarshal

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

func (*QueryFinalizedBundleRequest) XXX_DiscardUnknown

func (m *QueryFinalizedBundleRequest) XXX_DiscardUnknown()

func (*QueryFinalizedBundleRequest) XXX_Marshal

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

func (*QueryFinalizedBundleRequest) XXX_Merge

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

func (*QueryFinalizedBundleRequest) XXX_Size

func (m *QueryFinalizedBundleRequest) XXX_Size() int

func (*QueryFinalizedBundleRequest) XXX_Unmarshal

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

type QueryFinalizedBundleResponse

type QueryFinalizedBundleResponse struct {
	// finalized_bundle ...
	FinalizedBundle types.FinalizedBundle `protobuf:"bytes,1,opt,name=finalized_bundle,json=finalizedBundle,proto3" json:"finalized_bundle"`
}

QueryFinalizedBundleResponse is the response type for the Query/Staker RPC method.

func (*QueryFinalizedBundleResponse) Descriptor

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

func (*QueryFinalizedBundleResponse) GetFinalizedBundle

func (m *QueryFinalizedBundleResponse) GetFinalizedBundle() types.FinalizedBundle

func (*QueryFinalizedBundleResponse) Marshal

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

func (*QueryFinalizedBundleResponse) MarshalTo

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

func (*QueryFinalizedBundleResponse) MarshalToSizedBuffer

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

func (*QueryFinalizedBundleResponse) ProtoMessage

func (*QueryFinalizedBundleResponse) ProtoMessage()

func (*QueryFinalizedBundleResponse) Reset

func (m *QueryFinalizedBundleResponse) Reset()

func (*QueryFinalizedBundleResponse) Size

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

func (*QueryFinalizedBundleResponse) String

func (*QueryFinalizedBundleResponse) Unmarshal

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

func (*QueryFinalizedBundleResponse) XXX_DiscardUnknown

func (m *QueryFinalizedBundleResponse) XXX_DiscardUnknown()

func (*QueryFinalizedBundleResponse) XXX_Marshal

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

func (*QueryFinalizedBundleResponse) XXX_Merge

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

func (*QueryFinalizedBundleResponse) XXX_Size

func (m *QueryFinalizedBundleResponse) XXX_Size() int

func (*QueryFinalizedBundleResponse) XXX_Unmarshal

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

type QueryFinalizedBundlesByHeightRequest

type QueryFinalizedBundlesByHeightRequest struct {
	// pool_id ...
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// id ...
	Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
}

QueryFinalizedBundleRequest is the request type for the Query/Staker RPC method.

func (*QueryFinalizedBundlesByHeightRequest) Descriptor

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

func (*QueryFinalizedBundlesByHeightRequest) GetHeight

func (*QueryFinalizedBundlesByHeightRequest) GetPoolId

func (*QueryFinalizedBundlesByHeightRequest) Marshal

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

func (*QueryFinalizedBundlesByHeightRequest) MarshalTo

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

func (*QueryFinalizedBundlesByHeightRequest) MarshalToSizedBuffer

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

func (*QueryFinalizedBundlesByHeightRequest) ProtoMessage

func (*QueryFinalizedBundlesByHeightRequest) ProtoMessage()

func (*QueryFinalizedBundlesByHeightRequest) Reset

func (*QueryFinalizedBundlesByHeightRequest) Size

func (*QueryFinalizedBundlesByHeightRequest) String

func (*QueryFinalizedBundlesByHeightRequest) Unmarshal

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

func (*QueryFinalizedBundlesByHeightRequest) XXX_DiscardUnknown

func (m *QueryFinalizedBundlesByHeightRequest) XXX_DiscardUnknown()

func (*QueryFinalizedBundlesByHeightRequest) XXX_Marshal

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

func (*QueryFinalizedBundlesByHeightRequest) XXX_Merge

func (*QueryFinalizedBundlesByHeightRequest) XXX_Size

func (*QueryFinalizedBundlesByHeightRequest) XXX_Unmarshal

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

type QueryFinalizedBundlesByHeightResponse

type QueryFinalizedBundlesByHeightResponse struct {
	// finalized_bundle ...
	FinalizedBundle types.FinalizedBundle `protobuf:"bytes,1,opt,name=finalized_bundle,json=finalizedBundle,proto3" json:"finalized_bundle"`
}

QueryFinalizedBundleResponse is the response type for the Query/Staker RPC method.

func (*QueryFinalizedBundlesByHeightResponse) Descriptor

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

func (*QueryFinalizedBundlesByHeightResponse) GetFinalizedBundle

func (*QueryFinalizedBundlesByHeightResponse) Marshal

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

func (*QueryFinalizedBundlesByHeightResponse) MarshalTo

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

func (*QueryFinalizedBundlesByHeightResponse) MarshalToSizedBuffer

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

func (*QueryFinalizedBundlesByHeightResponse) ProtoMessage

func (*QueryFinalizedBundlesByHeightResponse) ProtoMessage()

func (*QueryFinalizedBundlesByHeightResponse) Reset

func (*QueryFinalizedBundlesByHeightResponse) Size

func (*QueryFinalizedBundlesByHeightResponse) String

func (*QueryFinalizedBundlesByHeightResponse) Unmarshal

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

func (*QueryFinalizedBundlesByHeightResponse) XXX_DiscardUnknown

func (m *QueryFinalizedBundlesByHeightResponse) XXX_DiscardUnknown()

func (*QueryFinalizedBundlesByHeightResponse) XXX_Marshal

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

func (*QueryFinalizedBundlesByHeightResponse) XXX_Merge

func (*QueryFinalizedBundlesByHeightResponse) XXX_Size

func (*QueryFinalizedBundlesByHeightResponse) XXX_Unmarshal

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

type QueryFinalizedBundlesRequest

type QueryFinalizedBundlesRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// pool_id ...
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

QueryFinalizedBundlesRequest is the request type for the Query/Staker RPC method.

func (*QueryFinalizedBundlesRequest) Descriptor

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

func (*QueryFinalizedBundlesRequest) GetPagination

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

func (*QueryFinalizedBundlesRequest) GetPoolId

func (m *QueryFinalizedBundlesRequest) GetPoolId() uint64

func (*QueryFinalizedBundlesRequest) Marshal

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

func (*QueryFinalizedBundlesRequest) MarshalTo

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

func (*QueryFinalizedBundlesRequest) MarshalToSizedBuffer

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

func (*QueryFinalizedBundlesRequest) ProtoMessage

func (*QueryFinalizedBundlesRequest) ProtoMessage()

func (*QueryFinalizedBundlesRequest) Reset

func (m *QueryFinalizedBundlesRequest) Reset()

func (*QueryFinalizedBundlesRequest) Size

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

func (*QueryFinalizedBundlesRequest) String

func (*QueryFinalizedBundlesRequest) Unmarshal

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

func (*QueryFinalizedBundlesRequest) XXX_DiscardUnknown

func (m *QueryFinalizedBundlesRequest) XXX_DiscardUnknown()

func (*QueryFinalizedBundlesRequest) XXX_Marshal

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

func (*QueryFinalizedBundlesRequest) XXX_Merge

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

func (*QueryFinalizedBundlesRequest) XXX_Size

func (m *QueryFinalizedBundlesRequest) XXX_Size() int

func (*QueryFinalizedBundlesRequest) XXX_Unmarshal

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

type QueryFinalizedBundlesResponse

type QueryFinalizedBundlesResponse struct {
	// finalized_bundles ...
	FinalizedBundles []types.FinalizedBundle `protobuf:"bytes,1,rep,name=finalized_bundles,json=finalizedBundles,proto3" json:"finalized_bundles"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryStakersByPoolResponse is the response type for the Query/Staker RPC method.

func (*QueryFinalizedBundlesResponse) Descriptor

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

func (*QueryFinalizedBundlesResponse) GetFinalizedBundles

func (m *QueryFinalizedBundlesResponse) GetFinalizedBundles() []types.FinalizedBundle

func (*QueryFinalizedBundlesResponse) GetPagination

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

func (*QueryFinalizedBundlesResponse) Marshal

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

func (*QueryFinalizedBundlesResponse) MarshalTo

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

func (*QueryFinalizedBundlesResponse) MarshalToSizedBuffer

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

func (*QueryFinalizedBundlesResponse) ProtoMessage

func (*QueryFinalizedBundlesResponse) ProtoMessage()

func (*QueryFinalizedBundlesResponse) Reset

func (m *QueryFinalizedBundlesResponse) Reset()

func (*QueryFinalizedBundlesResponse) Size

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

func (*QueryFinalizedBundlesResponse) String

func (*QueryFinalizedBundlesResponse) Unmarshal

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

func (*QueryFinalizedBundlesResponse) XXX_DiscardUnknown

func (m *QueryFinalizedBundlesResponse) XXX_DiscardUnknown()

func (*QueryFinalizedBundlesResponse) XXX_Marshal

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

func (*QueryFinalizedBundlesResponse) XXX_Merge

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

func (*QueryFinalizedBundlesResponse) XXX_Size

func (m *QueryFinalizedBundlesResponse) XXX_Size() int

func (*QueryFinalizedBundlesResponse) XXX_Unmarshal

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

type QueryParamsClient

type QueryParamsClient interface {
	// Pools queries for all pools.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
}

QueryParamsClient is the client API for QueryParams service.

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

func NewQueryParamsClient

func NewQueryParamsClient(cc grpc1.ClientConn) QueryParamsClient

type QueryParamsRequest

type QueryParamsRequest struct {
}

QueryParamsRequest ...

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 {
	// bundles_params ...
	BundlesParams *types.Params `protobuf:"bytes,1,opt,name=bundles_params,json=bundlesParams,proto3" json:"bundles_params,omitempty"`
	// delegation_params ...
	DelegationParams *types1.Params `protobuf:"bytes,2,opt,name=delegation_params,json=delegationParams,proto3" json:"delegation_params,omitempty"`
	// global_params ...
	GlobalParams *types2.Params `protobuf:"bytes,3,opt,name=global_params,json=globalParams,proto3" json:"global_params,omitempty"`
	// gov_params ...
	GovParams *v1.QueryParamsResponse `protobuf:"bytes,4,opt,name=gov_params,json=govParams,proto3" json:"gov_params,omitempty"`
	// stakers_params ...
	StakersParams *types3.Params `protobuf:"bytes,5,opt,name=stakers_params,json=stakersParams,proto3" json:"stakers_params,omitempty"`
}

QueryParamsResponse ...

func (*QueryParamsResponse) Descriptor

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

func (*QueryParamsResponse) GetBundlesParams

func (m *QueryParamsResponse) GetBundlesParams() *types.Params

func (*QueryParamsResponse) GetDelegationParams

func (m *QueryParamsResponse) GetDelegationParams() *types1.Params

func (*QueryParamsResponse) GetGlobalParams

func (m *QueryParamsResponse) GetGlobalParams() *types2.Params

func (*QueryParamsResponse) GetGovParams

func (m *QueryParamsResponse) GetGovParams() *v1.QueryParamsResponse

func (*QueryParamsResponse) GetStakersParams

func (m *QueryParamsResponse) GetStakersParams() *types3.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 QueryParamsServer

type QueryParamsServer interface {
	// Pools queries for all pools.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
}

QueryParamsServer is the server API for QueryParams service.

type QueryPoolClient

type QueryPoolClient interface {
	// Pools queries for all pools.
	Pools(ctx context.Context, in *QueryPoolsRequest, opts ...grpc.CallOption) (*QueryPoolsResponse, error)
	// Pool queries a pool by its Id.
	Pool(ctx context.Context, in *QueryPoolRequest, opts ...grpc.CallOption) (*QueryPoolResponse, error)
}

QueryPoolClient is the client API for QueryPool service.

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

func NewQueryPoolClient

func NewQueryPoolClient(cc grpc1.ClientConn) QueryPoolClient

type QueryPoolRequest

type QueryPoolRequest struct {
	// id defines the unique ID of the pool.
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
}

QueryPoolRequest is the request type for the Query/Pool RPC method.

func (*QueryPoolRequest) Descriptor

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

func (*QueryPoolRequest) GetId

func (m *QueryPoolRequest) GetId() uint64

func (*QueryPoolRequest) Marshal

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

func (*QueryPoolRequest) MarshalTo

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

func (*QueryPoolRequest) MarshalToSizedBuffer

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

func (*QueryPoolRequest) ProtoMessage

func (*QueryPoolRequest) ProtoMessage()

func (*QueryPoolRequest) Reset

func (m *QueryPoolRequest) Reset()

func (*QueryPoolRequest) Size

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

func (*QueryPoolRequest) String

func (m *QueryPoolRequest) String() string

func (*QueryPoolRequest) Unmarshal

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

func (*QueryPoolRequest) XXX_DiscardUnknown

func (m *QueryPoolRequest) XXX_DiscardUnknown()

func (*QueryPoolRequest) XXX_Marshal

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

func (*QueryPoolRequest) XXX_Merge

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

func (*QueryPoolRequest) XXX_Size

func (m *QueryPoolRequest) XXX_Size() int

func (*QueryPoolRequest) XXX_Unmarshal

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

type QueryPoolResponse

type QueryPoolResponse struct {
	// pool ...
	Pool PoolResponse `protobuf:"bytes,1,opt,name=pool,proto3" json:"pool"`
}

QueryPoolResponse is the response type for the Query/Pool RPC method.

func (*QueryPoolResponse) Descriptor

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

func (*QueryPoolResponse) GetPool

func (m *QueryPoolResponse) GetPool() PoolResponse

func (*QueryPoolResponse) Marshal

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

func (*QueryPoolResponse) MarshalTo

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

func (*QueryPoolResponse) MarshalToSizedBuffer

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

func (*QueryPoolResponse) ProtoMessage

func (*QueryPoolResponse) ProtoMessage()

func (*QueryPoolResponse) Reset

func (m *QueryPoolResponse) Reset()

func (*QueryPoolResponse) Size

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

func (*QueryPoolResponse) String

func (m *QueryPoolResponse) String() string

func (*QueryPoolResponse) Unmarshal

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

func (*QueryPoolResponse) XXX_DiscardUnknown

func (m *QueryPoolResponse) XXX_DiscardUnknown()

func (*QueryPoolResponse) XXX_Marshal

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

func (*QueryPoolResponse) XXX_Merge

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

func (*QueryPoolResponse) XXX_Size

func (m *QueryPoolResponse) XXX_Size() int

func (*QueryPoolResponse) XXX_Unmarshal

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

type QueryPoolServer

type QueryPoolServer interface {
	// Pools queries for all pools.
	Pools(context.Context, *QueryPoolsRequest) (*QueryPoolsResponse, error)
	// Pool queries a pool by its Id.
	Pool(context.Context, *QueryPoolRequest) (*QueryPoolResponse, error)
}

QueryPoolServer is the server API for QueryPool service.

type QueryPoolsRequest

type QueryPoolsRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// search ...
	Search string `protobuf:"bytes,2,opt,name=search,proto3" json:"search,omitempty"`
	// runtime ...
	Runtime string `protobuf:"bytes,3,opt,name=runtime,proto3" json:"runtime,omitempty"`
	// disabled ...
	Disabled bool `protobuf:"varint,4,opt,name=disabled,proto3" json:"disabled,omitempty"`
	// storage_provider_id ...
	StorageProviderId uint32 `protobuf:"varint,5,opt,name=storage_provider_id,json=storageProviderId,proto3" json:"storage_provider_id,omitempty"`
}

QueryPoolsRequest is the request type for the Query/Pools RPC method.

func (*QueryPoolsRequest) Descriptor

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

func (*QueryPoolsRequest) GetDisabled

func (m *QueryPoolsRequest) GetDisabled() bool

func (*QueryPoolsRequest) GetPagination

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

func (*QueryPoolsRequest) GetRuntime

func (m *QueryPoolsRequest) GetRuntime() string

func (*QueryPoolsRequest) GetSearch

func (m *QueryPoolsRequest) GetSearch() string

func (*QueryPoolsRequest) GetStorageProviderId

func (m *QueryPoolsRequest) GetStorageProviderId() uint32

func (*QueryPoolsRequest) Marshal

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

func (*QueryPoolsRequest) MarshalTo

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

func (*QueryPoolsRequest) MarshalToSizedBuffer

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

func (*QueryPoolsRequest) ProtoMessage

func (*QueryPoolsRequest) ProtoMessage()

func (*QueryPoolsRequest) Reset

func (m *QueryPoolsRequest) Reset()

func (*QueryPoolsRequest) Size

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

func (*QueryPoolsRequest) String

func (m *QueryPoolsRequest) String() string

func (*QueryPoolsRequest) Unmarshal

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

func (*QueryPoolsRequest) XXX_DiscardUnknown

func (m *QueryPoolsRequest) XXX_DiscardUnknown()

func (*QueryPoolsRequest) XXX_Marshal

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

func (*QueryPoolsRequest) XXX_Merge

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

func (*QueryPoolsRequest) XXX_Size

func (m *QueryPoolsRequest) XXX_Size() int

func (*QueryPoolsRequest) XXX_Unmarshal

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

type QueryPoolsResponse

type QueryPoolsResponse struct {
	// pools ...
	Pools []PoolResponse `protobuf:"bytes,1,rep,name=pools,proto3" json:"pools"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryPoolsResponse is the response type for the Query/Pools RPC method.

func (*QueryPoolsResponse) Descriptor

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

func (*QueryPoolsResponse) GetPagination

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

func (*QueryPoolsResponse) GetPools

func (m *QueryPoolsResponse) GetPools() []PoolResponse

func (*QueryPoolsResponse) Marshal

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

func (*QueryPoolsResponse) MarshalTo

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

func (*QueryPoolsResponse) MarshalToSizedBuffer

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

func (*QueryPoolsResponse) ProtoMessage

func (*QueryPoolsResponse) ProtoMessage()

func (*QueryPoolsResponse) Reset

func (m *QueryPoolsResponse) Reset()

func (*QueryPoolsResponse) Size

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

func (*QueryPoolsResponse) String

func (m *QueryPoolsResponse) String() string

func (*QueryPoolsResponse) Unmarshal

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

func (*QueryPoolsResponse) XXX_DiscardUnknown

func (m *QueryPoolsResponse) XXX_DiscardUnknown()

func (*QueryPoolsResponse) XXX_Marshal

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

func (*QueryPoolsResponse) XXX_Merge

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

func (*QueryPoolsResponse) XXX_Size

func (m *QueryPoolsResponse) XXX_Size() int

func (*QueryPoolsResponse) XXX_Unmarshal

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

type QueryStakerRequest

type QueryStakerRequest struct {
	// address ...
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

QueryStakerRequest is the request type for the Query/Staker RPC method.

func (*QueryStakerRequest) Descriptor

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

func (*QueryStakerRequest) GetAddress

func (m *QueryStakerRequest) GetAddress() string

func (*QueryStakerRequest) Marshal

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

func (*QueryStakerRequest) MarshalTo

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

func (*QueryStakerRequest) MarshalToSizedBuffer

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

func (*QueryStakerRequest) ProtoMessage

func (*QueryStakerRequest) ProtoMessage()

func (*QueryStakerRequest) Reset

func (m *QueryStakerRequest) Reset()

func (*QueryStakerRequest) Size

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

func (*QueryStakerRequest) String

func (m *QueryStakerRequest) String() string

func (*QueryStakerRequest) Unmarshal

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

func (*QueryStakerRequest) XXX_DiscardUnknown

func (m *QueryStakerRequest) XXX_DiscardUnknown()

func (*QueryStakerRequest) XXX_Marshal

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

func (*QueryStakerRequest) XXX_Merge

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

func (*QueryStakerRequest) XXX_Size

func (m *QueryStakerRequest) XXX_Size() int

func (*QueryStakerRequest) XXX_Unmarshal

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

type QueryStakerResponse

type QueryStakerResponse struct {
	// staker ...
	Staker FullStaker `protobuf:"bytes,1,opt,name=staker,proto3" json:"staker"`
}

QueryStakerResponse is the response type for the Query/Staker RPC method.

func (*QueryStakerResponse) Descriptor

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

func (*QueryStakerResponse) GetStaker

func (m *QueryStakerResponse) GetStaker() FullStaker

func (*QueryStakerResponse) Marshal

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

func (*QueryStakerResponse) MarshalTo

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

func (*QueryStakerResponse) MarshalToSizedBuffer

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

func (*QueryStakerResponse) ProtoMessage

func (*QueryStakerResponse) ProtoMessage()

func (*QueryStakerResponse) Reset

func (m *QueryStakerResponse) Reset()

func (*QueryStakerResponse) Size

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

func (*QueryStakerResponse) String

func (m *QueryStakerResponse) String() string

func (*QueryStakerResponse) Unmarshal

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

func (*QueryStakerResponse) XXX_DiscardUnknown

func (m *QueryStakerResponse) XXX_DiscardUnknown()

func (*QueryStakerResponse) XXX_Marshal

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

func (*QueryStakerResponse) XXX_Merge

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

func (*QueryStakerResponse) XXX_Size

func (m *QueryStakerResponse) XXX_Size() int

func (*QueryStakerResponse) XXX_Unmarshal

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

type QueryStakersByDelegatorRequest

type QueryStakersByDelegatorRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// delegator ...
	Delegator string `protobuf:"bytes,2,opt,name=delegator,proto3" json:"delegator,omitempty"`
}

QueryStakersByDelegatorRequest ...

func (*QueryStakersByDelegatorRequest) Descriptor

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

func (*QueryStakersByDelegatorRequest) GetDelegator

func (m *QueryStakersByDelegatorRequest) GetDelegator() string

func (*QueryStakersByDelegatorRequest) GetPagination

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

func (*QueryStakersByDelegatorRequest) Marshal

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

func (*QueryStakersByDelegatorRequest) MarshalTo

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

func (*QueryStakersByDelegatorRequest) MarshalToSizedBuffer

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

func (*QueryStakersByDelegatorRequest) ProtoMessage

func (*QueryStakersByDelegatorRequest) ProtoMessage()

func (*QueryStakersByDelegatorRequest) Reset

func (m *QueryStakersByDelegatorRequest) Reset()

func (*QueryStakersByDelegatorRequest) Size

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

func (*QueryStakersByDelegatorRequest) String

func (*QueryStakersByDelegatorRequest) Unmarshal

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

func (*QueryStakersByDelegatorRequest) XXX_DiscardUnknown

func (m *QueryStakersByDelegatorRequest) XXX_DiscardUnknown()

func (*QueryStakersByDelegatorRequest) XXX_Marshal

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

func (*QueryStakersByDelegatorRequest) XXX_Merge

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

func (*QueryStakersByDelegatorRequest) XXX_Size

func (m *QueryStakersByDelegatorRequest) XXX_Size() int

func (*QueryStakersByDelegatorRequest) XXX_Unmarshal

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

type QueryStakersByDelegatorResponse

type QueryStakersByDelegatorResponse struct {
	// delegator ...
	Delegator string `protobuf:"bytes,1,opt,name=delegator,proto3" json:"delegator,omitempty"`
	// stakers ...
	Stakers []DelegationForStakerResponse `protobuf:"bytes,2,rep,name=stakers,proto3" json:"stakers"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,3,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryStakersByDelegatorResponse ...

func (*QueryStakersByDelegatorResponse) Descriptor

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

func (*QueryStakersByDelegatorResponse) GetDelegator

func (m *QueryStakersByDelegatorResponse) GetDelegator() string

func (*QueryStakersByDelegatorResponse) GetPagination

func (*QueryStakersByDelegatorResponse) GetStakers

func (*QueryStakersByDelegatorResponse) Marshal

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

func (*QueryStakersByDelegatorResponse) MarshalTo

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

func (*QueryStakersByDelegatorResponse) MarshalToSizedBuffer

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

func (*QueryStakersByDelegatorResponse) ProtoMessage

func (*QueryStakersByDelegatorResponse) ProtoMessage()

func (*QueryStakersByDelegatorResponse) Reset

func (*QueryStakersByDelegatorResponse) Size

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

func (*QueryStakersByDelegatorResponse) String

func (*QueryStakersByDelegatorResponse) Unmarshal

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

func (*QueryStakersByDelegatorResponse) XXX_DiscardUnknown

func (m *QueryStakersByDelegatorResponse) XXX_DiscardUnknown()

func (*QueryStakersByDelegatorResponse) XXX_Marshal

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

func (*QueryStakersByDelegatorResponse) XXX_Merge

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

func (*QueryStakersByDelegatorResponse) XXX_Size

func (m *QueryStakersByDelegatorResponse) XXX_Size() int

func (*QueryStakersByDelegatorResponse) XXX_Unmarshal

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

type QueryStakersByPoolCountRequest

type QueryStakersByPoolCountRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryStakersByPoolCountRequest ...

func (*QueryStakersByPoolCountRequest) Descriptor

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

func (*QueryStakersByPoolCountRequest) GetPagination

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

func (*QueryStakersByPoolCountRequest) Marshal

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

func (*QueryStakersByPoolCountRequest) MarshalTo

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

func (*QueryStakersByPoolCountRequest) MarshalToSizedBuffer

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

func (*QueryStakersByPoolCountRequest) ProtoMessage

func (*QueryStakersByPoolCountRequest) ProtoMessage()

func (*QueryStakersByPoolCountRequest) Reset

func (m *QueryStakersByPoolCountRequest) Reset()

func (*QueryStakersByPoolCountRequest) Size

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

func (*QueryStakersByPoolCountRequest) String

func (*QueryStakersByPoolCountRequest) Unmarshal

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

func (*QueryStakersByPoolCountRequest) XXX_DiscardUnknown

func (m *QueryStakersByPoolCountRequest) XXX_DiscardUnknown()

func (*QueryStakersByPoolCountRequest) XXX_Marshal

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

func (*QueryStakersByPoolCountRequest) XXX_Merge

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

func (*QueryStakersByPoolCountRequest) XXX_Size

func (m *QueryStakersByPoolCountRequest) XXX_Size() int

func (*QueryStakersByPoolCountRequest) XXX_Unmarshal

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

type QueryStakersByPoolCountResponse

type QueryStakersByPoolCountResponse struct {
	// stakers ...
	Stakers []FullStaker `protobuf:"bytes,1,rep,name=stakers,proto3" json:"stakers"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryStakersByPoolCountResponse ...

func (*QueryStakersByPoolCountResponse) Descriptor

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

func (*QueryStakersByPoolCountResponse) GetPagination

func (*QueryStakersByPoolCountResponse) GetStakers

func (m *QueryStakersByPoolCountResponse) GetStakers() []FullStaker

func (*QueryStakersByPoolCountResponse) Marshal

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

func (*QueryStakersByPoolCountResponse) MarshalTo

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

func (*QueryStakersByPoolCountResponse) MarshalToSizedBuffer

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

func (*QueryStakersByPoolCountResponse) ProtoMessage

func (*QueryStakersByPoolCountResponse) ProtoMessage()

func (*QueryStakersByPoolCountResponse) Reset

func (*QueryStakersByPoolCountResponse) Size

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

func (*QueryStakersByPoolCountResponse) String

func (*QueryStakersByPoolCountResponse) Unmarshal

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

func (*QueryStakersByPoolCountResponse) XXX_DiscardUnknown

func (m *QueryStakersByPoolCountResponse) XXX_DiscardUnknown()

func (*QueryStakersByPoolCountResponse) XXX_Marshal

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

func (*QueryStakersByPoolCountResponse) XXX_Merge

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

func (*QueryStakersByPoolCountResponse) XXX_Size

func (m *QueryStakersByPoolCountResponse) XXX_Size() int

func (*QueryStakersByPoolCountResponse) XXX_Unmarshal

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

type QueryStakersByPoolRequest

type QueryStakersByPoolRequest struct {
	// pool_id ...
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
}

QueryStakersByPoolRequest is the request type for the Query/Staker RPC method.

func (*QueryStakersByPoolRequest) Descriptor

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

func (*QueryStakersByPoolRequest) GetPoolId

func (m *QueryStakersByPoolRequest) GetPoolId() uint64

func (*QueryStakersByPoolRequest) Marshal

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

func (*QueryStakersByPoolRequest) MarshalTo

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

func (*QueryStakersByPoolRequest) MarshalToSizedBuffer

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

func (*QueryStakersByPoolRequest) ProtoMessage

func (*QueryStakersByPoolRequest) ProtoMessage()

func (*QueryStakersByPoolRequest) Reset

func (m *QueryStakersByPoolRequest) Reset()

func (*QueryStakersByPoolRequest) Size

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

func (*QueryStakersByPoolRequest) String

func (m *QueryStakersByPoolRequest) String() string

func (*QueryStakersByPoolRequest) Unmarshal

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

func (*QueryStakersByPoolRequest) XXX_DiscardUnknown

func (m *QueryStakersByPoolRequest) XXX_DiscardUnknown()

func (*QueryStakersByPoolRequest) XXX_Marshal

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

func (*QueryStakersByPoolRequest) XXX_Merge

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

func (*QueryStakersByPoolRequest) XXX_Size

func (m *QueryStakersByPoolRequest) XXX_Size() int

func (*QueryStakersByPoolRequest) XXX_Unmarshal

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

type QueryStakersByPoolResponse

type QueryStakersByPoolResponse struct {
	// stakers ...
	Stakers []StakerPoolResponse `protobuf:"bytes,1,rep,name=stakers,proto3" json:"stakers"`
}

QueryStakersByPoolResponse is the response type for the Query/Staker RPC method.

func (*QueryStakersByPoolResponse) Descriptor

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

func (*QueryStakersByPoolResponse) GetStakers

func (*QueryStakersByPoolResponse) Marshal

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

func (*QueryStakersByPoolResponse) MarshalTo

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

func (*QueryStakersByPoolResponse) MarshalToSizedBuffer

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

func (*QueryStakersByPoolResponse) ProtoMessage

func (*QueryStakersByPoolResponse) ProtoMessage()

func (*QueryStakersByPoolResponse) Reset

func (m *QueryStakersByPoolResponse) Reset()

func (*QueryStakersByPoolResponse) Size

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

func (*QueryStakersByPoolResponse) String

func (m *QueryStakersByPoolResponse) String() string

func (*QueryStakersByPoolResponse) Unmarshal

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

func (*QueryStakersByPoolResponse) XXX_DiscardUnknown

func (m *QueryStakersByPoolResponse) XXX_DiscardUnknown()

func (*QueryStakersByPoolResponse) XXX_Marshal

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

func (*QueryStakersByPoolResponse) XXX_Merge

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

func (*QueryStakersByPoolResponse) XXX_Size

func (m *QueryStakersByPoolResponse) XXX_Size() int

func (*QueryStakersByPoolResponse) XXX_Unmarshal

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

type QueryStakersClient

type QueryStakersClient interface {
	// Stakers queries for all stakers.
	Stakers(ctx context.Context, in *QueryStakersRequest, opts ...grpc.CallOption) (*QueryStakersResponse, error)
	// Staker queries for all stakers.
	Staker(ctx context.Context, in *QueryStakerRequest, opts ...grpc.CallOption) (*QueryStakerResponse, error)
	// StakersByPool queries for all stakers that are currently participating in the given pool
	StakersByPool(ctx context.Context, in *QueryStakersByPoolRequest, opts ...grpc.CallOption) (*QueryStakersByPoolResponse, error)
	// StakersByPool queries for all stakers and sorted them first by number of pools participating and
	// then by delegation
	StakersByPoolCount(ctx context.Context, in *QueryStakersByPoolCountRequest, opts ...grpc.CallOption) (*QueryStakersByPoolCountResponse, error)
}

QueryStakersClient is the client API for QueryStakers service.

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

func NewQueryStakersClient

func NewQueryStakersClient(cc grpc1.ClientConn) QueryStakersClient

type QueryStakersRequest

type QueryStakersRequest struct {
	// pagination defines an optional pagination for the request.
	Pagination *query.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
	// status looks whether a staker is participating in pools or not
	Status StakerStatus `protobuf:"varint,2,opt,name=status,proto3,enum=kyve.query.v1beta1.StakerStatus" json:"status,omitempty"`
	// search searches for moniker OR address
	Search string `protobuf:"bytes,3,opt,name=search,proto3" json:"search,omitempty"`
}

QueryStakersRequest is the request type for the Query/Stakers RPC method.

func (*QueryStakersRequest) Descriptor

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

func (*QueryStakersRequest) GetPagination

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

func (*QueryStakersRequest) GetSearch

func (m *QueryStakersRequest) GetSearch() string

func (*QueryStakersRequest) GetStatus

func (m *QueryStakersRequest) GetStatus() StakerStatus

func (*QueryStakersRequest) Marshal

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

func (*QueryStakersRequest) MarshalTo

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

func (*QueryStakersRequest) MarshalToSizedBuffer

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

func (*QueryStakersRequest) ProtoMessage

func (*QueryStakersRequest) ProtoMessage()

func (*QueryStakersRequest) Reset

func (m *QueryStakersRequest) Reset()

func (*QueryStakersRequest) Size

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

func (*QueryStakersRequest) String

func (m *QueryStakersRequest) String() string

func (*QueryStakersRequest) Unmarshal

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

func (*QueryStakersRequest) XXX_DiscardUnknown

func (m *QueryStakersRequest) XXX_DiscardUnknown()

func (*QueryStakersRequest) XXX_Marshal

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

func (*QueryStakersRequest) XXX_Merge

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

func (*QueryStakersRequest) XXX_Size

func (m *QueryStakersRequest) XXX_Size() int

func (*QueryStakersRequest) XXX_Unmarshal

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

type QueryStakersResponse

type QueryStakersResponse struct {
	// stakers ...
	Stakers []FullStaker `protobuf:"bytes,1,rep,name=stakers,proto3" json:"stakers"`
	// pagination defines the pagination in the response.
	Pagination *query.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
}

QueryStakersResponse is the response type for the Query/Stakers RPC method.

func (*QueryStakersResponse) Descriptor

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

func (*QueryStakersResponse) GetPagination

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

func (*QueryStakersResponse) GetStakers

func (m *QueryStakersResponse) GetStakers() []FullStaker

func (*QueryStakersResponse) Marshal

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

func (*QueryStakersResponse) MarshalTo

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

func (*QueryStakersResponse) MarshalToSizedBuffer

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

func (*QueryStakersResponse) ProtoMessage

func (*QueryStakersResponse) ProtoMessage()

func (*QueryStakersResponse) Reset

func (m *QueryStakersResponse) Reset()

func (*QueryStakersResponse) Size

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

func (*QueryStakersResponse) String

func (m *QueryStakersResponse) String() string

func (*QueryStakersResponse) Unmarshal

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

func (*QueryStakersResponse) XXX_DiscardUnknown

func (m *QueryStakersResponse) XXX_DiscardUnknown()

func (*QueryStakersResponse) XXX_Marshal

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

func (*QueryStakersResponse) XXX_Merge

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

func (*QueryStakersResponse) XXX_Size

func (m *QueryStakersResponse) XXX_Size() int

func (*QueryStakersResponse) XXX_Unmarshal

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

type QueryStakersServer

type QueryStakersServer interface {
	// Stakers queries for all stakers.
	Stakers(context.Context, *QueryStakersRequest) (*QueryStakersResponse, error)
	// Staker queries for all stakers.
	Staker(context.Context, *QueryStakerRequest) (*QueryStakerResponse, error)
	// StakersByPool queries for all stakers that are currently participating in the given pool
	StakersByPool(context.Context, *QueryStakersByPoolRequest) (*QueryStakersByPoolResponse, error)
	// StakersByPool queries for all stakers and sorted them first by number of pools participating and
	// then by delegation
	StakersByPoolCount(context.Context, *QueryStakersByPoolCountRequest) (*QueryStakersByPoolCountResponse, error)
}

QueryStakersServer is the server API for QueryStakers service.

type RedelegationEntry

type RedelegationEntry struct {
	// creation_date ...
	CreationDate uint64 `protobuf:"varint,1,opt,name=creation_date,json=creationDate,proto3" json:"creation_date,omitempty"`
	// finish_date ...
	FinishDate uint64 `protobuf:"varint,2,opt,name=finish_date,json=finishDate,proto3" json:"finish_date,omitempty"`
}

RedelegationEntry ...

func (*RedelegationEntry) Descriptor

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

func (*RedelegationEntry) GetCreationDate

func (m *RedelegationEntry) GetCreationDate() uint64

func (*RedelegationEntry) GetFinishDate

func (m *RedelegationEntry) GetFinishDate() uint64

func (*RedelegationEntry) Marshal

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

func (*RedelegationEntry) MarshalTo

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

func (*RedelegationEntry) MarshalToSizedBuffer

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

func (*RedelegationEntry) ProtoMessage

func (*RedelegationEntry) ProtoMessage()

func (*RedelegationEntry) Reset

func (m *RedelegationEntry) Reset()

func (*RedelegationEntry) Size

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

func (*RedelegationEntry) String

func (m *RedelegationEntry) String() string

func (*RedelegationEntry) Unmarshal

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

func (*RedelegationEntry) XXX_DiscardUnknown

func (m *RedelegationEntry) XXX_DiscardUnknown()

func (*RedelegationEntry) XXX_Marshal

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

func (*RedelegationEntry) XXX_Merge

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

func (*RedelegationEntry) XXX_Size

func (m *RedelegationEntry) XXX_Size() int

func (*RedelegationEntry) XXX_Unmarshal

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

type StakerDelegatorResponse

type StakerDelegatorResponse struct {
	// delegator ...
	Delegator string `protobuf:"bytes,1,opt,name=delegator,proto3" json:"delegator,omitempty"`
	// current_reward ...
	CurrentReward uint64 `protobuf:"varint,2,opt,name=current_reward,json=currentReward,proto3" json:"current_reward,omitempty"`
	// delegation_amount ...
	DelegationAmount uint64 `protobuf:"varint,3,opt,name=delegation_amount,json=delegationAmount,proto3" json:"delegation_amount,omitempty"`
	// staker ...
	Staker string `protobuf:"bytes,4,opt,name=staker,proto3" json:"staker,omitempty"`
}

StakerDelegatorResponse ...

func (*StakerDelegatorResponse) Descriptor

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

func (*StakerDelegatorResponse) GetCurrentReward

func (m *StakerDelegatorResponse) GetCurrentReward() uint64

func (*StakerDelegatorResponse) GetDelegationAmount

func (m *StakerDelegatorResponse) GetDelegationAmount() uint64

func (*StakerDelegatorResponse) GetDelegator

func (m *StakerDelegatorResponse) GetDelegator() string

func (*StakerDelegatorResponse) GetStaker

func (m *StakerDelegatorResponse) GetStaker() string

func (*StakerDelegatorResponse) Marshal

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

func (*StakerDelegatorResponse) MarshalTo

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

func (*StakerDelegatorResponse) MarshalToSizedBuffer

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

func (*StakerDelegatorResponse) ProtoMessage

func (*StakerDelegatorResponse) ProtoMessage()

func (*StakerDelegatorResponse) Reset

func (m *StakerDelegatorResponse) Reset()

func (*StakerDelegatorResponse) Size

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

func (*StakerDelegatorResponse) String

func (m *StakerDelegatorResponse) String() string

func (*StakerDelegatorResponse) Unmarshal

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

func (*StakerDelegatorResponse) XXX_DiscardUnknown

func (m *StakerDelegatorResponse) XXX_DiscardUnknown()

func (*StakerDelegatorResponse) XXX_Marshal

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

func (*StakerDelegatorResponse) XXX_Merge

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

func (*StakerDelegatorResponse) XXX_Size

func (m *StakerDelegatorResponse) XXX_Size() int

func (*StakerDelegatorResponse) XXX_Unmarshal

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

type StakerMetadata

type StakerMetadata struct {
	// commission is the percentage of the rewards that will
	// get transferred to the staker before the remaining
	// rewards are split across all delegators
	Commission string `protobuf:"bytes,1,opt,name=commission,proto3" json:"commission,omitempty"`
	// moniker is a human-readable name for displaying
	// the staker in the UI
	Moniker string `protobuf:"bytes,2,opt,name=moniker,proto3" json:"moniker,omitempty"`
	// website is a https-link to the website of the staker
	Website string `protobuf:"bytes,3,opt,name=website,proto3" json:"website,omitempty"`
	Logo string `protobuf:"bytes,4,opt,name=logo,proto3" json:"logo,omitempty"`
	// pending_commission_change shows if the staker plans
	// to change its commission. Delegators will see a warning in
	// the UI. A Commission change takes some time until
	// the commission is applied. Users have time to redelegate
	// if they not agree with the new commission.
	PendingCommissionChange *CommissionChangeEntry `` /* 132-byte string literal not displayed */
}

StakerMetadata contains static information for a staker

func (*StakerMetadata) Descriptor

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

func (*StakerMetadata) GetCommission

func (m *StakerMetadata) GetCommission() string
func (m *StakerMetadata) GetLogo() string

func (*StakerMetadata) GetMoniker

func (m *StakerMetadata) GetMoniker() string

func (*StakerMetadata) GetPendingCommissionChange

func (m *StakerMetadata) GetPendingCommissionChange() *CommissionChangeEntry

func (*StakerMetadata) GetWebsite

func (m *StakerMetadata) GetWebsite() string

func (*StakerMetadata) Marshal

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

func (*StakerMetadata) MarshalTo

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

func (*StakerMetadata) MarshalToSizedBuffer

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

func (*StakerMetadata) ProtoMessage

func (*StakerMetadata) ProtoMessage()

func (*StakerMetadata) Reset

func (m *StakerMetadata) Reset()

func (*StakerMetadata) Size

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

func (*StakerMetadata) String

func (m *StakerMetadata) String() string

func (*StakerMetadata) Unmarshal

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

func (*StakerMetadata) XXX_DiscardUnknown

func (m *StakerMetadata) XXX_DiscardUnknown()

func (*StakerMetadata) XXX_Marshal

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

func (*StakerMetadata) XXX_Merge

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

func (*StakerMetadata) XXX_Size

func (m *StakerMetadata) XXX_Size() int

func (*StakerMetadata) XXX_Unmarshal

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

type StakerPoolResponse

type StakerPoolResponse struct {
	// staker ...
	Staker *FullStaker `protobuf:"bytes,1,opt,name=staker,proto3" json:"staker,omitempty"`
	// valaccount ...
	Valaccount *types.Valaccount `protobuf:"bytes,2,opt,name=valaccount,proto3" json:"valaccount,omitempty"`
}

StakerPoolResponse ...

func (*StakerPoolResponse) Descriptor

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

func (*StakerPoolResponse) GetStaker

func (m *StakerPoolResponse) GetStaker() *FullStaker

func (*StakerPoolResponse) GetValaccount

func (m *StakerPoolResponse) GetValaccount() *types.Valaccount

func (*StakerPoolResponse) Marshal

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

func (*StakerPoolResponse) MarshalTo

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

func (*StakerPoolResponse) MarshalToSizedBuffer

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

func (*StakerPoolResponse) ProtoMessage

func (*StakerPoolResponse) ProtoMessage()

func (*StakerPoolResponse) Reset

func (m *StakerPoolResponse) Reset()

func (*StakerPoolResponse) Size

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

func (*StakerPoolResponse) String

func (m *StakerPoolResponse) String() string

func (*StakerPoolResponse) Unmarshal

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

func (*StakerPoolResponse) XXX_DiscardUnknown

func (m *StakerPoolResponse) XXX_DiscardUnknown()

func (*StakerPoolResponse) XXX_Marshal

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

func (*StakerPoolResponse) XXX_Merge

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

func (*StakerPoolResponse) XXX_Size

func (m *StakerPoolResponse) XXX_Size() int

func (*StakerPoolResponse) XXX_Unmarshal

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

type StakerStatus

type StakerStatus int32

StakerStatus ...

const (
	// STAKER_STATUS_UNSPECIFIED ...
	STAKER_STATUS_UNSPECIFIED StakerStatus = 0
	// STAKER_STATUS_ACTIVE ...
	STAKER_STATUS_ACTIVE StakerStatus = 1
	// STAKER_STATUS_INACTIVE ...
	STAKER_STATUS_INACTIVE StakerStatus = 2
)

func (StakerStatus) EnumDescriptor

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

func (StakerStatus) String

func (x StakerStatus) String() string

type UnimplementedQueryAccountServer

type UnimplementedQueryAccountServer struct {
}

UnimplementedQueryAccountServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryAccountServer) AccountAssets

func (*UnimplementedQueryAccountServer) AccountFundedList

func (*UnimplementedQueryAccountServer) AccountRedelegation

type UnimplementedQueryBundlesServer

type UnimplementedQueryBundlesServer struct {
}

UnimplementedQueryBundlesServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryBundlesServer) CanPropose

func (*UnimplementedQueryBundlesServer) CanValidate

func (*UnimplementedQueryBundlesServer) CanVote

func (*UnimplementedQueryBundlesServer) CurrentVoteStatus

func (*UnimplementedQueryBundlesServer) FinalizedBundle

func (*UnimplementedQueryBundlesServer) FinalizedBundles

type UnimplementedQueryDelegationServer

type UnimplementedQueryDelegationServer struct {
}

UnimplementedQueryDelegationServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryDelegationServer) Delegator

func (*UnimplementedQueryDelegationServer) DelegatorsByStaker

func (*UnimplementedQueryDelegationServer) StakersByDelegator

type UnimplementedQueryParamsServer

type UnimplementedQueryParamsServer struct {
}

UnimplementedQueryParamsServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryParamsServer) Params

type UnimplementedQueryPoolServer

type UnimplementedQueryPoolServer struct {
}

UnimplementedQueryPoolServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryPoolServer) Pool

func (*UnimplementedQueryPoolServer) Pools

type UnimplementedQueryStakersServer

type UnimplementedQueryStakersServer struct {
}

UnimplementedQueryStakersServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryStakersServer) Staker

func (*UnimplementedQueryStakersServer) Stakers

func (*UnimplementedQueryStakersServer) StakersByPool

func (*UnimplementedQueryStakersServer) StakersByPoolCount

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL