types

package
v1.4.0 Latest Latest
Warning

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

Go to latest
Published: Nov 17, 2023 License: MIT Imports: 32 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.

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 query
	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 (
	ErrInvalidLengthFunders        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowFunders          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupFunders = 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 FundingStatus_name = map[int32]string{
	0: "FUNDING_STATUS_UNSPECIFIED",
	1: "FUNDING_STATUS_ACTIVE",
	2: "FUNDING_STATUS_INACTIVE",
}
View Source
var FundingStatus_value = map[string]int32{
	"FUNDING_STATUS_UNSPECIFIED": 0,
	"FUNDING_STATUS_ACTIVE":      1,
	"FUNDING_STATUS_INACTIVE":    2,
}
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 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 RegisterQueryFundersHandler added in v1.4.0

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

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

func RegisterQueryFundersHandlerClient added in v1.4.0

func RegisterQueryFundersHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryFundersClient) error

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

func RegisterQueryFundersHandlerFromEndpoint added in v1.4.0

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

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

func RegisterQueryFundersHandlerServer added in v1.4.0

func RegisterQueryFundersHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryFundersServer) error

RegisterQueryFundersHandlerServer registers the http handlers for service QueryFunders to "mux". UnaryRPC :call QueryFundersServer 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 RegisterQueryFundersHandlerFromEndpoint instead.

func RegisterQueryFundersServer added in v1.4.0

func RegisterQueryFundersServer(s grpc1.Server, srv QueryFundersServer)

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"`
	// inflation_share_weight is the base payout for each bundle reward
	InflationShareWeight uint64 `protobuf:"varint,5,opt,name=inflation_share_weight,json=inflationShareWeight,proto3" json:"inflation_share_weight,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 (*BasicPool) GetInflationShareWeight added in v1.4.0

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

func (*BasicPool) GetName

func (m *BasicPool) GetName() string

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 github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,1,opt,name=commission,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"commission"`
	// 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) 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 FinalizedAt added in v1.2.3

type FinalizedAt struct {
	// height is the block height in which the bundle got finalized.
	Height *cosmossdk_io_math.Int `protobuf:"bytes,1,opt,name=height,proto3,customtype=cosmossdk.io/math.Int" json:"height,omitempty"`
	// timestamp is the UNIX timestamp of the block in which the bundle got finalized.
	Timestamp string `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

FinalizedAt stores information about finalization block and time.

func (*FinalizedAt) Descriptor added in v1.2.3

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

func (*FinalizedAt) GetTimestamp added in v1.2.3

func (m *FinalizedAt) GetTimestamp() string

func (*FinalizedAt) Marshal added in v1.2.3

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

func (*FinalizedAt) MarshalTo added in v1.2.3

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

func (*FinalizedAt) MarshalToSizedBuffer added in v1.2.3

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

func (*FinalizedAt) ProtoMessage added in v1.2.3

func (*FinalizedAt) ProtoMessage()

func (*FinalizedAt) Reset added in v1.2.3

func (m *FinalizedAt) Reset()

func (*FinalizedAt) Size added in v1.2.3

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

func (*FinalizedAt) String added in v1.2.3

func (m *FinalizedAt) String() string

func (*FinalizedAt) Unmarshal added in v1.2.3

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

func (*FinalizedAt) XXX_DiscardUnknown added in v1.2.3

func (m *FinalizedAt) XXX_DiscardUnknown()

func (*FinalizedAt) XXX_Marshal added in v1.2.3

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

func (*FinalizedAt) XXX_Merge added in v1.2.3

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

func (*FinalizedAt) XXX_Size added in v1.2.3

func (m *FinalizedAt) XXX_Size() int

func (*FinalizedAt) XXX_Unmarshal added in v1.2.3

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

type FinalizedBundle added in v1.2.3

type FinalizedBundle struct {
	// pool_id in which the bundle was created
	PoolId uint64 `protobuf:"varint,1,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// id is is integrated with each valid bundle produced.
	Id uint64 `protobuf:"varint,2,opt,name=id,proto3" json:"id,omitempty"`
	// storage_id is the id with which the data can be retrieved from the configured data provider
	StorageId string `protobuf:"bytes,3,opt,name=storage_id,json=storageId,proto3" json:"storage_id,omitempty"`
	// uploader is the address of the staker who submitted this bundle
	Uploader string `protobuf:"bytes,4,opt,name=uploader,proto3" json:"uploader,omitempty"`
	// from_index is the index from where the bundle starts (inclusive)
	FromIndex uint64 `protobuf:"varint,5,opt,name=from_index,json=fromIndex,proto3" json:"from_index,omitempty"`
	// to_index is the index to which the bundle goes (exclusive)
	ToIndex uint64 `protobuf:"varint,6,opt,name=to_index,json=toIndex,proto3" json:"to_index,omitempty"`
	// from_key is the key of the first data item in the bundle proposal
	FromKey string `protobuf:"bytes,11,opt,name=from_key,json=fromKey,proto3" json:"from_key,omitempty"`
	// to_key the key of the last data item in the bundle
	ToKey string `protobuf:"bytes,7,opt,name=to_key,json=toKey,proto3" json:"to_key,omitempty"`
	// bundle_summary is a summary of the bundle.
	BundleSummary string `protobuf:"bytes,8,opt,name=bundle_summary,json=bundleSummary,proto3" json:"bundle_summary,omitempty"`
	// data_hash is a sha256 hash of the uploaded data.
	DataHash string `protobuf:"bytes,9,opt,name=data_hash,json=dataHash,proto3" json:"data_hash,omitempty"`
	// finalized_at contains details of the block that finalized this bundle.
	FinalizedAt *FinalizedAt `protobuf:"bytes,10,opt,name=finalized_at,json=finalizedAt,proto3" json:"finalized_at,omitempty"`
	// storage_provider_id the id of the storage provider where the bundle is stored
	StorageProviderId uint64 `protobuf:"varint,12,opt,name=storage_provider_id,json=storageProviderId,proto3" json:"storage_provider_id,omitempty"`
	// compression_id the id of the compression type with which the data was compressed
	CompressionId uint64 `protobuf:"varint,13,opt,name=compression_id,json=compressionId,proto3" json:"compression_id,omitempty"`
	// stake_security defines the amount of stake which was present in the pool during the finalization of the bundle.
	// This field was added in schema version 2. Bundles finalized before that return `null`.
	StakeSecurity *StakeSecurity `protobuf:"bytes,14,opt,name=stake_security,json=stakeSecurity,proto3" json:"stake_security,omitempty"`
}

