emissions

package

Go to main page

Versions in this module

v0

v0.1.0-dev.a53b6d4

May 11, 2024

v0.0.10

Apr 1, 2024

v0.0.9

Apr 1, 2024

v0.0.8

Mar 19, 2024

v0.0.7

Mar 15, 2024

v0.0.6

Mar 14, 2024

v0.0.5

Mar 13, 2024

v0.0.4

Mar 12, 2024

Changes in this version

+ const AlloraRequestsAccountName

+ const AlloraRewardsAccountName

+ const AlloraStakingAccountName

+ var ChurnReadyTopicsKey = collections.NewPrefix(30)

+ var ErrInferenceRequestNotInMempool = errors.Register(ModuleName, 54, "inference request not in mempool")

+ var ErrInvalidRequestId = errors.Register(ModuleName, 53, "invalid request ID")

+ func DefaultCoreTeamAddresses() []string

+ func DefaultParamsEpochLength() int64

+ func DefaultParamsMaxInferenceRequestValidity() uint64

+ func DefaultParamsMaxMissingInferencePercent() cosmosMath.LegacyDec

+ func DefaultParamsMaxRequestCadence() uint64

+ func DefaultParamsMaxTopicsPerBlock() uint64

+ func DefaultParamsMinRequestCadence() uint64

+ func DefaultParamsMinRequestUnmetDemand() cosmosMath.Uint

+ func DefaultParamsMinTopicUnmetDemand() cosmosMath.Uint

+ func DefaultParamsMinWeightCadence() uint64

+ func DefaultParamsRemoveStakeDelayWindow() uint64

+ func DefaultParamsRequiredMinimumStake() cosmosMath.Uint

+ func DefaultParamsVersion() string

+ func IsValidRequestId(requestId string) bool

type GenesisState

+ CoreTeamAddresses []string

+ func (m *GenesisState) GetCoreTeamAddresses() []string

+ type InferenceRequestAndDemandLeft struct

+ DemandLeft cosmossdk_io_math.Uint

+ InferenceRequest *InferenceRequest

+ func (*InferenceRequestAndDemandLeft) Descriptor() ([]byte, []int)

+ func (*InferenceRequestAndDemandLeft) ProtoMessage()

+ func (m *InferenceRequestAndDemandLeft) GetInferenceRequest() *InferenceRequest

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

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

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

+ func (m *InferenceRequestAndDemandLeft) Reset()

+ func (m *InferenceRequestAndDemandLeft) Size() (n int)

+ func (m *InferenceRequestAndDemandLeft) String() string

+ func (m *InferenceRequestAndDemandLeft) Unmarshal(dAtA []byte) error

+ func (m *InferenceRequestAndDemandLeft) XXX_DiscardUnknown()

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

+ func (m *InferenceRequestAndDemandLeft) XXX_Merge(src proto.Message)

+ func (m *InferenceRequestAndDemandLeft) XXX_Size() int

+ func (m *InferenceRequestAndDemandLeft) XXX_Unmarshal(b []byte) error

type MsgClient

+ UpdateParams func(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)

type MsgRegister

+ TopicIds []uint64

+ func (m *MsgRegister) GetTopicIds() []uint64

type MsgServer