FinalizedBundle represents the latest version of a valid bundle of a pool

func (*FinalizedBundle) Descriptor added in v1.2.3

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

func (*FinalizedBundle) GetBundleSummary added in v1.2.3

func (m *FinalizedBundle) GetBundleSummary() string

func (*FinalizedBundle) GetCompressionId added in v1.2.3

func (m *FinalizedBundle) GetCompressionId() uint64

func (*FinalizedBundle) GetDataHash added in v1.2.3

func (m *FinalizedBundle) GetDataHash() string

func (*FinalizedBundle) GetFinalizedAt added in v1.2.3

func (m *FinalizedBundle) GetFinalizedAt() *FinalizedAt

func (*FinalizedBundle) GetFromIndex added in v1.2.3

func (m *FinalizedBundle) GetFromIndex() uint64

func (*FinalizedBundle) GetFromKey added in v1.2.3

func (m *FinalizedBundle) GetFromKey() string

func (*FinalizedBundle) GetId added in v1.2.3

func (m *FinalizedBundle) GetId() uint64

func (*FinalizedBundle) GetPoolId added in v1.2.3

func (m *FinalizedBundle) GetPoolId() uint64

func (*FinalizedBundle) GetStakeSecurity added in v1.2.3

func (m *FinalizedBundle) GetStakeSecurity() *StakeSecurity

func (*FinalizedBundle) GetStorageId added in v1.2.3

func (m *FinalizedBundle) GetStorageId() string

func (*FinalizedBundle) GetStorageProviderId added in v1.2.3

func (m *FinalizedBundle) GetStorageProviderId() uint64

func (*FinalizedBundle) GetToIndex added in v1.2.3

func (m *FinalizedBundle) GetToIndex() uint64

func (*FinalizedBundle) GetToKey added in v1.2.3

func (m *FinalizedBundle) GetToKey() string

func (*FinalizedBundle) GetUploader added in v1.2.3

func (m *FinalizedBundle) GetUploader() string

func (*FinalizedBundle) Marshal added in v1.2.3

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

func (*FinalizedBundle) MarshalTo added in v1.2.3

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

func (*FinalizedBundle) MarshalToSizedBuffer added in v1.2.3

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

func (*FinalizedBundle) ProtoMessage added in v1.2.3

func (*FinalizedBundle) ProtoMessage()

func (*FinalizedBundle) Reset added in v1.2.3

func (m *FinalizedBundle) Reset()

func (*FinalizedBundle) Size added in v1.2.3

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

func (*FinalizedBundle) String added in v1.2.3

func (m *FinalizedBundle) String() string

func (*FinalizedBundle) Unmarshal added in v1.2.3

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

func (*FinalizedBundle) XXX_DiscardUnknown added in v1.2.3

func (m *FinalizedBundle) XXX_DiscardUnknown()

func (*FinalizedBundle) XXX_Marshal added in v1.2.3

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

func (*FinalizedBundle) XXX_Merge added in v1.2.3

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

func (*FinalizedBundle) XXX_Size added in v1.2.3

func (m *FinalizedBundle) XXX_Size() int

func (*FinalizedBundle) XXX_Unmarshal added in v1.2.3

func (m *FinalizedBundle) 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 Funder added in v1.4.0

type Funder struct {
	// address ...
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// moniker ...
	Moniker string `protobuf:"bytes,2,opt,name=moniker,proto3" json:"moniker,omitempty"`
	// identity is the 64 bit keybase.io identity string
	Identity string `protobuf:"bytes,3,opt,name=identity,proto3" json:"identity,omitempty"`
	// website ...
	Website string `protobuf:"bytes,4,opt,name=website,proto3" json:"website,omitempty"`
	// contact ...
	Contact string `protobuf:"bytes,5,opt,name=contact,proto3" json:"contact,omitempty"`
	// description ...
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// statistics about all the fundings of the funder.
	Stats *FundingStats `protobuf:"bytes,7,opt,name=stats,proto3" json:"stats,omitempty"`
}

Funder ...

func (*Funder) Descriptor added in v1.4.0

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

func (*Funder) GetAddress added in v1.4.0

func (m *Funder) GetAddress() string

func (*Funder) GetContact added in v1.4.0

func (m *Funder) GetContact() string

func (*Funder) GetDescription added in v1.4.0

func (m *Funder) GetDescription() string

func (*Funder) GetIdentity added in v1.4.0

func (m *Funder) GetIdentity() string

func (*Funder) GetMoniker added in v1.4.0

func (m *Funder) GetMoniker() string

func (*Funder) GetStats added in v1.4.0

func (m *Funder) GetStats() *FundingStats

func (*Funder) GetWebsite added in v1.4.0

func (m *Funder) GetWebsite() string

func (*Funder) Marshal added in v1.4.0

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

func (*Funder) MarshalTo added in v1.4.0

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

func (*Funder) MarshalToSizedBuffer added in v1.4.0

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

func (*Funder) ProtoMessage added in v1.4.0

func (*Funder) ProtoMessage()

func (*Funder) Reset added in v1.4.0

func (m *Funder) Reset()

func (*Funder) Size added in v1.4.0

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

func (*Funder) String added in v1.4.0

func (m *Funder) String() string

func (*Funder) Unmarshal added in v1.4.0

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

func (*Funder) XXX_DiscardUnknown added in v1.4.0

func (m *Funder) XXX_DiscardUnknown()

func (*Funder) XXX_Marshal added in v1.4.0

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

func (*Funder) XXX_Merge added in v1.4.0

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

func (*Funder) XXX_Size added in v1.4.0

func (m *Funder) XXX_Size() int

func (*Funder) XXX_Unmarshal added in v1.4.0

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

type Funding added in v1.4.0

type Funding struct {
	// funder_address
	FunderAddress string `protobuf:"bytes,1,opt,name=funder_address,json=funderAddress,proto3" json:"funder_address,omitempty"`
	// pool_id ...
	PoolId uint64 `protobuf:"varint,2,opt,name=pool_id,json=poolId,proto3" json:"pool_id,omitempty"`
	// amount ...
	Amount uint64 `protobuf:"varint,3,opt,name=amount,proto3" json:"amount,omitempty"`
	// amount_per_bundle ...
	AmountPerBundle uint64 `protobuf:"varint,4,opt,name=amount_per_bundle,json=amountPerBundle,proto3" json:"amount_per_bundle,omitempty"`
	// total_funded ...
	TotalFunded uint64 `protobuf:"varint,5,opt,name=total_funded,json=totalFunded,proto3" json:"total_funded,omitempty"`
}

Funding ...

func (*Funding) Descriptor added in v1.4.0

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

func (*Funding) GetAmount added in v1.4.0

func (m *Funding) GetAmount() uint64

func (*Funding) GetAmountPerBundle added in v1.4.0

func (m *Funding) GetAmountPerBundle() uint64

func (*Funding) GetFunderAddress added in v1.4.0

func (m *Funding) GetFunderAddress() string

func (*Funding) GetPoolId added in v1.4.0

func (m *Funding) GetPoolId() uint64

func (*Funding) GetTotalFunded added in v1.4.0

func (m *Funding) GetTotalFunded() uint64

func (*Funding) Marshal added in v1.4.0

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

func (*Funding) MarshalTo added in v1.4.0

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

func (*Funding) MarshalToSizedBuffer added in v1.4.0

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

func (*Funding) ProtoMessage added in v1.4.0

func (*Funding) ProtoMessage()

func (*Funding) Reset added in v1.4.0

func (m *Funding) Reset()

func (*Funding) Size added in v1.4.0

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

func (*Funding) String added in v1.4.0

func (m *Funding) String() string

func (*Funding) Unmarshal added in v1.4.0

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

func (*Funding) XXX_DiscardUnknown added in v1.4.0

func (m *Funding) XXX_DiscardUnknown()

func (*Funding) XXX_Marshal added in v1.4.0

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

func (*Funding) XXX_Merge added in v1.4.0

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

func (*Funding) XXX_Size added in v1.4.0

func (m *Funding) XXX_Size() int

func (*Funding) XXX_Unmarshal added in v1.4.0

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

type FundingStats added in v1.4.0

type FundingStats struct {
	// total_used_funds are the total funds that have been distributed by the funder.
	TotalUsedFunds uint64 `protobuf:"varint,1,opt,name=total_used_funds,json=totalUsedFunds,proto3" json:"total_used_funds,omitempty"`
	// total_allocated_funds are the total funds that have been allocated by the funder. They can either get distributed or refunded.
	TotalAllocatedFunds uint64 `protobuf:"varint,2,opt,name=total_allocated_funds,json=totalAllocatedFunds,proto3" json:"total_allocated_funds,omitempty"`
	// total_amount_per_bundle is the total amount per bundle of all fundings of the funder.
	TotalAmountPerBundle uint64 `` /* 126-byte string literal not displayed */
	// pools_funded are the ids of the pools that have been funded by the funder.
	PoolsFunded []uint64 `protobuf:"varint,4,rep,packed,name=pools_funded,json=poolsFunded,proto3" json:"pools_funded,omitempty"`
}

FundingStats ...

func (*FundingStats) Descriptor added in v1.4.0

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

func (*FundingStats) GetPoolsFunded added in v1.4.0

func (m *FundingStats) GetPoolsFunded() []uint64

func (*FundingStats) GetTotalAllocatedFunds added in v1.4.0