+ UpdateParams func(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

+ type MsgUpdateParams struct

+ Params *OptionalParams

+ Sender string

+ func (*MsgUpdateParams) Descriptor() ([]byte, []int)

+ func (*MsgUpdateParams) ProtoMessage()

+ func (m *MsgUpdateParams) GetParams() *OptionalParams

+ func (m *MsgUpdateParams) GetSender() string

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

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

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

+ func (m *MsgUpdateParams) Reset()

+ func (m *MsgUpdateParams) Size() (n int)

+ func (m *MsgUpdateParams) String() string

+ func (m *MsgUpdateParams) Unmarshal(dAtA []byte) error

+ func (m *MsgUpdateParams) XXX_DiscardUnknown()

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

+ func (m *MsgUpdateParams) XXX_Merge(src proto.Message)

+ func (m *MsgUpdateParams) XXX_Size() int

+ func (m *MsgUpdateParams) XXX_Unmarshal(b []byte) error

+ type MsgUpdateParamsResponse struct

+ func (*MsgUpdateParamsResponse) Descriptor() ([]byte, []int)

+ func (*MsgUpdateParamsResponse) ProtoMessage()

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

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

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

+ func (m *MsgUpdateParamsResponse) Reset()

+ func (m *MsgUpdateParamsResponse) Size() (n int)

+ func (m *MsgUpdateParamsResponse) String() string

+ func (m *MsgUpdateParamsResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

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

+ func (m *MsgUpdateParamsResponse) XXX_Merge(src proto.Message)

+ func (m *MsgUpdateParamsResponse) XXX_Size() int

+ func (m *MsgUpdateParamsResponse) XXX_Unmarshal(b []byte) error

+ type OptionalParams struct

+ EpochLength []int64

+ MaxInferenceRequestValidity []uint64

+ MaxMissingInferencePercent []cosmossdk_io_math.LegacyDec

+ MaxRequestCadence []uint64

+ MaxTopicsPerBlock []uint64

+ MinRequestCadence []uint64

+ MinRequestUnmetDemand []cosmossdk_io_math.Uint

+ MinTopicUnmetDemand []cosmossdk_io_math.Uint

+ MinWeightCadence []uint64

+ PercentRewardsReputersWorkers []cosmossdk_io_math.LegacyDec

+ RemoveStakeDelayWindow []uint64

+ RequiredMinimumStake []cosmossdk_io_math.Uint

+ Version []string

+ func (*OptionalParams) Descriptor() ([]byte, []int)

+ func (*OptionalParams) ProtoMessage()

+ func (m *OptionalParams) GetEpochLength() []int64

+ func (m *OptionalParams) GetMaxInferenceRequestValidity() []uint64

+ func (m *OptionalParams) GetMaxRequestCadence() []uint64

+ func (m *OptionalParams) GetMaxTopicsPerBlock() []uint64

+ func (m *OptionalParams) GetMinRequestCadence() []uint64

+ func (m *OptionalParams) GetMinWeightCadence() []uint64

+ func (m *OptionalParams) GetRemoveStakeDelayWindow() []uint64

+ func (m *OptionalParams) GetVersion() []string

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

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

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

+ func (m *OptionalParams) Reset()

+ func (m *OptionalParams) Size() (n int)

+ func (m *OptionalParams) String() string

+ func (m *OptionalParams) Unmarshal(dAtA []byte) error

+ func (m *OptionalParams) XXX_DiscardUnknown()

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

+ func (m *OptionalParams) XXX_Merge(src proto.Message)

+ func (m *OptionalParams) XXX_Size() int

+ func (m *OptionalParams) XXX_Unmarshal(b []byte) error

type Params

+ EpochLength int64

+ MaxInferenceRequestValidity uint64

+ MaxMissingInferencePercent cosmossdk_io_math.LegacyDec

+ MaxRequestCadence uint64

+ MaxTopicsPerBlock uint64

+ MinRequestCadence uint64

+ MinRequestUnmetDemand cosmossdk_io_math.Uint

+ MinTopicUnmetDemand cosmossdk_io_math.Uint

+ MinWeightCadence uint64

+ PercentRewardsReputersWorkers cosmossdk_io_math.LegacyDec

+ RemoveStakeDelayWindow uint64

+ RequiredMinimumStake cosmossdk_io_math.Uint

+ func (m *Params) GetEpochLength() int64

+ func (m *Params) GetMaxInferenceRequestValidity() uint64

+ func (m *Params) GetMaxRequestCadence() uint64

+ func (m *Params) GetMaxTopicsPerBlock() uint64

+ func (m *Params) GetMinRequestCadence() uint64

+ func (m *Params) GetMinWeightCadence() uint64

+ func (m *Params) GetRemoveStakeDelayWindow() uint64

+ type QueryAllExistingInferenceRequest struct

+ func (*QueryAllExistingInferenceRequest) Descriptor() ([]byte, []int)

+ func (*QueryAllExistingInferenceRequest) ProtoMessage()

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

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

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

+ func (m *QueryAllExistingInferenceRequest) Reset()

+ func (m *QueryAllExistingInferenceRequest) Size() (n int)

+ func (m *QueryAllExistingInferenceRequest) String() string

+ func (m *QueryAllExistingInferenceRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryAllExistingInferenceRequest) XXX_DiscardUnknown()

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

+ func (m *QueryAllExistingInferenceRequest) XXX_Merge(src proto.Message)

+ func (m *QueryAllExistingInferenceRequest) XXX_Size() int

+ func (m *QueryAllExistingInferenceRequest) XXX_Unmarshal(b []byte) error

+ type QueryAllExistingInferenceResponse struct

+ InferenceRequests []*InferenceRequestAndDemandLeft

+ func (*QueryAllExistingInferenceResponse) Descriptor() ([]byte, []int)

+ func (*QueryAllExistingInferenceResponse) ProtoMessage()

+ func (m *QueryAllExistingInferenceResponse) GetInferenceRequests() []*InferenceRequestAndDemandLeft

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

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

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

+ func (m *QueryAllExistingInferenceResponse) Reset()

+ func (m *QueryAllExistingInferenceResponse) Size() (n int)

+ func (m *QueryAllExistingInferenceResponse) String() string

+ func (m *QueryAllExistingInferenceResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryAllExistingInferenceResponse) XXX_DiscardUnknown()

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

+ func (m *QueryAllExistingInferenceResponse) XXX_Merge(src proto.Message)

+ func (m *QueryAllExistingInferenceResponse) XXX_Size() int

+ func (m *QueryAllExistingInferenceResponse) XXX_Unmarshal(b []byte) error

+ type QueryAllInferencesRequest struct

+ Timestamp uint64

+ TopicId uint64

+ func (*QueryAllInferencesRequest) Descriptor() ([]byte, []int)

+ func (*QueryAllInferencesRequest) ProtoMessage()

+ func (m *QueryAllInferencesRequest) GetTimestamp() uint64

+ func (m *QueryAllInferencesRequest) GetTopicId() uint64

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

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

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

+ func (m *QueryAllInferencesRequest) Reset()

+ func (m *QueryAllInferencesRequest) Size() (n int)

+ func (m *QueryAllInferencesRequest) String() string

+ func (m *QueryAllInferencesRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryAllInferencesRequest) XXX_DiscardUnknown()

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

+ func (m *QueryAllInferencesRequest) XXX_Merge(src proto.Message)

+ func (m *QueryAllInferencesRequest) XXX_Size() int

+ func (m *QueryAllInferencesRequest) XXX_Unmarshal(b []byte) error

+ type QueryAllInferencesResponse struct

+ Inferences *Inferences

+ func (*QueryAllInferencesResponse) Descriptor() ([]byte, []int)

+ func (*QueryAllInferencesResponse) ProtoMessage()

+ func (m *QueryAllInferencesResponse) GetInferences() *Inferences

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

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

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

+ func (m *QueryAllInferencesResponse) Reset()

+ func (m *QueryAllInferencesResponse) Size() (n int)

+ func (m *QueryAllInferencesResponse) String() string

+ func (m *QueryAllInferencesResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryAllInferencesResponse) XXX_DiscardUnknown()

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

+ func (m *QueryAllInferencesResponse) XXX_Merge(src proto.Message)

+ func (m *QueryAllInferencesResponse) XXX_Size() int

+ func (m *QueryAllInferencesResponse) XXX_Unmarshal(b []byte) error

+ type QueryAllTopicsRequest struct

+ func (*QueryAllTopicsRequest) Descriptor() ([]byte, []int)

+ func (*QueryAllTopicsRequest) ProtoMessage()

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

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

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

+ func (m *QueryAllTopicsRequest) Reset()

+ func (m *QueryAllTopicsRequest) Size() (n int)

+ func (m *QueryAllTopicsRequest) String() string

+ func (m *QueryAllTopicsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryAllTopicsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryAllTopicsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryAllTopicsRequest) XXX_Size() int

+ func (m *QueryAllTopicsRequest) XXX_Unmarshal(b []byte) error

+ type QueryAllTopicsResponse struct

+ Topics []*Topic

+ func (*QueryAllTopicsResponse) Descriptor() ([]byte, []int)

+ func (*QueryAllTopicsResponse) ProtoMessage()

+ func (m *QueryAllTopicsResponse) GetTopics() []*Topic

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

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

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

+ func (m *QueryAllTopicsResponse) Reset()

+ func (m *QueryAllTopicsResponse) Size() (n int)

+ func (m *QueryAllTopicsResponse) String() string

+ func (m *QueryAllTopicsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryAllTopicsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryAllTopicsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryAllTopicsResponse) XXX_Size() int

+ func (m *QueryAllTopicsResponse) XXX_Unmarshal(b []byte) error

type QueryClient

+ GetAllExistingInferenceRequests func(ctx context.Context, in *QueryAllExistingInferenceRequest, ...) (*QueryAllExistingInferenceResponse, error)

+ GetAllTopics func(ctx context.Context, in *QueryAllTopicsRequest, opts ...grpc.CallOption) (*QueryAllTopicsResponse, error)

+ GetExistingInferenceRequest func(ctx context.Context, in *QueryExistingInferenceRequest, ...) (*QueryExistingInferenceResponse, error)

+ GetRegisteredTopicIds func(ctx context.Context, in *QueryRegisteredTopicIdsRequest, ...) (*QueryRegisteredTopicIdsResponse, error)

+ GetTopicUnmetDemand func(ctx context.Context, in *QueryTopicUnmetDemandRequest, opts ...grpc.CallOption) (*QueryTopicUnmetDemandResponse, error)

+ GetWorkerLatestInferenceByTopicId func(ctx context.Context, in *QueryWorkerLatestInferenceRequest, ...) (*QueryWorkerLatestInferenceResponse, error)

+ type QueryExistingInferenceRequest struct

+ RequestId string

+ TopicId uint64

+ func (*QueryExistingInferenceRequest) Descriptor() ([]byte, []int)

+ func (*QueryExistingInferenceRequest) ProtoMessage()

+ func (m *QueryExistingInferenceRequest) GetRequestId() string

+ func (m *QueryExistingInferenceRequest) GetTopicId() uint64

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

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

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

+ func (m *QueryExistingInferenceRequest) Reset()

+ func (m *QueryExistingInferenceRequest) Size() (n int)

+ func (m *QueryExistingInferenceRequest) String() string

+ func (m *QueryExistingInferenceRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryExistingInferenceRequest) XXX_DiscardUnknown()

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

+ func (m *QueryExistingInferenceRequest) XXX_Merge(src proto.Message)

+ func (m *QueryExistingInferenceRequest) XXX_Size() int

+ func (m *QueryExistingInferenceRequest) XXX_Unmarshal(b []byte) error

+ type QueryExistingInferenceResponse struct

+ DemandLeft cosmossdk_io_math.Uint

+ InferenceRequest *InferenceRequest

+ func (*QueryExistingInferenceResponse) Descriptor() ([]byte, []int)

+ func (*QueryExistingInferenceResponse) ProtoMessage()

+ func (m *QueryExistingInferenceResponse) GetInferenceRequest() *InferenceRequest

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

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

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

+ func (m *QueryExistingInferenceResponse) Reset()

+ func (m *QueryExistingInferenceResponse) Size() (n int)

+ func (m *QueryExistingInferenceResponse) String() string

+ func (m *QueryExistingInferenceResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryExistingInferenceResponse) XXX_DiscardUnknown()

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

+ func (m *QueryExistingInferenceResponse) XXX_Merge(src proto.Message)

+ func (m *QueryExistingInferenceResponse) XXX_Size() int

+ func (m *QueryExistingInferenceResponse) XXX_Unmarshal(b []byte) error

+ type QueryRegisteredTopicIdsRequest struct

+ Address string

+ IsReputer bool

+ func (*QueryRegisteredTopicIdsRequest) Descriptor() ([]byte, []int)

+ func (*QueryRegisteredTopicIdsRequest) ProtoMessage()

+ func (m *QueryRegisteredTopicIdsRequest) GetAddress() string

+ func (m *QueryRegisteredTopicIdsRequest) GetIsReputer() bool

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

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

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

+ func (m *QueryRegisteredTopicIdsRequest) Reset()

+ func (m *QueryRegisteredTopicIdsRequest) Size() (n int)

+ func (m *QueryRegisteredTopicIdsRequest) String() string

+ func (m *QueryRegisteredTopicIdsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRegisteredTopicIdsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryRegisteredTopicIdsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRegisteredTopicIdsRequest) XXX_Size() int

+ func (m *QueryRegisteredTopicIdsRequest) XXX_Unmarshal(b []byte) error

+ type QueryRegisteredTopicIdsResponse struct

+ TopicIds []uint64

+ func (*QueryRegisteredTopicIdsResponse) Descriptor() ([]byte, []int)

+ func (*QueryRegisteredTopicIdsResponse) ProtoMessage()

+ func (m *QueryRegisteredTopicIdsResponse) GetTopicIds() []uint64

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

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

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

+ func (m *QueryRegisteredTopicIdsResponse) Reset()

+ func (m *QueryRegisteredTopicIdsResponse) Size() (n int)

+ func (m *QueryRegisteredTopicIdsResponse) String() string

+ func (m *QueryRegisteredTopicIdsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryRegisteredTopicIdsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryRegisteredTopicIdsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryRegisteredTopicIdsResponse) XXX_Size() int

+ func (m *QueryRegisteredTopicIdsResponse) XXX_Unmarshal(b []byte) error

type QueryServer

+ GetAllExistingInferenceRequests func(context.Context, *QueryAllExistingInferenceRequest) (*QueryAllExistingInferenceResponse, error)

+ GetAllTopics func(context.Context, *QueryAllTopicsRequest) (*QueryAllTopicsResponse, error)

+ GetExistingInferenceRequest func(context.Context, *QueryExistingInferenceRequest) (*QueryExistingInferenceResponse, error)

+ GetRegisteredTopicIds func(context.Context, *QueryRegisteredTopicIdsRequest) (*QueryRegisteredTopicIdsResponse, error)

+ GetTopicUnmetDemand func(context.Context, *QueryTopicUnmetDemandRequest) (*QueryTopicUnmetDemandResponse, error)

+ GetWorkerLatestInferenceByTopicId func(context.Context, *QueryWorkerLatestInferenceRequest) (*QueryWorkerLatestInferenceResponse, error)

+ type QueryTopicUnmetDemandRequest struct

+ TopicId uint64

+ func (*QueryTopicUnmetDemandRequest) Descriptor() ([]byte, []int)

+ func (*QueryTopicUnmetDemandRequest) ProtoMessage()

+ func (m *QueryTopicUnmetDemandRequest) GetTopicId() uint64

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

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

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

+ func (m *QueryTopicUnmetDemandRequest) Reset()

+ func (m *QueryTopicUnmetDemandRequest) Size() (n int)

+ func (m *QueryTopicUnmetDemandRequest) String() string

+ func (m *QueryTopicUnmetDemandRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryTopicUnmetDemandRequest) XXX_DiscardUnknown()

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

+ func (m *QueryTopicUnmetDemandRequest) XXX_Merge(src proto.Message)

+ func (m *QueryTopicUnmetDemandRequest) XXX_Size() int

+ func (m *QueryTopicUnmetDemandRequest) XXX_Unmarshal(b []byte) error

+ type QueryTopicUnmetDemandResponse struct

+ DemandLeft cosmossdk_io_math.Uint

+ func (*QueryTopicUnmetDemandResponse) Descriptor() ([]byte, []int)

+ func (*QueryTopicUnmetDemandResponse) ProtoMessage()

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

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

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

+ func (m *QueryTopicUnmetDemandResponse) Reset()

+ func (m *QueryTopicUnmetDemandResponse) Size() (n int)

+ func (m *QueryTopicUnmetDemandResponse) String() string

+ func (m *QueryTopicUnmetDemandResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryTopicUnmetDemandResponse) XXX_DiscardUnknown()

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

+ func (m *QueryTopicUnmetDemandResponse) XXX_Merge(src proto.Message)

+ func (m *QueryTopicUnmetDemandResponse) XXX_Size() int

+ func (m *QueryTopicUnmetDemandResponse) XXX_Unmarshal(b []byte) error

+ type QueryWorkerLatestInferenceRequest struct

+ TopicId uint64

+ WorkerAddress string

+ func (*QueryWorkerLatestInferenceRequest) Descriptor() ([]byte, []int)

+ func (*QueryWorkerLatestInferenceRequest) ProtoMessage()

+ func (m *QueryWorkerLatestInferenceRequest) GetTopicId() uint64

+ func (m *QueryWorkerLatestInferenceRequest) GetWorkerAddress() string

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

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

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

+ func (m *QueryWorkerLatestInferenceRequest) Reset()

+ func (m *QueryWorkerLatestInferenceRequest) Size() (n int)

+ func (m *QueryWorkerLatestInferenceRequest) String() string

+ func (m *QueryWorkerLatestInferenceRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryWorkerLatestInferenceRequest) XXX_DiscardUnknown()

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

+ func (m *QueryWorkerLatestInferenceRequest) XXX_Merge(src proto.Message)

+ func (m *QueryWorkerLatestInferenceRequest) XXX_Size() int

+ func (m *QueryWorkerLatestInferenceRequest) XXX_Unmarshal(b []byte) error

+ type QueryWorkerLatestInferenceResponse struct

+ LatestInference *Inference

+ func (*QueryWorkerLatestInferenceResponse) Descriptor() ([]byte, []int)

+ func (*QueryWorkerLatestInferenceResponse) ProtoMessage()

+ func (m *QueryWorkerLatestInferenceResponse) GetLatestInference() *Inference

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

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

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

+ func (m *QueryWorkerLatestInferenceResponse) Reset()

+ func (m *QueryWorkerLatestInferenceResponse) Size() (n int)

+ func (m *QueryWorkerLatestInferenceResponse) String() string

+ func (m *QueryWorkerLatestInferenceResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryWorkerLatestInferenceResponse) XXX_DiscardUnknown()

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

+ func (m *QueryWorkerLatestInferenceResponse) XXX_Merge(src proto.Message)

+ func (m *QueryWorkerLatestInferenceResponse) XXX_Size() int

+ func (m *QueryWorkerLatestInferenceResponse) XXX_Unmarshal(b []byte) error

type StakeRemovalPlacement

+ TopicIds []uint64

+ func (m *StakeRemovalPlacement) GetTopicIds() []uint64

+ type TopicList struct

+ Topics []*Topic

+ func (*TopicList) Descriptor() ([]byte, []int)

+ func (*TopicList) ProtoMessage()

+ func (m *TopicList) GetTopics() []*Topic

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

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

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

+ func (m *TopicList) Reset()

+ func (m *TopicList) Size() (n int)

+ func (m *TopicList) String() string

+ func (m *TopicList) Unmarshal(dAtA []byte) error

+ func (m *TopicList) XXX_DiscardUnknown()

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

+ func (m *TopicList) XXX_Merge(src proto.Message)

+ func (m *TopicList) XXX_Size() int

+ func (m *TopicList) XXX_Unmarshal(b []byte) error

type UnimplementedMsgServer

+ func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServer

+ func (*UnimplementedQueryServer) GetAllExistingInferenceRequests(ctx context.Context, req *QueryAllExistingInferenceRequest) (*QueryAllExistingInferenceResponse, error)

+ func (*UnimplementedQueryServer) GetAllTopics(ctx context.Context, req *QueryAllTopicsRequest) (*QueryAllTopicsResponse, error)

+ func (*UnimplementedQueryServer) GetExistingInferenceRequest(ctx context.Context, req *QueryExistingInferenceRequest) (*QueryExistingInferenceResponse, error)

+ func (*UnimplementedQueryServer) GetRegisteredTopicIds(ctx context.Context, req *QueryRegisteredTopicIdsRequest) (*QueryRegisteredTopicIdsResponse, error)

+ func (*UnimplementedQueryServer) GetTopicUnmetDemand(ctx context.Context, req *QueryTopicUnmetDemandRequest) (*QueryTopicUnmetDemandResponse, error)

+ func (*UnimplementedQueryServer) GetWorkerLatestInferenceByTopicId(ctx context.Context, req *QueryWorkerLatestInferenceRequest) (*QueryWorkerLatestInferenceResponse, error)

v0.0.3

Feb 26, 2024

v0.0.2

Feb 23, 2024

v0.0.1

Feb 23, 2024

Changes in this version

+ var ErrInferenceCadenceBelowMinimum = errors.Register(ModuleName, 47, "inference cadence must be at least 60 seconds (1 minute)")

+ var ErrNotInTopicCreationWhitelist = errors.Register(ModuleName, 50, "not in topic creation whitelist")

+ var ErrNotInWeightSettingWhitelist = errors.Register(ModuleName, 51, "not in topic weight setting whitelist")

+ var ErrNotWhitelistAdmin = errors.Register(ModuleName, 49, "not whitelist admin")

+ var ErrTopicNotEnoughDemand = errors.Register(ModuleName, 52, "topic not enough demand")

+ var ErrWeightCadenceBelowMinimum = errors.Register(ModuleName, 48, "weight cadence must be at least 10800 seconds (3 hours)")

+ var NumInferencesInRewardEpochKey = collections.NewPrefix(25)

+ var TopicCreationWhitelistKey = collections.NewPrefix(27)

+ var WeightSettingWhitelistKey = collections.NewPrefix(28)

+ var WhitelistAdminsKey = collections.NewPrefix(26)

+ type MsgAddToTopicCreationWhitelist struct

+ Address string

+ Sender string

+ func (*MsgAddToTopicCreationWhitelist) Descriptor() ([]byte, []int)

+ func (*MsgAddToTopicCreationWhitelist) ProtoMessage()

+ func (m *MsgAddToTopicCreationWhitelist) GetAddress() string

+ func (m *MsgAddToTopicCreationWhitelist) GetSender() string

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

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

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

+ func (m *MsgAddToTopicCreationWhitelist) Reset()

+ func (m *MsgAddToTopicCreationWhitelist) Size() (n int)

+ func (m *MsgAddToTopicCreationWhitelist) String() string

+ func (m *MsgAddToTopicCreationWhitelist) Unmarshal(dAtA []byte) error

+ func (m *MsgAddToTopicCreationWhitelist) XXX_DiscardUnknown()

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

+ func (m *MsgAddToTopicCreationWhitelist) XXX_Merge(src proto.Message)

+ func (m *MsgAddToTopicCreationWhitelist) XXX_Size() int

+ func (m *MsgAddToTopicCreationWhitelist) XXX_Unmarshal(b []byte) error

+ type MsgAddToTopicCreationWhitelistResponse struct

+ func (*MsgAddToTopicCreationWhitelistResponse) Descriptor() ([]byte, []int)

+ func (*MsgAddToTopicCreationWhitelistResponse) ProtoMessage()

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

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

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

+ func (m *MsgAddToTopicCreationWhitelistResponse) Reset()

+ func (m *MsgAddToTopicCreationWhitelistResponse) Size() (n int)

+ func (m *MsgAddToTopicCreationWhitelistResponse) String() string

+ func (m *MsgAddToTopicCreationWhitelistResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgAddToTopicCreationWhitelistResponse) XXX_DiscardUnknown()

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

+ func (m *MsgAddToTopicCreationWhitelistResponse) XXX_Merge(src proto.Message)

+ func (m *MsgAddToTopicCreationWhitelistResponse) XXX_Size() int

+ func (m *MsgAddToTopicCreationWhitelistResponse) XXX_Unmarshal(b []byte) error

+ type MsgAddToWeightSettingWhitelist struct

+ Address string

+ Sender string

+ func (*MsgAddToWeightSettingWhitelist) Descriptor() ([]byte, []int)

+ func (*MsgAddToWeightSettingWhitelist) ProtoMessage()

+ func (m *MsgAddToWeightSettingWhitelist) GetAddress() string

+ func (m *MsgAddToWeightSettingWhitelist) GetSender() string

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

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

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

+ func (m *MsgAddToWeightSettingWhitelist) Reset()

+ func (m *MsgAddToWeightSettingWhitelist) Size() (n int)

+ func (m *MsgAddToWeightSettingWhitelist) String() string

+ func (m *MsgAddToWeightSettingWhitelist) Unmarshal(dAtA []byte) error

+ func (m *MsgAddToWeightSettingWhitelist) XXX_DiscardUnknown()

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

+ func (m *MsgAddToWeightSettingWhitelist) XXX_Merge(src proto.Message)

+ func (m *MsgAddToWeightSettingWhitelist) XXX_Size() int

+ func (m *MsgAddToWeightSettingWhitelist) XXX_Unmarshal(b []byte) error

+ type MsgAddToWeightSettingWhitelistResponse struct

+ func (*MsgAddToWeightSettingWhitelistResponse) Descriptor() ([]byte, []int)

+ func (*MsgAddToWeightSettingWhitelistResponse) ProtoMessage()

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

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

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

+ func (m *MsgAddToWeightSettingWhitelistResponse) Reset()

+ func (m *MsgAddToWeightSettingWhitelistResponse) Size() (n int)

+ func (m *MsgAddToWeightSettingWhitelistResponse) String() string

+ func (m *MsgAddToWeightSettingWhitelistResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgAddToWeightSettingWhitelistResponse) XXX_DiscardUnknown()

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

+ func (m *MsgAddToWeightSettingWhitelistResponse) XXX_Merge(src proto.Message)

+ func (m *MsgAddToWeightSettingWhitelistResponse) XXX_Size() int

+ func (m *MsgAddToWeightSettingWhitelistResponse) XXX_Unmarshal(b []byte) error

+ type MsgAddToWhitelistAdmin struct

+ Address string

+ Sender string

+ func (*MsgAddToWhitelistAdmin) Descriptor() ([]byte, []int)

+ func (*MsgAddToWhitelistAdmin) ProtoMessage()

+ func (m *MsgAddToWhitelistAdmin) GetAddress() string

+ func (m *MsgAddToWhitelistAdmin) GetSender() string

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

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

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

+ func (m *MsgAddToWhitelistAdmin) Reset()

+ func (m *MsgAddToWhitelistAdmin) Size() (n int)

+ func (m *MsgAddToWhitelistAdmin) String() string

+ func (m *MsgAddToWhitelistAdmin) Unmarshal(dAtA []byte) error

+ func (m *MsgAddToWhitelistAdmin) XXX_DiscardUnknown()

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

+ func (m *MsgAddToWhitelistAdmin) XXX_Merge(src proto.Message)

+ func (m *MsgAddToWhitelistAdmin) XXX_Size() int

+ func (m *MsgAddToWhitelistAdmin) XXX_Unmarshal(b []byte) error

+ type MsgAddToWhitelistAdminResponse struct

+ func (*MsgAddToWhitelistAdminResponse) Descriptor() ([]byte, []int)

+ func (*MsgAddToWhitelistAdminResponse) ProtoMessage()

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

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

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

+ func (m *MsgAddToWhitelistAdminResponse) Reset()

+ func (m *MsgAddToWhitelistAdminResponse) Size() (n int)

+ func (m *MsgAddToWhitelistAdminResponse) String() string

+ func (m *MsgAddToWhitelistAdminResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgAddToWhitelistAdminResponse) XXX_DiscardUnknown()

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

+ func (m *MsgAddToWhitelistAdminResponse) XXX_Merge(src proto.Message)

+ func (m *MsgAddToWhitelistAdminResponse) XXX_Size() int

+ func (m *MsgAddToWhitelistAdminResponse) XXX_Unmarshal(b []byte) error

type MsgClient

+ AddToTopicCreationWhitelist func(ctx context.Context, in *MsgAddToTopicCreationWhitelist, ...) (*MsgAddToTopicCreationWhitelistResponse, error)

+ AddToWeightSettingWhitelist func(ctx context.Context, in *MsgAddToWeightSettingWhitelist, ...) (*MsgAddToWeightSettingWhitelistResponse, error)

+ AddToWhitelistAdmin func(ctx context.Context, in *MsgAddToWhitelistAdmin, opts ...grpc.CallOption) (*MsgAddToWhitelistAdminResponse, error)

+ ReactivateTopic func(ctx context.Context, in *MsgReactivateTopic, opts ...grpc.CallOption) (*MsgReactivateTopicResponse, error)

+ RemoveFromTopicCreationWhitelist func(ctx context.Context, in *MsgRemoveFromTopicCreationWhitelist, ...) (*MsgRemoveFromTopicCreationWhitelistResponse, error)

+ RemoveFromWeightSettingWhitelist func(ctx context.Context, in *MsgRemoveFromWeightSettingWhitelist, ...) (*MsgRemoveFromWeightSettingWhitelistResponse, error)

+ RemoveFromWhitelistAdmin func(ctx context.Context, in *MsgRemoveFromWhitelistAdmin, opts ...grpc.CallOption) (*MsgRemoveFromWhitelistAdminResponse, error)

+ type MsgReactivateTopic struct

+ Sender string

+ TopicId uint64

+ func (*MsgReactivateTopic) Descriptor() ([]byte, []int)

+ func (*MsgReactivateTopic) ProtoMessage()

+ func (m *MsgReactivateTopic) GetSender() string

+ func (m *MsgReactivateTopic) GetTopicId() uint64

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

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

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

+ func (m *MsgReactivateTopic) Reset()

+ func (m *MsgReactivateTopic) Size() (n int)

+ func (m *MsgReactivateTopic) String() string

+ func (m *MsgReactivateTopic) Unmarshal(dAtA []byte) error

+ func (m *MsgReactivateTopic) XXX_DiscardUnknown()

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

+ func (m *MsgReactivateTopic) XXX_Merge(src proto.Message)

+ func (m *MsgReactivateTopic) XXX_Size() int

+ func (m *MsgReactivateTopic) XXX_Unmarshal(b []byte) error

+ type MsgReactivateTopicResponse struct

+ Success bool

+ func (*MsgReactivateTopicResponse) Descriptor() ([]byte, []int)

+ func (*MsgReactivateTopicResponse) ProtoMessage()

+ func (m *MsgReactivateTopicResponse) GetSuccess() bool

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

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

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

+ func (m *MsgReactivateTopicResponse) Reset()

+ func (m *MsgReactivateTopicResponse) Size() (n int)

+ func (m *MsgReactivateTopicResponse) String() string

+ func (m *MsgReactivateTopicResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgReactivateTopicResponse) XXX_DiscardUnknown()

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

+ func (m *MsgReactivateTopicResponse) XXX_Merge(src proto.Message)

+ func (m *MsgReactivateTopicResponse) XXX_Size() int

+ func (m *MsgReactivateTopicResponse) XXX_Unmarshal(b []byte) error

+ type MsgRemoveFromTopicCreationWhitelist struct

+ Address string

+ Sender string

+ func (*MsgRemoveFromTopicCreationWhitelist) Descriptor() ([]byte, []int)

+ func (*MsgRemoveFromTopicCreationWhitelist) ProtoMessage()

+ func (m *MsgRemoveFromTopicCreationWhitelist) GetAddress() string

+ func (m *MsgRemoveFromTopicCreationWhitelist) GetSender() string

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

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

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

+ func (m *MsgRemoveFromTopicCreationWhitelist) Reset()

+ func (m *MsgRemoveFromTopicCreationWhitelist) Size() (n int)

+ func (m *MsgRemoveFromTopicCreationWhitelist) String() string

+ func (m *MsgRemoveFromTopicCreationWhitelist) Unmarshal(dAtA []byte) error

+ func (m *MsgRemoveFromTopicCreationWhitelist) XXX_DiscardUnknown()

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

+ func (m *MsgRemoveFromTopicCreationWhitelist) XXX_Merge(src proto.Message)

+ func (m *MsgRemoveFromTopicCreationWhitelist) XXX_Size() int

+ func (m *MsgRemoveFromTopicCreationWhitelist) XXX_Unmarshal(b []byte) error

+ type MsgRemoveFromTopicCreationWhitelistResponse struct

+ func (*MsgRemoveFromTopicCreationWhitelistResponse) Descriptor() ([]byte, []int)

+ func (*MsgRemoveFromTopicCreationWhitelistResponse) ProtoMessage()

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

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

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

+ func (m *MsgRemoveFromTopicCreationWhitelistResponse) Reset()

+ func (m *MsgRemoveFromTopicCreationWhitelistResponse) Size() (n int)

+ func (m *MsgRemoveFromTopicCreationWhitelistResponse) String() string

+ func (m *MsgRemoveFromTopicCreationWhitelistResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgRemoveFromTopicCreationWhitelistResponse) XXX_DiscardUnknown()

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

+ func (m *MsgRemoveFromTopicCreationWhitelistResponse) XXX_Merge(src proto.Message)

+ func (m *MsgRemoveFromTopicCreationWhitelistResponse) XXX_Size() int

+ func (m *MsgRemoveFromTopicCreationWhitelistResponse) XXX_Unmarshal(b []byte) error

+ type MsgRemoveFromWeightSettingWhitelist struct

+ Address string

+ Sender string

+ func (*MsgRemoveFromWeightSettingWhitelist) Descriptor() ([]byte, []int)

+ func (*MsgRemoveFromWeightSettingWhitelist) ProtoMessage()

+ func (m *MsgRemoveFromWeightSettingWhitelist) GetAddress() string

+ func (m *MsgRemoveFromWeightSettingWhitelist) GetSender() string

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

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

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

+ func (m *MsgRemoveFromWeightSettingWhitelist) Reset()

+ func (m *MsgRemoveFromWeightSettingWhitelist) Size() (n int)

+ func (m *MsgRemoveFromWeightSettingWhitelist) String() string

+ func (m *MsgRemoveFromWeightSettingWhitelist) Unmarshal(dAtA []byte) error

+ func (m *MsgRemoveFromWeightSettingWhitelist) XXX_DiscardUnknown()

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

+ func (m *MsgRemoveFromWeightSettingWhitelist) XXX_Merge(src proto.Message)

+ func (m *MsgRemoveFromWeightSettingWhitelist) XXX_Size() int

+ func (m *MsgRemoveFromWeightSettingWhitelist) XXX_Unmarshal(b []byte) error

+ type MsgRemoveFromWeightSettingWhitelistResponse struct

+ func (*MsgRemoveFromWeightSettingWhitelistResponse) Descriptor() ([]byte, []int)

+ func (*MsgRemoveFromWeightSettingWhitelistResponse) ProtoMessage()

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

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

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

+ func (m *MsgRemoveFromWeightSettingWhitelistResponse) Reset()

+ func (m *MsgRemoveFromWeightSettingWhitelistResponse) Size() (n int)

+ func (m *MsgRemoveFromWeightSettingWhitelistResponse) String() string

+ func (m *MsgRemoveFromWeightSettingWhitelistResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgRemoveFromWeightSettingWhitelistResponse) XXX_DiscardUnknown()

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

+ func (m *MsgRemoveFromWeightSettingWhitelistResponse) XXX_Merge(src proto.Message)

+ func (m *MsgRemoveFromWeightSettingWhitelistResponse) XXX_Size() int

+ func (m *MsgRemoveFromWeightSettingWhitelistResponse) XXX_Unmarshal(b []byte) error

+ type MsgRemoveFromWhitelistAdmin struct

+ Address string

+ Sender string

+ func (*MsgRemoveFromWhitelistAdmin) Descriptor() ([]byte, []int)

+ func (*MsgRemoveFromWhitelistAdmin) ProtoMessage()

+ func (m *MsgRemoveFromWhitelistAdmin) GetAddress() string

+ func (m *MsgRemoveFromWhitelistAdmin) GetSender() string

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

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

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

+ func (m *MsgRemoveFromWhitelistAdmin) Reset()

+ func (m *MsgRemoveFromWhitelistAdmin) Size() (n int)

+ func (m *MsgRemoveFromWhitelistAdmin) String() string

+ func (m *MsgRemoveFromWhitelistAdmin) Unmarshal(dAtA []byte) error

+ func (m *MsgRemoveFromWhitelistAdmin) XXX_DiscardUnknown()

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

+ func (m *MsgRemoveFromWhitelistAdmin) XXX_Merge(src proto.Message)

+ func (m *MsgRemoveFromWhitelistAdmin) XXX_Size() int

+ func (m *MsgRemoveFromWhitelistAdmin) XXX_Unmarshal(b []byte) error

+ type MsgRemoveFromWhitelistAdminResponse struct

+ func (*MsgRemoveFromWhitelistAdminResponse) Descriptor() ([]byte, []int)

+ func (*MsgRemoveFromWhitelistAdminResponse) ProtoMessage()

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

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

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

+ func (m *MsgRemoveFromWhitelistAdminResponse) Reset()

+ func (m *MsgRemoveFromWhitelistAdminResponse) Size() (n int)

+ func (m *MsgRemoveFromWhitelistAdminResponse) String() string

+ func (m *MsgRemoveFromWhitelistAdminResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgRemoveFromWhitelistAdminResponse) XXX_DiscardUnknown()

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

+ func (m *MsgRemoveFromWhitelistAdminResponse) XXX_Merge(src proto.Message)

+ func (m *MsgRemoveFromWhitelistAdminResponse) XXX_Size() int

+ func (m *MsgRemoveFromWhitelistAdminResponse) XXX_Unmarshal(b []byte) error

type MsgServer

+ AddToTopicCreationWhitelist func(context.Context, *MsgAddToTopicCreationWhitelist) (*MsgAddToTopicCreationWhitelistResponse, error)

+ AddToWeightSettingWhitelist func(context.Context, *MsgAddToWeightSettingWhitelist) (*MsgAddToWeightSettingWhitelistResponse, error)

+ AddToWhitelistAdmin func(context.Context, *MsgAddToWhitelistAdmin) (*MsgAddToWhitelistAdminResponse, error)

+ ReactivateTopic func(context.Context, *MsgReactivateTopic) (*MsgReactivateTopicResponse, error)

+ RemoveFromTopicCreationWhitelist func(context.Context, *MsgRemoveFromTopicCreationWhitelist) (*MsgRemoveFromTopicCreationWhitelistResponse, error)

+ RemoveFromWeightSettingWhitelist func(context.Context, *MsgRemoveFromWeightSettingWhitelist) (*MsgRemoveFromWeightSettingWhitelistResponse, error)

+ RemoveFromWhitelistAdmin func(context.Context, *MsgRemoveFromWhitelistAdmin) (*MsgRemoveFromWhitelistAdminResponse, error)

type UnimplementedMsgServer

+ func (*UnimplementedMsgServer) AddToTopicCreationWhitelist(ctx context.Context, req *MsgAddToTopicCreationWhitelist) (*MsgAddToTopicCreationWhitelistResponse, error)

+ func (*UnimplementedMsgServer) AddToWeightSettingWhitelist(ctx context.Context, req *MsgAddToWeightSettingWhitelist) (*MsgAddToWeightSettingWhitelistResponse, error)

+ func (*UnimplementedMsgServer) AddToWhitelistAdmin(ctx context.Context, req *MsgAddToWhitelistAdmin) (*MsgAddToWhitelistAdminResponse, error)

+ func (*UnimplementedMsgServer) ReactivateTopic(ctx context.Context, req *MsgReactivateTopic) (*MsgReactivateTopicResponse, error)

+ func (*UnimplementedMsgServer) RemoveFromTopicCreationWhitelist(ctx context.Context, req *MsgRemoveFromTopicCreationWhitelist) (*MsgRemoveFromTopicCreationWhitelistResponse, error)

+ func (*UnimplementedMsgServer) RemoveFromWeightSettingWhitelist(ctx context.Context, req *MsgRemoveFromWeightSettingWhitelist) (*MsgRemoveFromWeightSettingWhitelistResponse, error)

+ func (*UnimplementedMsgServer) RemoveFromWhitelistAdmin(ctx context.Context, req *MsgRemoveFromWhitelistAdmin) (*MsgRemoveFromWhitelistAdminResponse, error)

v0.0.0

Feb 23, 2024

Changes in this version

+ const AlloraRequestsModuleName

+ const AlloraStakingModuleName

+ const ModuleName

+ var AccumulatedMetDemandKey = collections.NewPrefix(24)

+ var AddressTopicsKey = collections.NewPrefix(23)

+ var AllInferencesKey = collections.NewPrefix(20)

+ var AllTopicStakeSumKey = collections.NewPrefix(22)

+ var BondsKey = collections.NewPrefix(10)

+ var DelegatorStakeKey = collections.NewPrefix(9)

+ var ErrAddressAlreadyRegisteredInATopic = errors.Register(ModuleName, 10, "address already registered in a topic")

+ var ErrAddressIsNotRegisteredInAnyTopic = errors.Register(ModuleName, 11, "address is not registered in any topic")

+ var ErrAddressIsNotRegisteredInThisTopic = errors.Register(ModuleName, 12, "address is not registered in this topic")

+ var ErrAddressNotRegistered = errors.Register(ModuleName, 15, "address not registered")

+ var ErrBlockHeightLessThanPrevious = errors.Register(ModuleName, 22, "block height less than previous")

+ var ErrBlockHeightNegative = errors.Register(ModuleName, 21, "block height negative")

+ var ErrCannotRemoveMoreStakeThanStakedInTopic = errors.Register(ModuleName, 35, "cannot remove more stake than staked in topic")

+ var ErrConfirmRemoveStakeNoRemovalStarted = errors.Register(ModuleName, 26, "confirm remove stake no removal started")

+ var ErrConfirmRemoveStakeTooEarly = errors.Register(ModuleName, 27, "confirm remove stake too early")

+ var ErrConfirmRemoveStakeTooLate = errors.Register(ModuleName, 28, "confirm remove stake too late")

+ var ErrDivideMapValuesByZero = errors.Register(ModuleName, 30, "divide map values by zero")

+ var ErrDoNotSetMapValueToZero = errors.Register(ModuleName, 20, "do not set map value to zero")

+ var ErrInferenceRequestAlreadyInMempool = errors.Register(ModuleName, 36, "inference request already in mempool")

+ var ErrInferenceRequestBidAmountLessThanPrice = errors.Register(ModuleName, 37, "inference request bid amount less than price")

+ var ErrInferenceRequestBidAmountTooLow = errors.Register(ModuleName, 45, "inference request bid amount too low")

+ var ErrInferenceRequestCadenceTooFast = errors.Register(ModuleName, 40, "inference request cadence too fast")

+ var ErrInferenceRequestCadenceTooSlow = errors.Register(ModuleName, 41, "inference request cadence too slow")

+ var ErrInferenceRequestTimestampValidUntilInPast = errors.Register(ModuleName, 38, "inference request timestamp valid until in past")

+ var ErrInferenceRequestTimestampValidUntilTooFarInFuture = errors.Register(ModuleName, 39, "inference request timestamp valid until too far in future")

+ var ErrInferenceRequestWillNeverBeScheduled = errors.Register(ModuleName, 42, "inference request will never be scheduled")

+ var ErrInsufficientStakeAfterRemoval = errors.Register(ModuleName, 44, "insufficient stake after removal")

+ var ErrInsufficientStakeToRegister = errors.Register(ModuleName, 13, "insufficient stake to register")

+ var ErrInsufficientStakeToRemove = errors.Register(ModuleName, 18, "insufficient stake to remove")

+ var ErrIntOverflowQuery = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTx = fmt.Errorf("proto: integer overflow")

+ var ErrIntOverflowTypes = fmt.Errorf("proto: integer overflow")

+ var ErrIntegerUnderflowBonds = errors.Register(ModuleName, 2, "integer underflow for bonds")

+ var ErrIntegerUnderflowDelegator = errors.Register(ModuleName, 1, "integer underflow for delegator")

+ var ErrIntegerUnderflowTarget = errors.Register(ModuleName, 3, "integer underflow for target")

+ var ErrIntegerUnderflowTopicStake = errors.Register(ModuleName, 4, "integer underflow for topic stake")

+ var ErrIntegerUnderflowTotalStake = errors.Register(ModuleName, 5, "integer underflow for total stake")

+ var ErrIntegerUnderflowUnmetDemand = errors.Register(ModuleName, 46, "integer underflow for unmet demand")

+ var ErrInvalidLengthQuery = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTx = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrInvalidTopicId = errors.Register(ModuleName, 7, "invalid topic ID")

+ var ErrIterationLengthDoesNotMatch = errors.Register(ModuleName, 6, "iteration length does not match")

+ var ErrLibP2PKeyRequired = errors.Register(ModuleName, 14, "libp2p key required")

+ var ErrModifyStakeBeforeBondLessThanAmountModified = errors.Register(ModuleName, 23, "modify stake before bond less than amount modified")

+ var ErrModifyStakeBeforeSumGreaterThanSenderStake = errors.Register(ModuleName, 24, "modify stake before sum greater than sender stake")

+ var ErrModifyStakeSumBeforeNotEqualToSumAfter = errors.Register(ModuleName, 25, "modify stake sum before not equal to sum after")

+ var ErrNoStakeToRemove = errors.Register(ModuleName, 19, "no stake to remove")

+ var ErrOwnerCannotBeEmpty = errors.Register(ModuleName, 43, "owner cannot be empty")

+ var ErrReputerAlreadyRegisteredInTopic = errors.Register(ModuleName, 8, "reputer already registered in topic")

+ var ErrScalarMultiplyNegative = errors.Register(ModuleName, 29, "scalar multiply negative")

+ var ErrStakeTargetNotRegistered = errors.Register(ModuleName, 16, "stake target not registered")

+ var ErrTopicDoesNotExist = errors.Register(ModuleName, 34, "topic does not exist")

+ var ErrTopicIdListValueDecodeInvalidLength = errors.Register(ModuleName, 31, "topic ID list value decode invalid length")

+ var ErrTopicIdListValueDecodeJsonInvalidFormat = errors.Register(ModuleName, 33, "topic ID list value decode JSON invalid format")

+ var ErrTopicIdListValueDecodeJsonInvalidLength = errors.Register(ModuleName, 32, "topic ID list value decode JSON invalid length")

+ var ErrTopicIdOfStakerAndTargetDoNotMatch = errors.Register(ModuleName, 17, "topic ID of staker and target do not match")

+ var ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")

+ var ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")

+ var ErrWorkerAlreadyRegisteredInTopic = errors.Register(ModuleName, 9, "worker already registered in topic")

+ var InferencesKey = collections.NewPrefix(13)

+ var LastRewardsUpdateKey = collections.NewPrefix(3)

+ var LatestInferencesTsKey = collections.NewPrefix(16)

+ var MempoolKey = collections.NewPrefix(17)

+ var NextTopicIdKey = collections.NewPrefix(5)

+ var ParamsKey = collections.NewPrefix(0)

+ var ReputerNodesKey = collections.NewPrefix(15)

+ var RequestUnmetDemandKey = collections.NewPrefix(18)

+ var RewardsKey = collections.NewPrefix(4)

+ var StakeRemovalQueueKey = collections.NewPrefix(21)

+ var TargetStakeKey = collections.NewPrefix(11)

+ var TopicReputersKey = collections.NewPrefix(8)

+ var TopicStakeKey = collections.NewPrefix(2)

+ var TopicUnmetDemandKey = collections.NewPrefix(19)

+ var TopicWorkersKey = collections.NewPrefix(7)

+ var TopicsKey = collections.NewPrefix(6)

+ var TotalStakeKey = collections.NewPrefix(1)

+ var WeightsKey = collections.NewPrefix(12)

+ var WorkerNodesKey = collections.NewPrefix(14)

+ func RegisterInterfaces(registry types.InterfaceRegistry)

+ func RegisterMsgServer(s grpc1.Server, srv MsgServer)

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

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

+ func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterQueryServer(s grpc1.Server, srv QueryServer)

+ type GenesisState struct

+ Params Params

+ func NewGenesisState() *GenesisState

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

+ func (*GenesisState) ProtoMessage()

+ func (gs *GenesisState) Validate() error

+ func (m *GenesisState) GetParams() Params

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

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

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

+ func (m *GenesisState) Reset()

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

+ func (m *GenesisState) String() string

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

+ func (m *GenesisState) XXX_DiscardUnknown()

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

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

+ func (m *GenesisState) XXX_Size() int

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

+ type Inference struct

+ ExtraData []byte

+ Proof string

+ TopicId uint64

+ Value cosmossdk_io_math.Uint

+ Worker string

+ func (*Inference) Descriptor() ([]byte, []int)

+ func (*Inference) ProtoMessage()

+ func (m *Inference) GetExtraData() []byte

+ func (m *Inference) GetProof() string

+ func (m *Inference) GetTopicId() uint64

+ func (m *Inference) GetWorker() string

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

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

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

+ func (m *Inference) Reset()

+ func (m *Inference) Size() (n int)

+ func (m *Inference) String() string

+ func (m *Inference) Unmarshal(dAtA []byte) error

+ func (m *Inference) XXX_DiscardUnknown()

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

+ func (m *Inference) XXX_Merge(src proto.Message)

+ func (m *Inference) XXX_Size() int

+ func (m *Inference) XXX_Unmarshal(b []byte) error

+ func (this *Inference) Equal(that interface{}) bool

+ type InferenceRequest struct

+ BidAmount cosmossdk_io_math.Uint

+ Cadence uint64

+ ExtraData []byte

+ LastChecked uint64

+ MaxPricePerInference cosmossdk_io_math.Uint

+ Nonce uint64

+ Sender string

+ TimestampValidUntil uint64

+ TopicId uint64

+ func CreateNewInferenceRequestFromListItem(sender string, item *RequestInferenceListItem) *InferenceRequest

+ func (*InferenceRequest) Descriptor() ([]byte, []int)

+ func (*InferenceRequest) ProtoMessage()

+ func (m *InferenceRequest) GetCadence() uint64

+ func (m *InferenceRequest) GetExtraData() []byte

+ func (m *InferenceRequest) GetLastChecked() uint64

+ func (m *InferenceRequest) GetNonce() uint64

+ func (m *InferenceRequest) GetRequestBytes() (ret []byte, err error)

+ func (m *InferenceRequest) GetRequestId() (string, error)

+ func (m *InferenceRequest) GetSender() string

+ func (m *InferenceRequest) GetTimestampValidUntil() uint64

+ func (m *InferenceRequest) GetTopicId() uint64

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

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

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

+ func (m *InferenceRequest) Reset()

+ func (m *InferenceRequest) Size() (n int)

+ func (m *InferenceRequest) String() string

+ func (m *InferenceRequest) Unmarshal(dAtA []byte) error

+ func (m *InferenceRequest) XXX_DiscardUnknown()

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

+ func (m *InferenceRequest) XXX_Merge(src proto.Message)

+ func (m *InferenceRequest) XXX_Size() int

+ func (m *InferenceRequest) XXX_Unmarshal(b []byte) error

+ type InferenceSetForScoring struct

+ Inferences *Inferences

+ Timestamp uint64

+ TopicId uint64

+ func (*InferenceSetForScoring) Descriptor() ([]byte, []int)

+ func (*InferenceSetForScoring) ProtoMessage()

+ func (m *InferenceSetForScoring) GetInferences() *Inferences

+ func (m *InferenceSetForScoring) GetTimestamp() uint64

+ func (m *InferenceSetForScoring) GetTopicId() uint64

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

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

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

+ func (m *InferenceSetForScoring) Reset()

+ func (m *InferenceSetForScoring) Size() (n int)

+ func (m *InferenceSetForScoring) String() string

+ func (m *InferenceSetForScoring) Unmarshal(dAtA []byte) error

+ func (m *InferenceSetForScoring) XXX_DiscardUnknown()

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

+ func (m *InferenceSetForScoring) XXX_Merge(src proto.Message)

+ func (m *InferenceSetForScoring) XXX_Size() int

+ func (m *InferenceSetForScoring) XXX_Unmarshal(b []byte) error

+ type Inferences struct

+ Inferences []*Inference

+ func (*Inferences) Descriptor() ([]byte, []int)

+ func (*Inferences) ProtoMessage()

+ func (m *Inferences) GetInferences() []*Inference

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

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

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

+ func (m *Inferences) Reset()

+ func (m *Inferences) Size() (n int)

+ func (m *Inferences) String() string

+ func (m *Inferences) Unmarshal(dAtA []byte) error

+ func (m *Inferences) XXX_DiscardUnknown()

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

+ func (m *Inferences) XXX_Merge(src proto.Message)

+ func (m *Inferences) XXX_Size() int

+ func (m *Inferences) XXX_Unmarshal(b []byte) error

+ type MsgAddNewRegistration struct

+ Creator string

+ IsReputer bool

+ LibP2PKey string

+ MultiAddress string

+ Owner string

+ TopicId uint64

+ func (*MsgAddNewRegistration) Descriptor() ([]byte, []int)

+ func (*MsgAddNewRegistration) ProtoMessage()

+ func (m *MsgAddNewRegistration) GetCreator() string

+ func (m *MsgAddNewRegistration) GetIsReputer() bool

+ func (m *MsgAddNewRegistration) GetLibP2PKey() string

+ func (m *MsgAddNewRegistration) GetMultiAddress() string

+ func (m *MsgAddNewRegistration) GetOwner() string

+ func (m *MsgAddNewRegistration) GetTopicId() uint64

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

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

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

+ func (m *MsgAddNewRegistration) Reset()

+ func (m *MsgAddNewRegistration) Size() (n int)

+ func (m *MsgAddNewRegistration) String() string

+ func (m *MsgAddNewRegistration) Unmarshal(dAtA []byte) error

+ func (m *MsgAddNewRegistration) XXX_DiscardUnknown()

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

+ func (m *MsgAddNewRegistration) XXX_Merge(src proto.Message)

+ func (m *MsgAddNewRegistration) XXX_Size() int

+ func (m *MsgAddNewRegistration) XXX_Unmarshal(b []byte) error

+ type MsgAddNewRegistrationResponse struct

+ Message string

+ Success bool

+ func (*MsgAddNewRegistrationResponse) Descriptor() ([]byte, []int)

+ func (*MsgAddNewRegistrationResponse) ProtoMessage()

+ func (m *MsgAddNewRegistrationResponse) GetMessage() string

+ func (m *MsgAddNewRegistrationResponse) GetSuccess() bool

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

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

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

+ func (m *MsgAddNewRegistrationResponse) Reset()

+ func (m *MsgAddNewRegistrationResponse) Size() (n int)

+ func (m *MsgAddNewRegistrationResponse) String() string

+ func (m *MsgAddNewRegistrationResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgAddNewRegistrationResponse) XXX_DiscardUnknown()

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

+ func (m *MsgAddNewRegistrationResponse) XXX_Merge(src proto.Message)

+ func (m *MsgAddNewRegistrationResponse) XXX_Size() int

+ func (m *MsgAddNewRegistrationResponse) XXX_Unmarshal(b []byte) error

+ type MsgAddStake struct

+ Amount cosmossdk_io_math.Uint

+ Sender string

+ StakeTarget string

+ func (*MsgAddStake) Descriptor() ([]byte, []int)

+ func (*MsgAddStake) ProtoMessage()

+ func (m *MsgAddStake) GetSender() string

+ func (m *MsgAddStake) GetStakeTarget() string

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

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

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

+ func (m *MsgAddStake) Reset()

+ func (m *MsgAddStake) Size() (n int)

+ func (m *MsgAddStake) String() string

+ func (m *MsgAddStake) Unmarshal(dAtA []byte) error

+ func (m *MsgAddStake) XXX_DiscardUnknown()

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

+ func (m *MsgAddStake) XXX_Merge(src proto.Message)

+ func (m *MsgAddStake) XXX_Size() int

+ func (m *MsgAddStake) XXX_Unmarshal(b []byte) error

+ type MsgAddStakeResponse struct

+ func (*MsgAddStakeResponse) Descriptor() ([]byte, []int)

+ func (*MsgAddStakeResponse) ProtoMessage()

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

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

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

+ func (m *MsgAddStakeResponse) Reset()

+ func (m *MsgAddStakeResponse) Size() (n int)

+ func (m *MsgAddStakeResponse) String() string

+ func (m *MsgAddStakeResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgAddStakeResponse) XXX_DiscardUnknown()

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

+ func (m *MsgAddStakeResponse) XXX_Merge(src proto.Message)

+ func (m *MsgAddStakeResponse) XXX_Size() int

+ func (m *MsgAddStakeResponse) XXX_Unmarshal(b []byte) error

+ type MsgClient interface

+ AddNewRegistration func(ctx context.Context, in *MsgAddNewRegistration, opts ...grpc.CallOption) (*MsgAddNewRegistrationResponse, error)

+ AddStake func(ctx context.Context, in *MsgAddStake, opts ...grpc.CallOption) (*MsgAddStakeResponse, error)

+ ConfirmRemoveStake func(ctx context.Context, in *MsgConfirmRemoveStake, opts ...grpc.CallOption) (*MsgConfirmRemoveStakeResponse, error)

+ CreateNewTopic func(ctx context.Context, in *MsgCreateNewTopic, opts ...grpc.CallOption) (*MsgCreateNewTopicResponse, error)

+ ModifyStake func(ctx context.Context, in *MsgModifyStake, opts ...grpc.CallOption) (*MsgModifyStakeResponse, error)

+ ProcessInferences func(ctx context.Context, in *MsgProcessInferences, opts ...grpc.CallOption) (*MsgProcessInferencesResponse, error)

+ Register func(ctx context.Context, in *MsgRegister, opts ...grpc.CallOption) (*MsgRegisterResponse, error)

+ RemoveRegistration func(ctx context.Context, in *MsgRemoveRegistration, opts ...grpc.CallOption) (*MsgRemoveRegistrationResponse, error)

+ RequestInference func(ctx context.Context, in *MsgRequestInference, opts ...grpc.CallOption) (*MsgRequestInferenceResponse, error)

+ SetInferences func(ctx context.Context, in *MsgSetInferences, opts ...grpc.CallOption) (*MsgSetInferencesResponse, error)

+ SetWeights func(ctx context.Context, in *MsgSetWeights, opts ...grpc.CallOption) (*MsgSetWeightsResponse, error)

+ StartRemoveAllStake func(ctx context.Context, in *MsgStartRemoveAllStake, opts ...grpc.CallOption) (*MsgStartRemoveAllStakeResponse, error)

+ StartRemoveStake func(ctx context.Context, in *MsgStartRemoveStake, opts ...grpc.CallOption) (*MsgStartRemoveStakeResponse, error)

+ func NewMsgClient(cc grpc1.ClientConn) MsgClient

+ type MsgConfirmRemoveStake struct

+ Sender string

+ func (*MsgConfirmRemoveStake) Descriptor() ([]byte, []int)

+ func (*MsgConfirmRemoveStake) ProtoMessage()

+ func (m *MsgConfirmRemoveStake) GetSender() string

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

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

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

+ func (m *MsgConfirmRemoveStake) Reset()

+ func (m *MsgConfirmRemoveStake) Size() (n int)

+ func (m *MsgConfirmRemoveStake) String() string

+ func (m *MsgConfirmRemoveStake) Unmarshal(dAtA []byte) error

+ func (m *MsgConfirmRemoveStake) XXX_DiscardUnknown()

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

+ func (m *MsgConfirmRemoveStake) XXX_Merge(src proto.Message)

+ func (m *MsgConfirmRemoveStake) XXX_Size() int

+ func (m *MsgConfirmRemoveStake) XXX_Unmarshal(b []byte) error

+ type MsgConfirmRemoveStakeResponse struct

+ func (*MsgConfirmRemoveStakeResponse) Descriptor() ([]byte, []int)

+ func (*MsgConfirmRemoveStakeResponse) ProtoMessage()

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

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

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

+ func (m *MsgConfirmRemoveStakeResponse) Reset()

+ func (m *MsgConfirmRemoveStakeResponse) Size() (n int)

+ func (m *MsgConfirmRemoveStakeResponse) String() string

+ func (m *MsgConfirmRemoveStakeResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgConfirmRemoveStakeResponse) XXX_DiscardUnknown()

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

+ func (m *MsgConfirmRemoveStakeResponse) XXX_Merge(src proto.Message)

+ func (m *MsgConfirmRemoveStakeResponse) XXX_Size() int

+ func (m *MsgConfirmRemoveStakeResponse) XXX_Unmarshal(b []byte) error

+ type MsgCreateNewTopic struct

+ Creator string

+ DefaultArg string

+ InferenceCadence uint64

+ InferenceLogic string

+ InferenceMethod string

+ Metadata string

+ WeightCadence uint64

+ WeightLogic string

+ WeightMethod string

+ func (*MsgCreateNewTopic) Descriptor() ([]byte, []int)

+ func (*MsgCreateNewTopic) ProtoMessage()

+ func (m *MsgCreateNewTopic) GetCreator() string

+ func (m *MsgCreateNewTopic) GetDefaultArg() string

+ func (m *MsgCreateNewTopic) GetInferenceCadence() uint64

+ func (m *MsgCreateNewTopic) GetInferenceLogic() string

+ func (m *MsgCreateNewTopic) GetInferenceMethod() string

+ func (m *MsgCreateNewTopic) GetMetadata() string

+ func (m *MsgCreateNewTopic) GetWeightCadence() uint64

+ func (m *MsgCreateNewTopic) GetWeightLogic() string

+ func (m *MsgCreateNewTopic) GetWeightMethod() string

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

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

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

+ func (m *MsgCreateNewTopic) Reset()

+ func (m *MsgCreateNewTopic) Size() (n int)

+ func (m *MsgCreateNewTopic) String() string

+ func (m *MsgCreateNewTopic) Unmarshal(dAtA []byte) error

+ func (m *MsgCreateNewTopic) XXX_DiscardUnknown()

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

+ func (m *MsgCreateNewTopic) XXX_Merge(src proto.Message)

+ func (m *MsgCreateNewTopic) XXX_Size() int

+ func (m *MsgCreateNewTopic) XXX_Unmarshal(b []byte) error

+ type MsgCreateNewTopicResponse struct

+ TopicId uint64

+ func (*MsgCreateNewTopicResponse) Descriptor() ([]byte, []int)

+ func (*MsgCreateNewTopicResponse) ProtoMessage()

+ func (m *MsgCreateNewTopicResponse) GetTopicId() uint64

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

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

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

+ func (m *MsgCreateNewTopicResponse) Reset()

+ func (m *MsgCreateNewTopicResponse) Size() (n int)

+ func (m *MsgCreateNewTopicResponse) String() string

+ func (m *MsgCreateNewTopicResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgCreateNewTopicResponse) XXX_DiscardUnknown()

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

+ func (m *MsgCreateNewTopicResponse) XXX_Merge(src proto.Message)

+ func (m *MsgCreateNewTopicResponse) XXX_Size() int

+ func (m *MsgCreateNewTopicResponse) XXX_Unmarshal(b []byte) error

+ type MsgModifyStake struct

+ PlacementsAdd []*StakePlacement

+ PlacementsRemove []*StakePlacement

+ Sender string

+ func (*MsgModifyStake) Descriptor() ([]byte, []int)

+ func (*MsgModifyStake) ProtoMessage()

+ func (m *MsgModifyStake) GetPlacementsAdd() []*StakePlacement

+ func (m *MsgModifyStake) GetPlacementsRemove() []*StakePlacement

+ func (m *MsgModifyStake) GetSender() string

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

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

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

+ func (m *MsgModifyStake) Reset()

+ func (m *MsgModifyStake) Size() (n int)

+ func (m *MsgModifyStake) String() string

+ func (m *MsgModifyStake) Unmarshal(dAtA []byte) error

+ func (m *MsgModifyStake) XXX_DiscardUnknown()

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

+ func (m *MsgModifyStake) XXX_Merge(src proto.Message)

+ func (m *MsgModifyStake) XXX_Size() int

+ func (m *MsgModifyStake) XXX_Unmarshal(b []byte) error

+ type MsgModifyStakeResponse struct

+ func (*MsgModifyStakeResponse) Descriptor() ([]byte, []int)

+ func (*MsgModifyStakeResponse) ProtoMessage()

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

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

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

+ func (m *MsgModifyStakeResponse) Reset()

+ func (m *MsgModifyStakeResponse) Size() (n int)

+ func (m *MsgModifyStakeResponse) String() string

+ func (m *MsgModifyStakeResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgModifyStakeResponse) XXX_DiscardUnknown()

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

+ func (m *MsgModifyStakeResponse) XXX_Merge(src proto.Message)

+ func (m *MsgModifyStakeResponse) XXX_Size() int

+ func (m *MsgModifyStakeResponse) XXX_Unmarshal(b []byte) error

+ type MsgProcessInferences struct

+ Inferences []*Inference

+ Sender string

+ func (*MsgProcessInferences) Descriptor() ([]byte, []int)

+ func (*MsgProcessInferences) ProtoMessage()

+ func (m *MsgProcessInferences) GetInferences() []*Inference

+ func (m *MsgProcessInferences) GetSender() string

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

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

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

+ func (m *MsgProcessInferences) Reset()

+ func (m *MsgProcessInferences) Size() (n int)

+ func (m *MsgProcessInferences) String() string

+ func (m *MsgProcessInferences) Unmarshal(dAtA []byte) error

+ func (m *MsgProcessInferences) XXX_DiscardUnknown()

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

+ func (m *MsgProcessInferences) XXX_Merge(src proto.Message)

+ func (m *MsgProcessInferences) XXX_Size() int

+ func (m *MsgProcessInferences) XXX_Unmarshal(b []byte) error

+ type MsgProcessInferencesResponse struct

+ func (*MsgProcessInferencesResponse) Descriptor() ([]byte, []int)

+ func (*MsgProcessInferencesResponse) ProtoMessage()

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

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

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

+ func (m *MsgProcessInferencesResponse) Reset()

+ func (m *MsgProcessInferencesResponse) Size() (n int)

+ func (m *MsgProcessInferencesResponse) String() string

+ func (m *MsgProcessInferencesResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgProcessInferencesResponse) XXX_DiscardUnknown()

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

+ func (m *MsgProcessInferencesResponse) XXX_Merge(src proto.Message)

+ func (m *MsgProcessInferencesResponse) XXX_Size() int

+ func (m *MsgProcessInferencesResponse) XXX_Unmarshal(b []byte) error

+ type MsgRegister struct

+ Creator string

+ InitialStake cosmossdk_io_math.Uint

+ IsReputer bool

+ LibP2PKey string

+ MultiAddress string

+ Owner string

+ TopicsIds []uint64

+ func (*MsgRegister) Descriptor() ([]byte, []int)

+ func (*MsgRegister) ProtoMessage()

+ func (m *MsgRegister) GetCreator() string

+ func (m *MsgRegister) GetInitialStake() cosmosMath.Uint

+ func (m *MsgRegister) GetIsReputer() bool

+ func (m *MsgRegister) GetLibP2PKey() string

+ func (m *MsgRegister) GetMultiAddress() string

+ func (m *MsgRegister) GetOwner() string

+ func (m *MsgRegister) GetTopicsIds() []uint64

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

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

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

+ func (m *MsgRegister) Reset()

+ func (m *MsgRegister) Size() (n int)

+ func (m *MsgRegister) String() string

+ func (m *MsgRegister) Unmarshal(dAtA []byte) error

+ func (m *MsgRegister) XXX_DiscardUnknown()

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

+ func (m *MsgRegister) XXX_Merge(src proto.Message)

+ func (m *MsgRegister) XXX_Size() int

+ func (m *MsgRegister) XXX_Unmarshal(b []byte) error

+ type MsgRegisterResponse struct

+ Message string

+ Success bool

+ func (*MsgRegisterResponse) Descriptor() ([]byte, []int)

+ func (*MsgRegisterResponse) ProtoMessage()

+ func (m *MsgRegisterResponse) GetMessage() string

+ func (m *MsgRegisterResponse) GetSuccess() bool

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

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

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

+ func (m *MsgRegisterResponse) Reset()

+ func (m *MsgRegisterResponse) Size() (n int)

+ func (m *MsgRegisterResponse) String() string

+ func (m *MsgRegisterResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgRegisterResponse) XXX_DiscardUnknown()

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

+ func (m *MsgRegisterResponse) XXX_Merge(src proto.Message)

+ func (m *MsgRegisterResponse) XXX_Size() int

+ func (m *MsgRegisterResponse) XXX_Unmarshal(b []byte) error

+ type MsgRemoveRegistration struct

+ Creator string

+ IsReputer bool

+ TopicId uint64

+ func (*MsgRemoveRegistration) Descriptor() ([]byte, []int)

+ func (*MsgRemoveRegistration) ProtoMessage()

+ func (m *MsgRemoveRegistration) GetCreator() string

+ func (m *MsgRemoveRegistration) GetIsReputer() bool

+ func (m *MsgRemoveRegistration) GetTopicId() uint64

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

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

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

+ func (m *MsgRemoveRegistration) Reset()

+ func (m *MsgRemoveRegistration) Size() (n int)

+ func (m *MsgRemoveRegistration) String() string

+ func (m *MsgRemoveRegistration) Unmarshal(dAtA []byte) error

+ func (m *MsgRemoveRegistration) XXX_DiscardUnknown()

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

+ func (m *MsgRemoveRegistration) XXX_Merge(src proto.Message)

+ func (m *MsgRemoveRegistration) XXX_Size() int

+ func (m *MsgRemoveRegistration) XXX_Unmarshal(b []byte) error

+ type MsgRemoveRegistrationResponse struct

+ Message string

+ Success bool

+ func (*MsgRemoveRegistrationResponse) Descriptor() ([]byte, []int)

+ func (*MsgRemoveRegistrationResponse) ProtoMessage()

+ func (m *MsgRemoveRegistrationResponse) GetMessage() string

+ func (m *MsgRemoveRegistrationResponse) GetSuccess() bool

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

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

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

+ func (m *MsgRemoveRegistrationResponse) Reset()

+ func (m *MsgRemoveRegistrationResponse) Size() (n int)

+ func (m *MsgRemoveRegistrationResponse) String() string

+ func (m *MsgRemoveRegistrationResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgRemoveRegistrationResponse) XXX_DiscardUnknown()

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

+ func (m *MsgRemoveRegistrationResponse) XXX_Merge(src proto.Message)

+ func (m *MsgRemoveRegistrationResponse) XXX_Size() int

+ func (m *MsgRemoveRegistrationResponse) XXX_Unmarshal(b []byte) error

+ type MsgRequestInference struct

+ Requests []*RequestInferenceListItem

+ Sender string

+ func (*MsgRequestInference) Descriptor() ([]byte, []int)

+ func (*MsgRequestInference) ProtoMessage()

+ func (m *MsgRequestInference) GetRequests() []*RequestInferenceListItem

+ func (m *MsgRequestInference) GetSender() string

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

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

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

+ func (m *MsgRequestInference) Reset()

+ func (m *MsgRequestInference) Size() (n int)

+ func (m *MsgRequestInference) String() string

+ func (m *MsgRequestInference) Unmarshal(dAtA []byte) error

+ func (m *MsgRequestInference) XXX_DiscardUnknown()

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

+ func (m *MsgRequestInference) XXX_Merge(src proto.Message)

+ func (m *MsgRequestInference) XXX_Size() int

+ func (m *MsgRequestInference) XXX_Unmarshal(b []byte) error

+ type MsgRequestInferenceResponse struct

+ func (*MsgRequestInferenceResponse) Descriptor() ([]byte, []int)

+ func (*MsgRequestInferenceResponse) ProtoMessage()

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

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

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

+ func (m *MsgRequestInferenceResponse) Reset()

+ func (m *MsgRequestInferenceResponse) Size() (n int)

+ func (m *MsgRequestInferenceResponse) String() string

+ func (m *MsgRequestInferenceResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgRequestInferenceResponse) XXX_DiscardUnknown()

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

+ func (m *MsgRequestInferenceResponse) XXX_Merge(src proto.Message)

+ func (m *MsgRequestInferenceResponse) XXX_Size() int

+ func (m *MsgRequestInferenceResponse) XXX_Unmarshal(b []byte) error

+ type MsgServer interface

+ AddNewRegistration func(context.Context, *MsgAddNewRegistration) (*MsgAddNewRegistrationResponse, error)

+ AddStake func(context.Context, *MsgAddStake) (*MsgAddStakeResponse, error)

+ ConfirmRemoveStake func(context.Context, *MsgConfirmRemoveStake) (*MsgConfirmRemoveStakeResponse, error)

+ CreateNewTopic func(context.Context, *MsgCreateNewTopic) (*MsgCreateNewTopicResponse, error)

+ ModifyStake func(context.Context, *MsgModifyStake) (*MsgModifyStakeResponse, error)

+ ProcessInferences func(context.Context, *MsgProcessInferences) (*MsgProcessInferencesResponse, error)

+ Register func(context.Context, *MsgRegister) (*MsgRegisterResponse, error)

+ RemoveRegistration func(context.Context, *MsgRemoveRegistration) (*MsgRemoveRegistrationResponse, error)

+ RequestInference func(context.Context, *MsgRequestInference) (*MsgRequestInferenceResponse, error)

+ SetInferences func(context.Context, *MsgSetInferences) (*MsgSetInferencesResponse, error)

+ SetWeights func(context.Context, *MsgSetWeights) (*MsgSetWeightsResponse, error)

+ StartRemoveAllStake func(context.Context, *MsgStartRemoveAllStake) (*MsgStartRemoveAllStakeResponse, error)

+ StartRemoveStake func(context.Context, *MsgStartRemoveStake) (*MsgStartRemoveStakeResponse, error)

+ type MsgSetInferences struct

+ Inferences []*Inference

+ Sender string

+ func (*MsgSetInferences) Descriptor() ([]byte, []int)

+ func (*MsgSetInferences) ProtoMessage()

+ func (m *MsgSetInferences) GetInferences() []*Inference

+ func (m *MsgSetInferences) GetSender() string

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

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

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

+ func (m *MsgSetInferences) Reset()

+ func (m *MsgSetInferences) Size() (n int)

+ func (m *MsgSetInferences) String() string

+ func (m *MsgSetInferences) Unmarshal(dAtA []byte) error

+ func (m *MsgSetInferences) XXX_DiscardUnknown()

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

+ func (m *MsgSetInferences) XXX_Merge(src proto.Message)

+ func (m *MsgSetInferences) XXX_Size() int

+ func (m *MsgSetInferences) XXX_Unmarshal(b []byte) error

+ type MsgSetInferencesResponse struct

+ func (*MsgSetInferencesResponse) Descriptor() ([]byte, []int)

+ func (*MsgSetInferencesResponse) ProtoMessage()

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

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

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

+ func (m *MsgSetInferencesResponse) Reset()

+ func (m *MsgSetInferencesResponse) Size() (n int)

+ func (m *MsgSetInferencesResponse) String() string

+ func (m *MsgSetInferencesResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgSetInferencesResponse) XXX_DiscardUnknown()

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

+ func (m *MsgSetInferencesResponse) XXX_Merge(src proto.Message)

+ func (m *MsgSetInferencesResponse) XXX_Size() int

+ func (m *MsgSetInferencesResponse) XXX_Unmarshal(b []byte) error

+ type MsgSetWeights struct

+ Sender string

+ Weights []*Weight

+ func (*MsgSetWeights) Descriptor() ([]byte, []int)

+ func (*MsgSetWeights) ProtoMessage()

+ func (m *MsgSetWeights) GetSender() string

+ func (m *MsgSetWeights) GetWeights() []*Weight

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

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

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

+ func (m *MsgSetWeights) Reset()

+ func (m *MsgSetWeights) Size() (n int)

+ func (m *MsgSetWeights) String() string

+ func (m *MsgSetWeights) Unmarshal(dAtA []byte) error

+ func (m *MsgSetWeights) XXX_DiscardUnknown()

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

+ func (m *MsgSetWeights) XXX_Merge(src proto.Message)

+ func (m *MsgSetWeights) XXX_Size() int

+ func (m *MsgSetWeights) XXX_Unmarshal(b []byte) error

+ type MsgSetWeightsResponse struct

+ func (*MsgSetWeightsResponse) Descriptor() ([]byte, []int)

+ func (*MsgSetWeightsResponse) ProtoMessage()

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

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

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

+ func (m *MsgSetWeightsResponse) Reset()

+ func (m *MsgSetWeightsResponse) Size() (n int)

+ func (m *MsgSetWeightsResponse) String() string

+ func (m *MsgSetWeightsResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgSetWeightsResponse) XXX_DiscardUnknown()

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

+ func (m *MsgSetWeightsResponse) XXX_Merge(src proto.Message)

+ func (m *MsgSetWeightsResponse) XXX_Size() int

+ func (m *MsgSetWeightsResponse) XXX_Unmarshal(b []byte) error

+ type MsgStartRemoveAllStake struct

+ Sender string

+ func (*MsgStartRemoveAllStake) Descriptor() ([]byte, []int)

+ func (*MsgStartRemoveAllStake) ProtoMessage()

+ func (m *MsgStartRemoveAllStake) GetSender() string

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

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

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

+ func (m *MsgStartRemoveAllStake) Reset()

+ func (m *MsgStartRemoveAllStake) Size() (n int)

+ func (m *MsgStartRemoveAllStake) String() string

+ func (m *MsgStartRemoveAllStake) Unmarshal(dAtA []byte) error

+ func (m *MsgStartRemoveAllStake) XXX_DiscardUnknown()

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

+ func (m *MsgStartRemoveAllStake) XXX_Merge(src proto.Message)

+ func (m *MsgStartRemoveAllStake) XXX_Size() int

+ func (m *MsgStartRemoveAllStake) XXX_Unmarshal(b []byte) error

+ type MsgStartRemoveAllStakeResponse struct

+ func (*MsgStartRemoveAllStakeResponse) Descriptor() ([]byte, []int)

+ func (*MsgStartRemoveAllStakeResponse) ProtoMessage()

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

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

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

+ func (m *MsgStartRemoveAllStakeResponse) Reset()

+ func (m *MsgStartRemoveAllStakeResponse) Size() (n int)

+ func (m *MsgStartRemoveAllStakeResponse) String() string

+ func (m *MsgStartRemoveAllStakeResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgStartRemoveAllStakeResponse) XXX_DiscardUnknown()

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

+ func (m *MsgStartRemoveAllStakeResponse) XXX_Merge(src proto.Message)

+ func (m *MsgStartRemoveAllStakeResponse) XXX_Size() int

+ func (m *MsgStartRemoveAllStakeResponse) XXX_Unmarshal(b []byte) error

+ type MsgStartRemoveStake struct

+ PlacementsRemove []*StakePlacement

+ Sender string

+ func (*MsgStartRemoveStake) Descriptor() ([]byte, []int)

+ func (*MsgStartRemoveStake) ProtoMessage()

+ func (m *MsgStartRemoveStake) GetPlacementsRemove() []*StakePlacement

+ func (m *MsgStartRemoveStake) GetSender() string

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

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

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

+ func (m *MsgStartRemoveStake) Reset()

+ func (m *MsgStartRemoveStake) Size() (n int)

+ func (m *MsgStartRemoveStake) String() string

+ func (m *MsgStartRemoveStake) Unmarshal(dAtA []byte) error

+ func (m *MsgStartRemoveStake) XXX_DiscardUnknown()

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

+ func (m *MsgStartRemoveStake) XXX_Merge(src proto.Message)

+ func (m *MsgStartRemoveStake) XXX_Size() int

+ func (m *MsgStartRemoveStake) XXX_Unmarshal(b []byte) error

+ type MsgStartRemoveStakeResponse struct

+ func (*MsgStartRemoveStakeResponse) Descriptor() ([]byte, []int)

+ func (*MsgStartRemoveStakeResponse) ProtoMessage()

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

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

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

+ func (m *MsgStartRemoveStakeResponse) Reset()

+ func (m *MsgStartRemoveStakeResponse) Size() (n int)

+ func (m *MsgStartRemoveStakeResponse) String() string

+ func (m *MsgStartRemoveStakeResponse) Unmarshal(dAtA []byte) error

+ func (m *MsgStartRemoveStakeResponse) XXX_DiscardUnknown()

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

+ func (m *MsgStartRemoveStakeResponse) XXX_Merge(src proto.Message)

+ func (m *MsgStartRemoveStakeResponse) XXX_Size() int

+ func (m *MsgStartRemoveStakeResponse) XXX_Unmarshal(b []byte) error

+ type OffchainNode struct

+ LibP2PKey string

+ MultiAddress string

+ NodeAddress string

+ NodeId string

+ Owner string

+ func (*OffchainNode) Descriptor() ([]byte, []int)

+ func (*OffchainNode) ProtoMessage()

+ func (m *OffchainNode) GetLibP2PKey() string

+ func (m *OffchainNode) GetMultiAddress() string

+ func (m *OffchainNode) GetNodeAddress() string

+ func (m *OffchainNode) GetNodeId() string

+ func (m *OffchainNode) GetOwner() string

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

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

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

+ func (m *OffchainNode) Reset()

+ func (m *OffchainNode) Size() (n int)

+ func (m *OffchainNode) String() string

+ func (m *OffchainNode) Unmarshal(dAtA []byte) error

+ func (m *OffchainNode) XXX_DiscardUnknown()

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

+ func (m *OffchainNode) XXX_Merge(src proto.Message)

+ func (m *OffchainNode) XXX_Size() int

+ func (m *OffchainNode) XXX_Unmarshal(b []byte) error

+ type OffchainNodes struct

+ OffchainNode []*Inference

+ func (*OffchainNodes) Descriptor() ([]byte, []int)

+ func (*OffchainNodes) ProtoMessage()

+ func (m *OffchainNodes) GetOffchainNode() []*Inference

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

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

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

+ func (m *OffchainNodes) Reset()

+ func (m *OffchainNodes) Size() (n int)

+ func (m *OffchainNodes) String() string

+ func (m *OffchainNodes) Unmarshal(dAtA []byte) error

+ func (m *OffchainNodes) XXX_DiscardUnknown()

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

+ func (m *OffchainNodes) XXX_Merge(src proto.Message)

+ func (m *OffchainNodes) XXX_Size() int

+ func (m *OffchainNodes) XXX_Unmarshal(b []byte) error

+ type Params struct

+ Version string

+ func DefaultParams() Params

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

+ func (*Params) ProtoMessage()

+ func (m *Params) GetVersion() string

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

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

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

+ func (m *Params) Reset()

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

+ func (m *Params) String() string

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

+ func (m *Params) XXX_DiscardUnknown()

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

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

+ func (m *Params) XXX_Size() int

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

+ func (p Params) Validate() error

+ type QueryAccountStakeListRequest struct

+ Address string

+ func (*QueryAccountStakeListRequest) Descriptor() ([]byte, []int)

+ func (*QueryAccountStakeListRequest) ProtoMessage()

+ func (m *QueryAccountStakeListRequest) GetAddress() string

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

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

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

+ func (m *QueryAccountStakeListRequest) Reset()

+ func (m *QueryAccountStakeListRequest) Size() (n int)

+ func (m *QueryAccountStakeListRequest) String() string

+ func (m *QueryAccountStakeListRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryAccountStakeListRequest) XXX_DiscardUnknown()

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

+ func (m *QueryAccountStakeListRequest) XXX_Merge(src proto.Message)

+ func (m *QueryAccountStakeListRequest) XXX_Size() int

+ func (m *QueryAccountStakeListRequest) XXX_Unmarshal(b []byte) error

+ type QueryAccountStakeListResponse struct

+ Stakes []*StakeInfo

+ func (*QueryAccountStakeListResponse) Descriptor() ([]byte, []int)

+ func (*QueryAccountStakeListResponse) ProtoMessage()

+ func (m *QueryAccountStakeListResponse) GetStakes() []*StakeInfo

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

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

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

+ func (m *QueryAccountStakeListResponse) Reset()

+ func (m *QueryAccountStakeListResponse) Size() (n int)

+ func (m *QueryAccountStakeListResponse) String() string

+ func (m *QueryAccountStakeListResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryAccountStakeListResponse) XXX_DiscardUnknown()

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

+ func (m *QueryAccountStakeListResponse) XXX_Merge(src proto.Message)

+ func (m *QueryAccountStakeListResponse) XXX_Size() int

+ func (m *QueryAccountStakeListResponse) XXX_Unmarshal(b []byte) error

+ type QueryAccumulatedEpochRewardsRequest struct

+ func (*QueryAccumulatedEpochRewardsRequest) Descriptor() ([]byte, []int)

+ func (*QueryAccumulatedEpochRewardsRequest) ProtoMessage()

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

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

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

+ func (m *QueryAccumulatedEpochRewardsRequest) Reset()

+ func (m *QueryAccumulatedEpochRewardsRequest) Size() (n int)

+ func (m *QueryAccumulatedEpochRewardsRequest) String() string

+ func (m *QueryAccumulatedEpochRewardsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryAccumulatedEpochRewardsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryAccumulatedEpochRewardsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryAccumulatedEpochRewardsRequest) XXX_Size() int

+ func (m *QueryAccumulatedEpochRewardsRequest) XXX_Unmarshal(b []byte) error

+ type QueryAccumulatedEpochRewardsResponse struct

+ Amount cosmossdk_io_math.Int

+ func (*QueryAccumulatedEpochRewardsResponse) Descriptor() ([]byte, []int)

+ func (*QueryAccumulatedEpochRewardsResponse) ProtoMessage()

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

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

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

+ func (m *QueryAccumulatedEpochRewardsResponse) Reset()

+ func (m *QueryAccumulatedEpochRewardsResponse) Size() (n int)

+ func (m *QueryAccumulatedEpochRewardsResponse) String() string

+ func (m *QueryAccumulatedEpochRewardsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryAccumulatedEpochRewardsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryAccumulatedEpochRewardsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryAccumulatedEpochRewardsResponse) XXX_Size() int

+ func (m *QueryAccumulatedEpochRewardsResponse) XXX_Unmarshal(b []byte) error

+ func (this *QueryAccumulatedEpochRewardsResponse) Equal(that interface{}) bool

+ type QueryActiveTopicsRequest struct

+ func (*QueryActiveTopicsRequest) Descriptor() ([]byte, []int)

+ func (*QueryActiveTopicsRequest) ProtoMessage()

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

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

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

+ func (m *QueryActiveTopicsRequest) Reset()

+ func (m *QueryActiveTopicsRequest) Size() (n int)

+ func (m *QueryActiveTopicsRequest) String() string

+ func (m *QueryActiveTopicsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryActiveTopicsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryActiveTopicsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryActiveTopicsRequest) XXX_Size() int

+ func (m *QueryActiveTopicsRequest) XXX_Unmarshal(b []byte) error

+ type QueryActiveTopicsResponse struct

+ Topics []*Topic

+ func (*QueryActiveTopicsResponse) Descriptor() ([]byte, []int)

+ func (*QueryActiveTopicsResponse) ProtoMessage()

+ func (m *QueryActiveTopicsResponse) GetTopics() []*Topic

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

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

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

+ func (m *QueryActiveTopicsResponse) Reset()

+ func (m *QueryActiveTopicsResponse) Size() (n int)

+ func (m *QueryActiveTopicsResponse) String() string

+ func (m *QueryActiveTopicsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryActiveTopicsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryActiveTopicsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryActiveTopicsResponse) XXX_Size() int

+ func (m *QueryActiveTopicsResponse) XXX_Unmarshal(b []byte) error

+ type QueryClient interface

+ GetAccountStakeList func(ctx context.Context, in *QueryAccountStakeListRequest, opts ...grpc.CallOption) (*QueryAccountStakeListResponse, error)

+ GetAccumulatedEpochRewards func(ctx context.Context, in *QueryAccumulatedEpochRewardsRequest, ...) (*QueryAccumulatedEpochRewardsResponse, error)

+ GetActiveTopics func(ctx context.Context, in *QueryActiveTopicsRequest, opts ...grpc.CallOption) (*QueryActiveTopicsResponse, error)

+ GetAllInferences func(ctx context.Context, in *QueryInferenceRequest, opts ...grpc.CallOption) (*QueryInferenceResponse, error)

+ GetInferencesToScore func(ctx context.Context, in *QueryInferencesToScoreRequest, ...) (*QueryInferencesToScoreResponse, error)

+ GetLastRewardsUpdate func(ctx context.Context, in *QueryLastRewardsUpdateRequest, ...) (*QueryLastRewardsUpdateResponse, error)

+ GetNextTopicId func(ctx context.Context, in *QueryNextTopicIdRequest, opts ...grpc.CallOption) (*QueryNextTopicIdResponse, error)

+ GetRegisteredTopicsIds func(ctx context.Context, in *QueryRegisteredTopicsIdsRequest, ...) (*QueryRegisteredTopicsIdsResponse, error)

+ GetTopic func(ctx context.Context, in *QueryTopicRequest, opts ...grpc.CallOption) (*QueryTopicResponse, error)

+ GetTopicsByCreator func(ctx context.Context, in *QueryGetTopicsByCreatorRequest, ...) (*QueryGetTopicsByCreatorResponse, error)

+ GetTotalStake func(ctx context.Context, in *QueryTotalStakeRequest, opts ...grpc.CallOption) (*QueryTotalStakeResponse, error)

+ GetWeight func(ctx context.Context, in *QueryWeightRequest, opts ...grpc.CallOption) (*QueryWeightResponse, error)

+ GetWorkerAddressByP2PKey func(ctx context.Context, in *QueryWorkerAddressByP2PKeyRequest, ...) (*QueryWorkerAddressByP2PKeyResponse, error)

+ GetWorkerNodeRegistration func(ctx context.Context, in *QueryRegisteredWorkerNodesRequest, ...) (*QueryRegisteredWorkerNodesResponse, error)

+ Params func(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)

+ func NewQueryClient(cc grpc1.ClientConn) QueryClient

+ type QueryGetTopicsByCreatorRequest struct

+ Creator string

+ func (*QueryGetTopicsByCreatorRequest) Descriptor() ([]byte, []int)

+ func (*QueryGetTopicsByCreatorRequest) ProtoMessage()

+ func (m *QueryGetTopicsByCreatorRequest) GetCreator() string

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

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

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

+ func (m *QueryGetTopicsByCreatorRequest) Reset()

+ func (m *QueryGetTopicsByCreatorRequest) Size() (n int)

+ func (m *QueryGetTopicsByCreatorRequest) String() string

+ func (m *QueryGetTopicsByCreatorRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryGetTopicsByCreatorRequest) XXX_DiscardUnknown()

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

+ func (m *QueryGetTopicsByCreatorRequest) XXX_Merge(src proto.Message)

+ func (m *QueryGetTopicsByCreatorRequest) XXX_Size() int

+ func (m *QueryGetTopicsByCreatorRequest) XXX_Unmarshal(b []byte) error

+ type QueryGetTopicsByCreatorResponse struct

+ Topics []*Topic

+ func (*QueryGetTopicsByCreatorResponse) Descriptor() ([]byte, []int)

+ func (*QueryGetTopicsByCreatorResponse) ProtoMessage()

+ func (m *QueryGetTopicsByCreatorResponse) GetTopics() []*Topic

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

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

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

+ func (m *QueryGetTopicsByCreatorResponse) Reset()

+ func (m *QueryGetTopicsByCreatorResponse) Size() (n int)

+ func (m *QueryGetTopicsByCreatorResponse) String() string

+ func (m *QueryGetTopicsByCreatorResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryGetTopicsByCreatorResponse) XXX_DiscardUnknown()

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

+ func (m *QueryGetTopicsByCreatorResponse) XXX_Merge(src proto.Message)

+ func (m *QueryGetTopicsByCreatorResponse) XXX_Size() int

+ func (m *QueryGetTopicsByCreatorResponse) XXX_Unmarshal(b []byte) error

+ type QueryInferenceRequest struct

+ Timestamp uint64

+ TopicId uint64

+ func (*QueryInferenceRequest) Descriptor() ([]byte, []int)

+ func (*QueryInferenceRequest) ProtoMessage()

+ func (m *QueryInferenceRequest) GetTimestamp() uint64

+ func (m *QueryInferenceRequest) GetTopicId() uint64

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

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

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

+ func (m *QueryInferenceRequest) Reset()

+ func (m *QueryInferenceRequest) Size() (n int)

+ func (m *QueryInferenceRequest) String() string

+ func (m *QueryInferenceRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryInferenceRequest) XXX_DiscardUnknown()

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

+ func (m *QueryInferenceRequest) XXX_Merge(src proto.Message)

+ func (m *QueryInferenceRequest) XXX_Size() int

+ func (m *QueryInferenceRequest) XXX_Unmarshal(b []byte) error

+ type QueryInferenceResponse struct

+ Inferences *Inferences

+ func (*QueryInferenceResponse) Descriptor() ([]byte, []int)

+ func (*QueryInferenceResponse) ProtoMessage()

+ func (m *QueryInferenceResponse) GetInferences() *Inferences

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

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

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

+ func (m *QueryInferenceResponse) Reset()

+ func (m *QueryInferenceResponse) Size() (n int)

+ func (m *QueryInferenceResponse) String() string

+ func (m *QueryInferenceResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryInferenceResponse) XXX_DiscardUnknown()

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

+ func (m *QueryInferenceResponse) XXX_Merge(src proto.Message)

+ func (m *QueryInferenceResponse) XXX_Size() int

+ func (m *QueryInferenceResponse) XXX_Unmarshal(b []byte) error

+ type QueryInferencesToScoreRequest struct

+ TopicId uint64

+ func (*QueryInferencesToScoreRequest) Descriptor() ([]byte, []int)

+ func (*QueryInferencesToScoreRequest) ProtoMessage()

+ func (m *QueryInferencesToScoreRequest) GetTopicId() uint64

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

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

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

+ func (m *QueryInferencesToScoreRequest) Reset()

+ func (m *QueryInferencesToScoreRequest) Size() (n int)

+ func (m *QueryInferencesToScoreRequest) String() string

+ func (m *QueryInferencesToScoreRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryInferencesToScoreRequest) XXX_DiscardUnknown()

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

+ func (m *QueryInferencesToScoreRequest) XXX_Merge(src proto.Message)

+ func (m *QueryInferencesToScoreRequest) XXX_Size() int

+ func (m *QueryInferencesToScoreRequest) XXX_Unmarshal(b []byte) error

+ type QueryInferencesToScoreResponse struct

+ Inferences []*InferenceSetForScoring

+ func (*QueryInferencesToScoreResponse) Descriptor() ([]byte, []int)

+ func (*QueryInferencesToScoreResponse) ProtoMessage()

+ func (m *QueryInferencesToScoreResponse) GetInferences() []*InferenceSetForScoring

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

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

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

+ func (m *QueryInferencesToScoreResponse) Reset()

+ func (m *QueryInferencesToScoreResponse) Size() (n int)

+ func (m *QueryInferencesToScoreResponse) String() string

+ func (m *QueryInferencesToScoreResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryInferencesToScoreResponse) XXX_DiscardUnknown()

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

+ func (m *QueryInferencesToScoreResponse) XXX_Merge(src proto.Message)

+ func (m *QueryInferencesToScoreResponse) XXX_Size() int

+ func (m *QueryInferencesToScoreResponse) XXX_Unmarshal(b []byte) error

+ type QueryLastRewardsUpdateRequest struct

+ func (*QueryLastRewardsUpdateRequest) Descriptor() ([]byte, []int)

+ func (*QueryLastRewardsUpdateRequest) ProtoMessage()

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

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

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

+ func (m *QueryLastRewardsUpdateRequest) Reset()

+ func (m *QueryLastRewardsUpdateRequest) Size() (n int)

+ func (m *QueryLastRewardsUpdateRequest) String() string

+ func (m *QueryLastRewardsUpdateRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryLastRewardsUpdateRequest) XXX_DiscardUnknown()

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

+ func (m *QueryLastRewardsUpdateRequest) XXX_Merge(src proto.Message)

+ func (m *QueryLastRewardsUpdateRequest) XXX_Size() int

+ func (m *QueryLastRewardsUpdateRequest) XXX_Unmarshal(b []byte) error

+ type QueryLastRewardsUpdateResponse struct

+ LastRewardsUpdate int64

+ func (*QueryLastRewardsUpdateResponse) Descriptor() ([]byte, []int)

+ func (*QueryLastRewardsUpdateResponse) ProtoMessage()

+ func (m *QueryLastRewardsUpdateResponse) GetLastRewardsUpdate() int64

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

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

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

+ func (m *QueryLastRewardsUpdateResponse) Reset()

+ func (m *QueryLastRewardsUpdateResponse) Size() (n int)

+ func (m *QueryLastRewardsUpdateResponse) String() string

+ func (m *QueryLastRewardsUpdateResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryLastRewardsUpdateResponse) XXX_DiscardUnknown()

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

+ func (m *QueryLastRewardsUpdateResponse) XXX_Merge(src proto.Message)

+ func (m *QueryLastRewardsUpdateResponse) XXX_Size() int

+ func (m *QueryLastRewardsUpdateResponse) XXX_Unmarshal(b []byte) error

+ type QueryNextTopicIdRequest struct

+ func (*QueryNextTopicIdRequest) Descriptor() ([]byte, []int)

+ func (*QueryNextTopicIdRequest) ProtoMessage()

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

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

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

+ func (m *QueryNextTopicIdRequest) Reset()

+ func (m *QueryNextTopicIdRequest) Size() (n int)

+ func (m *QueryNextTopicIdRequest) String() string

+ func (m *QueryNextTopicIdRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryNextTopicIdRequest) XXX_DiscardUnknown()

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

+ func (m *QueryNextTopicIdRequest) XXX_Merge(src proto.Message)

+ func (m *QueryNextTopicIdRequest) XXX_Size() int

+ func (m *QueryNextTopicIdRequest) XXX_Unmarshal(b []byte) error

+ type QueryNextTopicIdResponse struct

+ NextTopicId uint64

+ func (*QueryNextTopicIdResponse) Descriptor() ([]byte, []int)

+ func (*QueryNextTopicIdResponse) ProtoMessage()

+ func (m *QueryNextTopicIdResponse) GetNextTopicId() uint64

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

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

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

+ func (m *QueryNextTopicIdResponse) Reset()

+ func (m *QueryNextTopicIdResponse) Size() (n int)

+ func (m *QueryNextTopicIdResponse) String() string

+ func (m *QueryNextTopicIdResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryNextTopicIdResponse) XXX_DiscardUnknown()

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

+ func (m *QueryNextTopicIdResponse) XXX_Merge(src proto.Message)

+ func (m *QueryNextTopicIdResponse) XXX_Size() int

+ func (m *QueryNextTopicIdResponse) XXX_Unmarshal(b []byte) error

+ type QueryParamsRequest struct

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

+ func (*QueryParamsRequest) ProtoMessage()

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

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

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

+ func (m *QueryParamsRequest) Reset()

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

+ func (m *QueryParamsRequest) String() string

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

+ func (m *QueryParamsRequest) XXX_DiscardUnknown()

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

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

+ func (m *QueryParamsRequest) XXX_Size() int

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

+ type QueryParamsResponse struct

+ Params Params

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

+ func (*QueryParamsResponse) ProtoMessage()

+ func (m *QueryParamsResponse) GetParams() Params

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

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

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

+ func (m *QueryParamsResponse) Reset()

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

+ func (m *QueryParamsResponse) String() string

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

+ func (m *QueryParamsResponse) XXX_DiscardUnknown()

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

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

+ func (m *QueryParamsResponse) XXX_Size() int

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

+ type QueryRegisteredTopicsIdsRequest struct

+ Address string

+ IsReputer bool

+ func (*QueryRegisteredTopicsIdsRequest) Descriptor() ([]byte, []int)

+ func (*QueryRegisteredTopicsIdsRequest) ProtoMessage()

+ func (m *QueryRegisteredTopicsIdsRequest) GetAddress() string

+ func (m *QueryRegisteredTopicsIdsRequest) GetIsReputer() bool

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

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

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

+ func (m *QueryRegisteredTopicsIdsRequest) Reset()

+ func (m *QueryRegisteredTopicsIdsRequest) Size() (n int)

+ func (m *QueryRegisteredTopicsIdsRequest) String() string

+ func (m *QueryRegisteredTopicsIdsRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRegisteredTopicsIdsRequest) XXX_DiscardUnknown()

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

+ func (m *QueryRegisteredTopicsIdsRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRegisteredTopicsIdsRequest) XXX_Size() int

+ func (m *QueryRegisteredTopicsIdsRequest) XXX_Unmarshal(b []byte) error

+ type QueryRegisteredTopicsIdsResponse struct

+ TopicsIds []uint64

+ func (*QueryRegisteredTopicsIdsResponse) Descriptor() ([]byte, []int)

+ func (*QueryRegisteredTopicsIdsResponse) ProtoMessage()

+ func (m *QueryRegisteredTopicsIdsResponse) GetTopicsIds() []uint64

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

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

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

+ func (m *QueryRegisteredTopicsIdsResponse) Reset()

+ func (m *QueryRegisteredTopicsIdsResponse) Size() (n int)

+ func (m *QueryRegisteredTopicsIdsResponse) String() string

+ func (m *QueryRegisteredTopicsIdsResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryRegisteredTopicsIdsResponse) XXX_DiscardUnknown()

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

+ func (m *QueryRegisteredTopicsIdsResponse) XXX_Merge(src proto.Message)

+ func (m *QueryRegisteredTopicsIdsResponse) XXX_Size() int

+ func (m *QueryRegisteredTopicsIdsResponse) XXX_Unmarshal(b []byte) error

+ type QueryRegisteredWorkerNodesRequest struct

+ NodeId string

+ func (*QueryRegisteredWorkerNodesRequest) Descriptor() ([]byte, []int)

+ func (*QueryRegisteredWorkerNodesRequest) ProtoMessage()

+ func (m *QueryRegisteredWorkerNodesRequest) GetNodeId() string

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

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

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

+ func (m *QueryRegisteredWorkerNodesRequest) Reset()

+ func (m *QueryRegisteredWorkerNodesRequest) Size() (n int)

+ func (m *QueryRegisteredWorkerNodesRequest) String() string

+ func (m *QueryRegisteredWorkerNodesRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryRegisteredWorkerNodesRequest) XXX_DiscardUnknown()

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

+ func (m *QueryRegisteredWorkerNodesRequest) XXX_Merge(src proto.Message)

+ func (m *QueryRegisteredWorkerNodesRequest) XXX_Size() int

+ func (m *QueryRegisteredWorkerNodesRequest) XXX_Unmarshal(b []byte) error

+ type QueryRegisteredWorkerNodesResponse struct

+ Nodes []*OffchainNode

+ func (*QueryRegisteredWorkerNodesResponse) Descriptor() ([]byte, []int)

+ func (*QueryRegisteredWorkerNodesResponse) ProtoMessage()

+ func (m *QueryRegisteredWorkerNodesResponse) GetNodes() []*OffchainNode

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

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

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

+ func (m *QueryRegisteredWorkerNodesResponse) Reset()

+ func (m *QueryRegisteredWorkerNodesResponse) Size() (n int)

+ func (m *QueryRegisteredWorkerNodesResponse) String() string

+ func (m *QueryRegisteredWorkerNodesResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryRegisteredWorkerNodesResponse) XXX_DiscardUnknown()

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

+ func (m *QueryRegisteredWorkerNodesResponse) XXX_Merge(src proto.Message)

+ func (m *QueryRegisteredWorkerNodesResponse) XXX_Size() int

+ func (m *QueryRegisteredWorkerNodesResponse) XXX_Unmarshal(b []byte) error

+ type QueryServer interface

+ GetAccountStakeList func(context.Context, *QueryAccountStakeListRequest) (*QueryAccountStakeListResponse, error)

+ GetAccumulatedEpochRewards func(context.Context, *QueryAccumulatedEpochRewardsRequest) (*QueryAccumulatedEpochRewardsResponse, error)

+ GetActiveTopics func(context.Context, *QueryActiveTopicsRequest) (*QueryActiveTopicsResponse, error)

+ GetAllInferences func(context.Context, *QueryInferenceRequest) (*QueryInferenceResponse, error)

+ GetInferencesToScore func(context.Context, *QueryInferencesToScoreRequest) (*QueryInferencesToScoreResponse, error)

+ GetLastRewardsUpdate func(context.Context, *QueryLastRewardsUpdateRequest) (*QueryLastRewardsUpdateResponse, error)

+ GetNextTopicId func(context.Context, *QueryNextTopicIdRequest) (*QueryNextTopicIdResponse, error)

+ GetRegisteredTopicsIds func(context.Context, *QueryRegisteredTopicsIdsRequest) (*QueryRegisteredTopicsIdsResponse, error)

+ GetTopic func(context.Context, *QueryTopicRequest) (*QueryTopicResponse, error)

+ GetTopicsByCreator func(context.Context, *QueryGetTopicsByCreatorRequest) (*QueryGetTopicsByCreatorResponse, error)

+ GetTotalStake func(context.Context, *QueryTotalStakeRequest) (*QueryTotalStakeResponse, error)

+ GetWeight func(context.Context, *QueryWeightRequest) (*QueryWeightResponse, error)

+ GetWorkerAddressByP2PKey func(context.Context, *QueryWorkerAddressByP2PKeyRequest) (*QueryWorkerAddressByP2PKeyResponse, error)

+ GetWorkerNodeRegistration func(context.Context, *QueryRegisteredWorkerNodesRequest) (*QueryRegisteredWorkerNodesResponse, error)

+ Params func(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)

+ type QueryTopicRequest struct

+ TopicId uint64

+ func (*QueryTopicRequest) Descriptor() ([]byte, []int)

+ func (*QueryTopicRequest) ProtoMessage()

+ func (m *QueryTopicRequest) GetTopicId() uint64

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

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

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

+ func (m *QueryTopicRequest) Reset()

+ func (m *QueryTopicRequest) Size() (n int)

+ func (m *QueryTopicRequest) String() string

+ func (m *QueryTopicRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryTopicRequest) XXX_DiscardUnknown()

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

+ func (m *QueryTopicRequest) XXX_Merge(src proto.Message)

+ func (m *QueryTopicRequest) XXX_Size() int

+ func (m *QueryTopicRequest) XXX_Unmarshal(b []byte) error

+ type QueryTopicResponse struct

+ Topic *Topic

+ func (*QueryTopicResponse) Descriptor() ([]byte, []int)

+ func (*QueryTopicResponse) ProtoMessage()

+ func (m *QueryTopicResponse) GetTopic() *Topic

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

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

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

+ func (m *QueryTopicResponse) Reset()

+ func (m *QueryTopicResponse) Size() (n int)

+ func (m *QueryTopicResponse) String() string

+ func (m *QueryTopicResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryTopicResponse) XXX_DiscardUnknown()

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

+ func (m *QueryTopicResponse) XXX_Merge(src proto.Message)

+ func (m *QueryTopicResponse) XXX_Size() int

+ func (m *QueryTopicResponse) XXX_Unmarshal(b []byte) error

+ type QueryTotalStakeRequest struct

+ func (*QueryTotalStakeRequest) Descriptor() ([]byte, []int)

+ func (*QueryTotalStakeRequest) ProtoMessage()

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

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

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

+ func (m *QueryTotalStakeRequest) Reset()

+ func (m *QueryTotalStakeRequest) Size() (n int)

+ func (m *QueryTotalStakeRequest) String() string

+ func (m *QueryTotalStakeRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryTotalStakeRequest) XXX_DiscardUnknown()

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

+ func (m *QueryTotalStakeRequest) XXX_Merge(src proto.Message)

+ func (m *QueryTotalStakeRequest) XXX_Size() int

+ func (m *QueryTotalStakeRequest) XXX_Unmarshal(b []byte) error

+ type QueryTotalStakeResponse struct

+ Amount cosmossdk_io_math.Uint

+ func (*QueryTotalStakeResponse) Descriptor() ([]byte, []int)

+ func (*QueryTotalStakeResponse) ProtoMessage()

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

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

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

+ func (m *QueryTotalStakeResponse) Reset()

+ func (m *QueryTotalStakeResponse) Size() (n int)

+ func (m *QueryTotalStakeResponse) String() string

+ func (m *QueryTotalStakeResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryTotalStakeResponse) XXX_DiscardUnknown()

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

+ func (m *QueryTotalStakeResponse) XXX_Merge(src proto.Message)

+ func (m *QueryTotalStakeResponse) XXX_Size() int

+ func (m *QueryTotalStakeResponse) XXX_Unmarshal(b []byte) error

+ func (this *QueryTotalStakeResponse) Equal(that interface{}) bool

+ type QueryWeightRequest struct

+ Reputer string

+ TopicId uint64

+ Worker string

+ func (*QueryWeightRequest) Descriptor() ([]byte, []int)

+ func (*QueryWeightRequest) ProtoMessage()

+ func (m *QueryWeightRequest) GetReputer() string

+ func (m *QueryWeightRequest) GetTopicId() uint64

+ func (m *QueryWeightRequest) GetWorker() string

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

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

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

+ func (m *QueryWeightRequest) Reset()

+ func (m *QueryWeightRequest) Size() (n int)

+ func (m *QueryWeightRequest) String() string

+ func (m *QueryWeightRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryWeightRequest) XXX_DiscardUnknown()

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

+ func (m *QueryWeightRequest) XXX_Merge(src proto.Message)

+ func (m *QueryWeightRequest) XXX_Size() int

+ func (m *QueryWeightRequest) XXX_Unmarshal(b []byte) error

+ type QueryWeightResponse struct

+ Amount cosmossdk_io_math.Uint

+ func (*QueryWeightResponse) Descriptor() ([]byte, []int)

+ func (*QueryWeightResponse) ProtoMessage()

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

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

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

+ func (m *QueryWeightResponse) Reset()

+ func (m *QueryWeightResponse) Size() (n int)

+ func (m *QueryWeightResponse) String() string

+ func (m *QueryWeightResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryWeightResponse) XXX_DiscardUnknown()

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

+ func (m *QueryWeightResponse) XXX_Merge(src proto.Message)

+ func (m *QueryWeightResponse) XXX_Size() int

+ func (m *QueryWeightResponse) XXX_Unmarshal(b []byte) error

+ func (this *QueryWeightResponse) Equal(that interface{}) bool

+ type QueryWorkerAddressByP2PKeyRequest struct

+ Libp2PKey string

+ func (*QueryWorkerAddressByP2PKeyRequest) Descriptor() ([]byte, []int)

+ func (*QueryWorkerAddressByP2PKeyRequest) ProtoMessage()

+ func (m *QueryWorkerAddressByP2PKeyRequest) GetLibp2PKey() string

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

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

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

+ func (m *QueryWorkerAddressByP2PKeyRequest) Reset()

+ func (m *QueryWorkerAddressByP2PKeyRequest) Size() (n int)

+ func (m *QueryWorkerAddressByP2PKeyRequest) String() string

+ func (m *QueryWorkerAddressByP2PKeyRequest) Unmarshal(dAtA []byte) error

+ func (m *QueryWorkerAddressByP2PKeyRequest) XXX_DiscardUnknown()

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

+ func (m *QueryWorkerAddressByP2PKeyRequest) XXX_Merge(src proto.Message)

+ func (m *QueryWorkerAddressByP2PKeyRequest) XXX_Size() int

+ func (m *QueryWorkerAddressByP2PKeyRequest) XXX_Unmarshal(b []byte) error

+ type QueryWorkerAddressByP2PKeyResponse struct

+ Address string

+ func (*QueryWorkerAddressByP2PKeyResponse) Descriptor() ([]byte, []int)

+ func (*QueryWorkerAddressByP2PKeyResponse) ProtoMessage()

+ func (m *QueryWorkerAddressByP2PKeyResponse) GetAddress() string

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

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

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

+ func (m *QueryWorkerAddressByP2PKeyResponse) Reset()

+ func (m *QueryWorkerAddressByP2PKeyResponse) Size() (n int)

+ func (m *QueryWorkerAddressByP2PKeyResponse) String() string

+ func (m *QueryWorkerAddressByP2PKeyResponse) Unmarshal(dAtA []byte) error

+ func (m *QueryWorkerAddressByP2PKeyResponse) XXX_DiscardUnknown()

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

+ func (m *QueryWorkerAddressByP2PKeyResponse) XXX_Merge(src proto.Message)

+ func (m *QueryWorkerAddressByP2PKeyResponse) XXX_Size() int

+ func (m *QueryWorkerAddressByP2PKeyResponse) XXX_Unmarshal(b []byte) error

+ type RequestInferenceListItem struct

+ BidAmount cosmossdk_io_math.Uint

+ Cadence uint64

+ ExtraData []byte

+ MaxPricePerInference cosmossdk_io_math.Uint

+ Nonce uint64

+ TimestampValidUntil uint64

+ TopicId uint64

+ func (*RequestInferenceListItem) Descriptor() ([]byte, []int)

+ func (*RequestInferenceListItem) ProtoMessage()

+ func (m *RequestInferenceListItem) GetCadence() uint64

+ func (m *RequestInferenceListItem) GetExtraData() []byte

+ func (m *RequestInferenceListItem) GetNonce() uint64

+ func (m *RequestInferenceListItem) GetTimestampValidUntil() uint64

+ func (m *RequestInferenceListItem) GetTopicId() uint64

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

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

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

+ func (m *RequestInferenceListItem) Reset()

+ func (m *RequestInferenceListItem) Size() (n int)

+ func (m *RequestInferenceListItem) String() string

+ func (m *RequestInferenceListItem) Unmarshal(dAtA []byte) error

+ func (m *RequestInferenceListItem) XXX_DiscardUnknown()

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

+ func (m *RequestInferenceListItem) XXX_Merge(src proto.Message)

+ func (m *RequestInferenceListItem) XXX_Size() int

+ func (m *RequestInferenceListItem) XXX_Unmarshal(b []byte) error

+ type StakeInfo struct

+ Address string

+ Amount string

+ func (*StakeInfo) Descriptor() ([]byte, []int)

+ func (*StakeInfo) ProtoMessage()

+ func (m *StakeInfo) GetAddress() string

+ func (m *StakeInfo) GetAmount() string

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

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

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

+ func (m *StakeInfo) Reset()

+ func (m *StakeInfo) Size() (n int)

+ func (m *StakeInfo) String() string

+ func (m *StakeInfo) Unmarshal(dAtA []byte) error

+ func (m *StakeInfo) XXX_DiscardUnknown()

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

+ func (m *StakeInfo) XXX_Merge(src proto.Message)

+ func (m *StakeInfo) XXX_Size() int

+ func (m *StakeInfo) XXX_Unmarshal(b []byte) error

+ type StakePlacement struct

+ Amount cosmossdk_io_math.Uint

+ Target string

+ func (*StakePlacement) Descriptor() ([]byte, []int)

+ func (*StakePlacement) ProtoMessage()

+ func (m *StakePlacement) GetTarget() string

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

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

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

+ func (m *StakePlacement) Reset()

+ func (m *StakePlacement) Size() (n int)

+ func (m *StakePlacement) String() string

+ func (m *StakePlacement) Unmarshal(dAtA []byte) error

+ func (m *StakePlacement) XXX_DiscardUnknown()

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

+ func (m *StakePlacement) XXX_Merge(src proto.Message)

+ func (m *StakePlacement) XXX_Size() int

+ func (m *StakePlacement) XXX_Unmarshal(b []byte) error

+ type StakeRemoval struct

+ Placements []*StakeRemovalPlacement

+ TimestampRemovalStarted uint64

+ func (*StakeRemoval) Descriptor() ([]byte, []int)

+ func (*StakeRemoval) ProtoMessage()

+ func (m *StakeRemoval) GetPlacements() []*StakeRemovalPlacement

+ func (m *StakeRemoval) GetTimestampRemovalStarted() uint64

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

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

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

+ func (m *StakeRemoval) Reset()

+ func (m *StakeRemoval) Size() (n int)

+ func (m *StakeRemoval) String() string

+ func (m *StakeRemoval) Unmarshal(dAtA []byte) error

+ func (m *StakeRemoval) XXX_DiscardUnknown()

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

+ func (m *StakeRemoval) XXX_Merge(src proto.Message)

+ func (m *StakeRemoval) XXX_Size() int

+ func (m *StakeRemoval) XXX_Unmarshal(b []byte) error

+ type StakeRemovalPlacement struct

+ Amount cosmossdk_io_math.Uint

+ Target string

+ TopicsIds []uint64

+ func (*StakeRemovalPlacement) Descriptor() ([]byte, []int)

+ func (*StakeRemovalPlacement) ProtoMessage()

+ func (m *StakeRemovalPlacement) GetTarget() string

+ func (m *StakeRemovalPlacement) GetTopicsIds() []uint64

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

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

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

+ func (m *StakeRemovalPlacement) Reset()

+ func (m *StakeRemovalPlacement) Size() (n int)

+ func (m *StakeRemovalPlacement) String() string

+ func (m *StakeRemovalPlacement) Unmarshal(dAtA []byte) error

+ func (m *StakeRemovalPlacement) XXX_DiscardUnknown()

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

+ func (m *StakeRemovalPlacement) XXX_Merge(src proto.Message)

+ func (m *StakeRemovalPlacement) XXX_Size() int

+ func (m *StakeRemovalPlacement) XXX_Unmarshal(b []byte) error

+ type Topic struct

+ Active bool

+ Creator string

+ DefaultArg string

+ Id uint64

+ InferenceCadence uint64

+ InferenceLastRan uint64

+ InferenceLogic string

+ InferenceMethod string

+ Metadata string

+ WeightCadence uint64

+ WeightLastRan uint64

+ WeightLogic string

+ WeightMethod string

+ func (*Topic) Descriptor() ([]byte, []int)

+ func (*Topic) ProtoMessage()

+ func (m *Topic) GetActive() bool

+ func (m *Topic) GetCreator() string

+ func (m *Topic) GetDefaultArg() string

+ func (m *Topic) GetId() uint64

+ func (m *Topic) GetInferenceCadence() uint64

+ func (m *Topic) GetInferenceLastRan() uint64

+ func (m *Topic) GetInferenceLogic() string

+ func (m *Topic) GetInferenceMethod() string

+ func (m *Topic) GetMetadata() string

+ func (m *Topic) GetWeightCadence() uint64

+ func (m *Topic) GetWeightLastRan() uint64

+ func (m *Topic) GetWeightLogic() string

+ func (m *Topic) GetWeightMethod() string

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

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

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

+ func (m *Topic) Reset()

+ func (m *Topic) Size() (n int)

+ func (m *Topic) String() string

+ func (m *Topic) Unmarshal(dAtA []byte) error

+ func (m *Topic) XXX_DiscardUnknown()

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

+ func (m *Topic) XXX_Merge(src proto.Message)

+ func (m *Topic) XXX_Size() int

+ func (m *Topic) XXX_Unmarshal(b []byte) error

+ type UnimplementedMsgServer struct

+ func (*UnimplementedMsgServer) AddNewRegistration(ctx context.Context, req *MsgAddNewRegistration) (*MsgAddNewRegistrationResponse, error)

+ func (*UnimplementedMsgServer) AddStake(ctx context.Context, req *MsgAddStake) (*MsgAddStakeResponse, error)

+ func (*UnimplementedMsgServer) ConfirmRemoveStake(ctx context.Context, req *MsgConfirmRemoveStake) (*MsgConfirmRemoveStakeResponse, error)

+ func (*UnimplementedMsgServer) CreateNewTopic(ctx context.Context, req *MsgCreateNewTopic) (*MsgCreateNewTopicResponse, error)

+ func (*UnimplementedMsgServer) ModifyStake(ctx context.Context, req *MsgModifyStake) (*MsgModifyStakeResponse, error)

+ func (*UnimplementedMsgServer) ProcessInferences(ctx context.Context, req *MsgProcessInferences) (*MsgProcessInferencesResponse, error)

+ func (*UnimplementedMsgServer) Register(ctx context.Context, req *MsgRegister) (*MsgRegisterResponse, error)

+ func (*UnimplementedMsgServer) RemoveRegistration(ctx context.Context, req *MsgRemoveRegistration) (*MsgRemoveRegistrationResponse, error)

+ func (*UnimplementedMsgServer) RequestInference(ctx context.Context, req *MsgRequestInference) (*MsgRequestInferenceResponse, error)

+ func (*UnimplementedMsgServer) SetInferences(ctx context.Context, req *MsgSetInferences) (*MsgSetInferencesResponse, error)

+ func (*UnimplementedMsgServer) SetWeights(ctx context.Context, req *MsgSetWeights) (*MsgSetWeightsResponse, error)

+ func (*UnimplementedMsgServer) StartRemoveAllStake(ctx context.Context, req *MsgStartRemoveAllStake) (*MsgStartRemoveAllStakeResponse, error)

+ func (*UnimplementedMsgServer) StartRemoveStake(ctx context.Context, req *MsgStartRemoveStake) (*MsgStartRemoveStakeResponse, error)

+ type UnimplementedQueryServer struct

+ func (*UnimplementedQueryServer) GetAccountStakeList(ctx context.Context, req *QueryAccountStakeListRequest) (*QueryAccountStakeListResponse, error)

+ func (*UnimplementedQueryServer) GetAccumulatedEpochRewards(ctx context.Context, req *QueryAccumulatedEpochRewardsRequest) (*QueryAccumulatedEpochRewardsResponse, error)

+ func (*UnimplementedQueryServer) GetActiveTopics(ctx context.Context, req *QueryActiveTopicsRequest) (*QueryActiveTopicsResponse, error)

+ func (*UnimplementedQueryServer) GetAllInferences(ctx context.Context, req *QueryInferenceRequest) (*QueryInferenceResponse, error)

+ func (*UnimplementedQueryServer) GetInferencesToScore(ctx context.Context, req *QueryInferencesToScoreRequest) (*QueryInferencesToScoreResponse, error)

+ func (*UnimplementedQueryServer) GetLastRewardsUpdate(ctx context.Context, req *QueryLastRewardsUpdateRequest) (*QueryLastRewardsUpdateResponse, error)

+ func (*UnimplementedQueryServer) GetNextTopicId(ctx context.Context, req *QueryNextTopicIdRequest) (*QueryNextTopicIdResponse, error)

+ func (*UnimplementedQueryServer) GetRegisteredTopicsIds(ctx context.Context, req *QueryRegisteredTopicsIdsRequest) (*QueryRegisteredTopicsIdsResponse, error)

+ func (*UnimplementedQueryServer) GetTopic(ctx context.Context, req *QueryTopicRequest) (*QueryTopicResponse, error)

+ func (*UnimplementedQueryServer) GetTopicsByCreator(ctx context.Context, req *QueryGetTopicsByCreatorRequest) (*QueryGetTopicsByCreatorResponse, error)

+ func (*UnimplementedQueryServer) GetTotalStake(ctx context.Context, req *QueryTotalStakeRequest) (*QueryTotalStakeResponse, error)

+ func (*UnimplementedQueryServer) GetWeight(ctx context.Context, req *QueryWeightRequest) (*QueryWeightResponse, error)

+ func (*UnimplementedQueryServer) GetWorkerAddressByP2PKey(ctx context.Context, req *QueryWorkerAddressByP2PKeyRequest) (*QueryWorkerAddressByP2PKeyResponse, error)

+ func (*UnimplementedQueryServer) GetWorkerNodeRegistration(ctx context.Context, req *QueryRegisteredWorkerNodesRequest) (*QueryRegisteredWorkerNodesResponse, error)

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

+ type Weight struct

+ Reputer string

+ TopicId uint64

+ Weight cosmossdk_io_math.Uint

+ Worker string

+ func (*Weight) Descriptor() ([]byte, []int)

+ func (*Weight) ProtoMessage()

+ func (m *Weight) GetReputer() string

+ func (m *Weight) GetTopicId() uint64

+ func (m *Weight) GetWorker() string

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

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

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

+ func (m *Weight) Reset()

+ func (m *Weight) Size() (n int)

+ func (m *Weight) String() string

+ func (m *Weight) Unmarshal(dAtA []byte) error

+ func (m *Weight) XXX_DiscardUnknown()

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

+ func (m *Weight) XXX_Merge(src proto.Message)

+ func (m *Weight) XXX_Size() int

+ func (m *Weight) XXX_Unmarshal(b []byte) error

+ func (this *Weight) Equal(that interface{}) bool

+ type Weights struct

+ Weights []*Weight

+ func (*Weights) Descriptor() ([]byte, []int)

+ func (*Weights) ProtoMessage()

+ func (m *Weights) GetWeights() []*Weight

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

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

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

+ func (m *Weights) Reset()

+ func (m *Weights) Size() (n int)

+ func (m *Weights) String() string

+ func (m *Weights) Unmarshal(dAtA []byte) error

+ func (m *Weights) XXX_DiscardUnknown()

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

+ func (m *Weights) XXX_Merge(src proto.Message)

+ func (m *Weights) XXX_Size() int

+ func (m *Weights) XXX_Unmarshal(b []byte) error

v0.0.0-dev.0

Feb 14, 2024

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