func (m *FundingStats) GetTotalAllocatedFunds() uint64

func (*FundingStats) GetTotalAmountPerBundle added in v1.4.0

func (m *FundingStats) GetTotalAmountPerBundle() uint64

func (*FundingStats) GetTotalUsedFunds added in v1.4.0

func (m *FundingStats) GetTotalUsedFunds() uint64

func (*FundingStats) Marshal added in v1.4.0

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

func (*FundingStats) MarshalTo added in v1.4.0

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

func (*FundingStats) MarshalToSizedBuffer added in v1.4.0

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

func (*FundingStats) ProtoMessage added in v1.4.0

func (*FundingStats) ProtoMessage()

func (*FundingStats) Reset added in v1.4.0

func (m *FundingStats) Reset()

func (*FundingStats) Size added in v1.4.0

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

func (*FundingStats) String added in v1.4.0

func (m *FundingStats) String() string

func (*FundingStats) Unmarshal added in v1.4.0

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

func (*FundingStats) XXX_DiscardUnknown added in v1.4.0

func (m *FundingStats) XXX_DiscardUnknown()

func (*FundingStats) XXX_Marshal added in v1.4.0

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

func (*FundingStats) XXX_Merge added in v1.4.0

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

func (*FundingStats) XXX_Size added in v1.4.0

func (m *FundingStats) XXX_Size() int

func (*FundingStats) XXX_Unmarshal added in v1.4.0

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

type FundingStatus added in v1.4.0

type FundingStatus int32

FundingStatus ...

const (
	// FundingStatusUnspecified ...
	FUNDING_STATUS_UNSPECIFIED FundingStatus = 0
	// FundingStatusActive status is set when the funding is active.
	FUNDING_STATUS_ACTIVE FundingStatus = 1
	// FundingStatusInactive status is set when the funding has been used up or refunded.
	FUNDING_STATUS_INACTIVE FundingStatus = 2
)

func (FundingStatus) EnumDescriptor added in v1.4.0

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

func (FundingStatus) String added in v1.4.0

func (x FundingStatus) String() string

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"`
	// account ...
	Account string `protobuf:"bytes,8,opt,name=account,proto3" json:"account,omitempty"`
	// account_balance ...
	AccountBalance uint64 `protobuf:"varint,9,opt,name=account_balance,json=accountBalance,proto3" json:"account_balance,omitempty"`
}

PoolResponse ...

func (*PoolResponse) Descriptor

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

func (*PoolResponse) GetAccount added in v1.3.0

func (m *PoolResponse) GetAccount() string

func (*PoolResponse) GetAccountBalance added in v1.3.0

func (m *PoolResponse) GetAccountBalance() uint64

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 ...
	FinalizedBundlesQuery(ctx context.Context, in *QueryFinalizedBundlesRequest, opts ...grpc.CallOption) (*QueryFinalizedBundlesResponse, error)
	// FinalizedBundle ...
	FinalizedBundleQuery(ctx context.Context, in *QueryFinalizedBundleRequest, opts ...grpc.CallOption) (*FinalizedBundle, 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 ...
	FinalizedBundlesQuery(context.Context, *QueryFinalizedBundlesRequest) (*QueryFinalizedBundlesResponse, error)
	// FinalizedBundle ...
	FinalizedBundleQuery(context.Context, *QueryFinalizedBundleRequest) (*FinalizedBundle, 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_bundles ...
	FinalizedBundles FinalizedBundle `protobuf:"bytes,1,opt,name=finalized_bundles,json=finalizedBundles,proto3" json:"finalized_bundles"`
}

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

func (*QueryFinalizedBundleResponse) Descriptor

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

func (*QueryFinalizedBundleResponse) GetFinalizedBundles added in v1.2.3

func (m *QueryFinalizedBundleResponse) GetFinalizedBundles() 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 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"`
	// index is an optional parameter which tells the server to only show
	// the bundle with the given index. This can not be combined with pagination.
	Index string `protobuf:"bytes,3,opt,name=index,proto3" json:"index,omitempty"`
}

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

func (*QueryFinalizedBundlesRequest) Descriptor

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

func (*QueryFinalizedBundlesRequest) GetIndex added in v1.2.3

func (m *QueryFinalizedBundlesRequest) GetIndex() string

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 []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() []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 QueryFunderRequest added in v1.4.0

type QueryFunderRequest struct {
	// address ...
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// status ...
	Status FundingStatus `protobuf:"varint,3,opt,name=status,proto3,enum=kyve.query.v1beta1.FundingStatus" json:"status,omitempty"`
}

QueryFunderRequest is the request type for the Query/Funder RPC method.

func (*QueryFunderRequest) Descriptor added in v1.4.0

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

func (*QueryFunderRequest) GetAddress added in v1.4.0

func (m *QueryFunderRequest) GetAddress() string

func (*QueryFunderRequest) GetStatus added in v1.4.0

func (m *QueryFunderRequest) GetStatus() FundingStatus

func (*QueryFunderRequest) Marshal added in v1.4.0

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

func (*QueryFunderRequest) MarshalTo added in v1.4.0

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

func (*QueryFunderRequest) MarshalToSizedBuffer added in v1.4.0

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

func (*QueryFunderRequest) ProtoMessage added in v1.4.0

func (*QueryFunderRequest) ProtoMessage()

func (*QueryFunderRequest) Reset added in v1.4.0

func (m *QueryFunderRequest) Reset()

func (*QueryFunderRequest) Size added in v1.4.0

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

func (*QueryFunderRequest) String added in v1.4.0

func (m *QueryFunderRequest) String() string

func (*QueryFunderRequest) Unmarshal added in v1.4.0

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

func (*QueryFunderRequest) XXX_DiscardUnknown added in v1.4.0

func (m *QueryFunderRequest) XXX_DiscardUnknown()

func (*QueryFunderRequest) XXX_Marshal added in v1.4.0

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

func (*QueryFunderRequest) XXX_Merge added in v1.4.0

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

func (*QueryFunderRequest) XXX_Size added in v1.4.0

func (m *QueryFunderRequest) XXX_Size() int

func (*QueryFunderRequest) XXX_Unmarshal added in v1.4.0

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

type QueryFunderResponse added in v1.4.0

type QueryFunderResponse struct {
	// funder ...
	Funder *Funder `protobuf:"bytes,1,opt,name=funder,proto3" json:"funder,omitempty"`
	// fundings ...
	Fundings []Funding `protobuf:"bytes,2,rep,name=fundings,proto3" json:"fundings"`
}

QueryFunderResponse is the response type for the Query/Funder RPC method.

func (*QueryFunderResponse) Descriptor added in v1.4.0

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

func (*QueryFunderResponse) GetFunder added in v1.4.0

func (m *QueryFunderResponse) GetFunder() *Funder

func (*QueryFunderResponse) GetFundings added in v1.4.0

func (m *QueryFunderResponse) GetFundings() []Funding

func (*QueryFunderResponse) Marshal added in v1.4.0

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

func (*QueryFunderResponse) MarshalTo added in v1.4.0

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

func (*QueryFunderResponse) MarshalToSizedBuffer added in v1.4.0

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

func (*QueryFunderResponse) ProtoMessage added in v1.4.0

func (*QueryFunderResponse) ProtoMessage()

func (*QueryFunderResponse) Reset added in v1.4.0

func (m *QueryFunderResponse) Reset()

func (*QueryFunderResponse) Size added in v1.4.0

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

func (*QueryFunderResponse) String added in v1.4.0

func (m *QueryFunderResponse) String() string

func (*QueryFunderResponse) Unmarshal added in v1.4.0

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

func (*QueryFunderResponse) XXX_DiscardUnknown added in v1.4.0

func (m *QueryFunderResponse) XXX_DiscardUnknown()

func (*QueryFunderResponse) XXX_Marshal added in v1.4.0

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

func (*QueryFunderResponse) XXX_Merge added in v1.4.0

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

func (*QueryFunderResponse) XXX_Size added in v1.4.0

func (m *QueryFunderResponse) XXX_Size() int

func (*QueryFunderResponse) XXX_Unmarshal added in v1.4.0

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

type QueryFundersClient added in v1.4.0

type QueryFundersClient interface {
	// Funders queries all funders.
	Funders(ctx context.Context, in *QueryFundersRequest, opts ...grpc.CallOption) (*QueryFundersResponse, error)
	// Funder queries a funder by address.
	Funder(ctx context.Context, in *QueryFunderRequest, opts ...grpc.CallOption) (*QueryFunderResponse, error)
	// FundingsByFunder queries all fundings of a funder by address.
	FundingsByFunder(ctx context.Context, in *QueryFundingsByFunderRequest, opts ...grpc.CallOption) (*QueryFundingsByFunderResponse, error)
	// FundingsByPool queries all fundings of a pool by id.
	FundingsByPool(ctx context.Context, in *QueryFundingsByPoolRequest, opts ...grpc.CallOption) (*QueryFundingsByPoolResponse, error)
}

QueryFundersClient is the client API for QueryFunders service.

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

func NewQueryFundersClient added in v1.4.0

func NewQueryFundersClient(cc grpc1.ClientConn) QueryFundersClient

type QueryFundersRequest added in v1.4.0

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

QueryFundersRequest is the request type for the Query/Funders RPC method.

func (*QueryFundersRequest) Descriptor added in v1.4.0

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

func (*QueryFundersRequest) GetPagination added in v1.4.0

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

func (*QueryFundersRequest) GetSearch added in v1.4.0

func (m *QueryFundersRequest) GetSearch() string

func (*QueryFundersRequest) Marshal added in v1.4.0

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

func (*QueryFundersRequest) MarshalTo added in v1.4.0

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

func (*QueryFundersRequest) MarshalToSizedBuffer added in v1.4.0

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

func (*QueryFundersRequest) ProtoMessage added in v1.4.0

func (*QueryFundersRequest) ProtoMessage()

func (*QueryFundersRequest) Reset added in v1.4.0

func (m *QueryFundersRequest) Reset()

func (*QueryFundersRequest) Size added in v1.4.0

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

func (*QueryFundersRequest) String added in v1.4.0

func (m *QueryFundersRequest) String() string

func (*QueryFundersRequest) Unmarshal added in v1.4.0

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

func (*QueryFundersRequest) XXX_DiscardUnknown added in v1.4.0

func (m *QueryFundersRequest) XXX_DiscardUnknown()

func (*QueryFundersRequest) XXX_Marshal added in v1.4.0

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

func (*QueryFundersRequest) XXX_Merge added in v1.4.0

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

func (*QueryFundersRequest) XXX_Size added in v1.4.0

func (m *QueryFundersRequest) XXX_Size() int

func (*QueryFundersRequest) XXX_Unmarshal added in v1.4.0

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

type QueryFundersResponse added in v1.4.0

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

QueryFundersResponse is the response type for the Query/Funders RPC method.

func (*QueryFundersResponse) Descriptor added in v1.4.0

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

func (*QueryFundersResponse) GetFunders added in v1.4.0

func (m *QueryFundersResponse) GetFunders() []Funder

func (*QueryFundersResponse) GetPagination added in v1.4.0

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

func (*QueryFundersResponse) Marshal added in v1.4.0

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

func (*QueryFundersResponse) MarshalTo added in v1.4.0

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

func (*QueryFundersResponse) MarshalToSizedBuffer added in v1.4.0

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

func (*QueryFundersResponse) ProtoMessage added in v1.4.0

func (*QueryFundersResponse) ProtoMessage()

func (*QueryFundersResponse) Reset added in v1.4.0

func (m *QueryFundersResponse) Reset()

func (*QueryFundersResponse) Size added in v1.4.0

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

func (*QueryFundersResponse) String added in v1.4.0

func (m *QueryFundersResponse) String() string

func (*QueryFundersResponse) Unmarshal added in v1.4.0

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

func (*QueryFundersResponse) XXX_DiscardUnknown added in v1.4.0

func (m *QueryFundersResponse) XXX_DiscardUnknown()

func (*QueryFundersResponse) XXX_Marshal added in v1.4.0

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

func (*QueryFundersResponse) XXX_Merge added in v1.4.0

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

func (*QueryFundersResponse) XXX_Size added in v1.4.0

func (m *QueryFundersResponse) XXX_Size() int

func (*QueryFundersResponse) XXX_Unmarshal added in v1.4.0

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

type QueryFundersServer added in v1.4.0

type QueryFundersServer interface {
	// Funders queries all funders.
	Funders(context.Context, *QueryFundersRequest) (*QueryFundersResponse, error)
	// Funder queries a funder by address.
	Funder(context.Context, *QueryFunderRequest) (*QueryFunderResponse, error)
	// FundingsByFunder queries all fundings of a funder by address.
	FundingsByFunder(context.Context, *QueryFundingsByFunderRequest) (*QueryFundingsByFunderResponse, error)
	// FundingsByPool queries all fundings of a pool by id.
	FundingsByPool(context.Context, *QueryFundingsByPoolRequest) (*QueryFundingsByPoolResponse, error)
}

QueryFundersServer is the server API for QueryFunders service.

type QueryFundingsByFunderRequest added in v1.4.0

type QueryFundingsByFunderRequest 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"`
	// status ...
	Status FundingStatus `protobuf:"varint,3,opt,name=status,proto3,enum=kyve.query.v1beta1.FundingStatus" json:"status,omitempty"`
}

QueryFundingsByFunderRequest is the request type for the Query/FundingsByFunder RPC method.

func (*QueryFundingsByFunderRequest) Descriptor added in v1.4.0

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

func (*QueryFundingsByFunderRequest) GetAddress added in v1.4.0

func (m *QueryFundingsByFunderRequest) GetAddress() string

func (*QueryFundingsByFunderRequest) GetPagination added in v1.4.0

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

func (*QueryFundingsByFunderRequest) GetStatus added in v1.4.0

func (*QueryFundingsByFunderRequest) Marshal added in v1.4.0

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

func (*QueryFundingsByFunderRequest) MarshalTo added in v1.4.0

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

func (*QueryFundingsByFunderRequest) MarshalToSizedBuffer added in v1.4.0

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

func (*QueryFundingsByFunderRequest) ProtoMessage added in v1.4.0

func (*QueryFundingsByFunderRequest) ProtoMessage()

func (*QueryFundingsByFunderRequest) Reset added in v1.4.0

func (m *QueryFundingsByFunderRequest) Reset()

func (*QueryFundingsByFunderRequest) Size added in v1.4.0

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

func (*QueryFundingsByFunderRequest) String added in v1.4.0

func (*QueryFundingsByFunderRequest) Unmarshal added in v1.4.0

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

func (*QueryFundingsByFunderRequest) XXX_DiscardUnknown added in v1.4.0

func (m *QueryFundingsByFunderRequest) XXX_DiscardUnknown()

func (*QueryFundingsByFunderRequest) XXX_Marshal added in v1.4.0

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

func (*QueryFundingsByFunderRequest) XXX_Merge added in v1.4.0

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

func (*QueryFundingsByFunderRequest) XXX_Size added in v1.4.0

func (m *QueryFundingsByFunderRequest) XXX_Size() int

func (*QueryFundingsByFunderRequest) XXX_Unmarshal added in v1.4.0

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

type QueryFundingsByFunderResponse added in v1.4.0

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

QueryFundingsByFunderResponse is the response type for the Query/FundingsByFunder RPC method.

func (*QueryFundingsByFunderResponse) Descriptor added in v1.4.0

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

func (*QueryFundingsByFunderResponse) GetFundings added in v1.4.0

func (m *QueryFundingsByFunderResponse) GetFundings() []Funding

func (*QueryFundingsByFunderResponse) GetPagination added in v1.4.0

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

func (*QueryFundingsByFunderResponse) Marshal added in v1.4.0

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

func (*QueryFundingsByFunderResponse) MarshalTo added in v1.4.0

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

func (*QueryFundingsByFunderResponse) MarshalToSizedBuffer added in v1.4.0

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

func (*QueryFundingsByFunderResponse) ProtoMessage added in v1.4.0

func (*QueryFundingsByFunderResponse) ProtoMessage()

func (*QueryFundingsByFunderResponse) Reset added in v1.4.0

func (m *QueryFundingsByFunderResponse) Reset()

func (*QueryFundingsByFunderResponse) Size added in v1.4.0

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

func (*QueryFundingsByFunderResponse) String added in v1.4.0

func (*QueryFundingsByFunderResponse) Unmarshal added in v1.4.0

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

func (*QueryFundingsByFunderResponse) XXX_DiscardUnknown added in v1.4.0

func (m *QueryFundingsByFunderResponse) XXX_DiscardUnknown()

func (*QueryFundingsByFunderResponse) XXX_Marshal added in v1.4.0

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

func (*QueryFundingsByFunderResponse) XXX_Merge added in v1.4.0

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

func (*QueryFundingsByFunderResponse) XXX_Size added in v1.4.0

func (m *QueryFundingsByFunderResponse) XXX_Size() int

func (*QueryFundingsByFunderResponse) XXX_Unmarshal added in v1.4.0

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

type QueryFundingsByPoolRequest added in v1.4.0

type QueryFundingsByPoolRequest 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"`
	// status ...
	Status FundingStatus `protobuf:"varint,3,opt,name=status,proto3,enum=kyve.query.v1beta1.FundingStatus" json:"status,omitempty"`
}

QueryFundingsByPoolRequest is the request type for the Query/FundingsByPool RPC method.

func (*QueryFundingsByPoolRequest) Descriptor added in v1.4.0

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

func (*QueryFundingsByPoolRequest) GetPagination added in v1.4.0

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

func (*QueryFundingsByPoolRequest) GetPoolId added in v1.4.0

func (m *QueryFundingsByPoolRequest) GetPoolId() uint64

func (*QueryFundingsByPoolRequest) GetStatus added in v1.4.0

func (*QueryFundingsByPoolRequest) Marshal added in v1.4.0

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

func (*QueryFundingsByPoolRequest) MarshalTo added in v1.4.0

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

func (*QueryFundingsByPoolRequest) MarshalToSizedBuffer added in v1.4.0

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

func (*QueryFundingsByPoolRequest) ProtoMessage added in v1.4.0

func (*QueryFundingsByPoolRequest) ProtoMessage()

func (*QueryFundingsByPoolRequest) Reset added in v1.4.0

func (m *QueryFundingsByPoolRequest) Reset()

func (*QueryFundingsByPoolRequest) Size added in v1.4.0

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

func (*QueryFundingsByPoolRequest) String added in v1.4.0

func (m *QueryFundingsByPoolRequest) String() string

func (*QueryFundingsByPoolRequest) Unmarshal added in v1.4.0

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

func (*QueryFundingsByPoolRequest) XXX_DiscardUnknown added in v1.4.0

func (m *QueryFundingsByPoolRequest) XXX_DiscardUnknown()

func (*QueryFundingsByPoolRequest) XXX_Marshal added in v1.4.0

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

func (*QueryFundingsByPoolRequest) XXX_Merge added in v1.4.0

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

func (*QueryFundingsByPoolRequest) XXX_Size added in v1.4.0

func (m *QueryFundingsByPoolRequest) XXX_Size() int

func (*QueryFundingsByPoolRequest) XXX_Unmarshal added in v1.4.0

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

type QueryFundingsByPoolResponse added in v1.4.0

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

QueryFundingsByPoolResponse is the response type for the Query/FundingsByPool RPC method.

func (*QueryFundingsByPoolResponse) Descriptor added in v1.4.0

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

func (*QueryFundingsByPoolResponse) GetFundings added in v1.4.0

func (m *QueryFundingsByPoolResponse) GetFundings() []Funding

func (*QueryFundingsByPoolResponse) GetPagination added in v1.4.0

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

func (*QueryFundingsByPoolResponse) Marshal added in v1.4.0

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

func (*QueryFundingsByPoolResponse) MarshalTo added in v1.4.0

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

func (*QueryFundingsByPoolResponse) MarshalToSizedBuffer added in v1.4.0

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

func (*QueryFundingsByPoolResponse) ProtoMessage added in v1.4.0

func (*QueryFundingsByPoolResponse) ProtoMessage()

func (*QueryFundingsByPoolResponse) Reset added in v1.4.0

func (m *QueryFundingsByPoolResponse) Reset()

func (*QueryFundingsByPoolResponse) Size added in v1.4.0

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

func (*QueryFundingsByPoolResponse) String added in v1.4.0

func (m *QueryFundingsByPoolResponse) String() string

func (*QueryFundingsByPoolResponse) Unmarshal added in v1.4.0

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

func (*QueryFundingsByPoolResponse) XXX_DiscardUnknown added in v1.4.0

func (m *QueryFundingsByPoolResponse) XXX_DiscardUnknown()

func (*QueryFundingsByPoolResponse) XXX_Marshal added in v1.4.0

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

func (*QueryFundingsByPoolResponse) XXX_Merge added in v1.4.0

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

func (*QueryFundingsByPoolResponse) XXX_Size added in v1.4.0

func (m *QueryFundingsByPoolResponse) XXX_Size() int

func (*QueryFundingsByPoolResponse) XXX_Unmarshal added in v1.4.0

func (m *QueryFundingsByPoolResponse) 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.Params `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"`
	// pool_params ...
	PoolParams *types4.Params `protobuf:"bytes,6,opt,name=pool_params,json=poolParams,proto3" json:"pool_params,omitempty"`
	// funders_params ...
	FundersParams *types5.Params `protobuf:"bytes,7,opt,name=funders_params,json=fundersParams,proto3" json:"funders_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) GetFundersParams added in v1.4.0

func (m *QueryParamsResponse) GetFundersParams() *types5.Params

func (*QueryParamsResponse) GetGlobalParams

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

func (*QueryParamsResponse) GetGovParams

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

func (*QueryParamsResponse) GetPoolParams added in v1.3.0

func (m *QueryParamsResponse) GetPoolParams() *types4.Params

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 StakeSecurity added in v1.2.3

type StakeSecurity struct {
	// valid_vote_power gives the amount of $KYVE stake that voted `valid`.
	ValidVotePower *cosmossdk_io_math.Int `` /* 138-byte string literal not displayed */
	// total_vote_power gives the amount of total $KYVE stake that was present in the pool
	// during finalization.
	TotalVotePower *cosmossdk_io_math.Int `` /* 138-byte string literal not displayed */
}

StakeSecurity represents the relative security of a finalized bundle

func (*StakeSecurity) Descriptor added in v1.2.3

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

func (*StakeSecurity) Marshal added in v1.2.3

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

func (*StakeSecurity) MarshalTo added in v1.2.3

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

func (*StakeSecurity) MarshalToSizedBuffer added in v1.2.3

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

func (*StakeSecurity) ProtoMessage added in v1.2.3

func (*StakeSecurity) ProtoMessage()

func (*StakeSecurity) Reset added in v1.2.3

func (m *StakeSecurity) Reset()

func (*StakeSecurity) Size added in v1.2.3

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

func (*StakeSecurity) String added in v1.2.3

func (m *StakeSecurity) String() string

func (*StakeSecurity) Unmarshal added in v1.2.3

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

func (*StakeSecurity) XXX_DiscardUnknown added in v1.2.3

func (m *StakeSecurity) XXX_DiscardUnknown()

func (*StakeSecurity) XXX_Marshal added in v1.2.3

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

func (*StakeSecurity) XXX_Merge added in v1.2.3

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

func (*StakeSecurity) XXX_Size added in v1.2.3

func (m *StakeSecurity) XXX_Size() int

func (*StakeSecurity) XXX_Unmarshal added in v1.2.3

func (m *StakeSecurity) 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 github_com_cosmos_cosmos_sdk_types.Dec `protobuf:"bytes,1,opt,name=commission,proto3,customtype=github.com/cosmos/cosmos-sdk/types.Dec" json:"commission"`
	// 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"`
	// identity from keybase.io
	Identity string `protobuf:"bytes,4,opt,name=identity,proto3" json:"identity,omitempty"`
	// security_contact ...
	SecurityContact string `protobuf:"bytes,5,opt,name=security_contact,json=securityContact,proto3" json:"security_contact,omitempty"`
	// details ...
	Details string `protobuf:"bytes,6,opt,name=details,proto3" json:"details,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 */
	// commission_rewards are the rewards in $KYVE earned through commission
	CommissionRewards uint64 `protobuf:"varint,8,opt,name=commission_rewards,json=commissionRewards,proto3" json:"commission_rewards,omitempty"`
}

StakerMetadata contains static information for a staker

func (*StakerMetadata) Descriptor

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

func (*StakerMetadata) GetCommissionRewards added in v1.3.0

func (m *StakerMetadata) GetCommissionRewards() uint64

func (*StakerMetadata) GetDetails added in v1.1.0

func (m *StakerMetadata) GetDetails() string

func (*StakerMetadata) GetIdentity added in v1.1.0

func (m *StakerMetadata) GetIdentity() string

func (*StakerMetadata) GetMoniker

func (m *StakerMetadata) GetMoniker() string

func (*StakerMetadata) GetPendingCommissionChange

func (m *StakerMetadata) GetPendingCommissionChange() *CommissionChangeEntry

func (*StakerMetadata) GetSecurityContact added in v1.1.0

func (m *StakerMetadata) GetSecurityContact() string

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) FinalizedBundleQuery added in v1.2.3

func (*UnimplementedQueryBundlesServer) FinalizedBundlesQuery added in v1.2.3

type UnimplementedQueryDelegationServer

type UnimplementedQueryDelegationServer struct {
}

UnimplementedQueryDelegationServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryDelegationServer) Delegator

func (*UnimplementedQueryDelegationServer) DelegatorsByStaker

func (*UnimplementedQueryDelegationServer) StakersByDelegator

type UnimplementedQueryFundersServer added in v1.4.0

type UnimplementedQueryFundersServer struct {
}

UnimplementedQueryFundersServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryFundersServer) Funder added in v1.4.0

func (*UnimplementedQueryFundersServer) Funders added in v1.4.0

func (*UnimplementedQueryFundersServer) FundingsByFunder added in v1.4.0

func (*UnimplementedQueryFundersServer) FundingsByPool added in v1.4.0

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