Documentation ¶
Overview ¶
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)
- func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)deprecated
- func (x *GenesisState) GetCoreTeamAddresses() []string
- func (x *GenesisState) GetParams() *Params
- func (*GenesisState) ProtoMessage()
- func (x *GenesisState) ProtoReflect() protoreflect.Message
- func (x *GenesisState) Reset()
- func (x *GenesisState) String() string
- type Inference
- func (*Inference) Descriptor() ([]byte, []int)deprecated
- func (x *Inference) GetExtraData() []byte
- func (x *Inference) GetProof() string
- func (x *Inference) GetTopicId() uint64
- func (x *Inference) GetValue() string
- func (x *Inference) GetWorker() string
- func (*Inference) ProtoMessage()
- func (x *Inference) ProtoReflect() protoreflect.Message
- func (x *Inference) Reset()
- func (x *Inference) String() string
- type InferenceRequest
- func (*InferenceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *InferenceRequest) GetBidAmount() string
- func (x *InferenceRequest) GetCadence() uint64
- func (x *InferenceRequest) GetExtraData() []byte
- func (x *InferenceRequest) GetLastChecked() uint64
- func (x *InferenceRequest) GetMaxPricePerInference() string
- func (x *InferenceRequest) GetNonce() uint64
- func (x *InferenceRequest) GetSender() string
- func (x *InferenceRequest) GetTimestampValidUntil() uint64
- func (x *InferenceRequest) GetTopicId() uint64
- func (*InferenceRequest) ProtoMessage()
- func (x *InferenceRequest) ProtoReflect() protoreflect.Message
- func (x *InferenceRequest) Reset()
- func (x *InferenceRequest) String() string
- type InferenceRequestAndDemandLeft
- func (*InferenceRequestAndDemandLeft) Descriptor() ([]byte, []int)deprecated
- func (x *InferenceRequestAndDemandLeft) GetDemandLeft() string
- func (x *InferenceRequestAndDemandLeft) GetInferenceRequest() *InferenceRequest
- func (*InferenceRequestAndDemandLeft) ProtoMessage()
- func (x *InferenceRequestAndDemandLeft) ProtoReflect() protoreflect.Message
- func (x *InferenceRequestAndDemandLeft) Reset()
- func (x *InferenceRequestAndDemandLeft) String() string
- type InferenceSetForScoring
- func (*InferenceSetForScoring) Descriptor() ([]byte, []int)deprecated
- func (x *InferenceSetForScoring) GetInferences() *Inferences
- func (x *InferenceSetForScoring) GetTimestamp() uint64
- func (x *InferenceSetForScoring) GetTopicId() uint64
- func (*InferenceSetForScoring) ProtoMessage()
- func (x *InferenceSetForScoring) ProtoReflect() protoreflect.Message
- func (x *InferenceSetForScoring) Reset()
- func (x *InferenceSetForScoring) String() string
- type Inferences
- type MsgAddNewRegistration
- func (*MsgAddNewRegistration) Descriptor() ([]byte, []int)deprecated
- func (x *MsgAddNewRegistration) GetCreator() string
- func (x *MsgAddNewRegistration) GetIsReputer() bool
- func (x *MsgAddNewRegistration) GetLibP2PKey() string
- func (x *MsgAddNewRegistration) GetMultiAddress() string
- func (x *MsgAddNewRegistration) GetOwner() string
- func (x *MsgAddNewRegistration) GetTopicId() uint64
- func (*MsgAddNewRegistration) ProtoMessage()
- func (x *MsgAddNewRegistration) ProtoReflect() protoreflect.Message
- func (x *MsgAddNewRegistration) Reset()
- func (x *MsgAddNewRegistration) String() string
- type MsgAddNewRegistrationResponse
- func (*MsgAddNewRegistrationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgAddNewRegistrationResponse) GetMessage() string
- func (x *MsgAddNewRegistrationResponse) GetSuccess() bool
- func (*MsgAddNewRegistrationResponse) ProtoMessage()
- func (x *MsgAddNewRegistrationResponse) ProtoReflect() protoreflect.Message
- func (x *MsgAddNewRegistrationResponse) Reset()
- func (x *MsgAddNewRegistrationResponse) String() string
- type MsgAddStake
- func (*MsgAddStake) Descriptor() ([]byte, []int)deprecated
- func (x *MsgAddStake) GetAmount() string
- func (x *MsgAddStake) GetSender() string
- func (x *MsgAddStake) GetStakeTarget() string
- func (*MsgAddStake) ProtoMessage()
- func (x *MsgAddStake) ProtoReflect() protoreflect.Message
- func (x *MsgAddStake) Reset()
- func (x *MsgAddStake) String() string
- type MsgAddStakeResponse
- type MsgAddToTopicCreationWhitelist
- func (*MsgAddToTopicCreationWhitelist) Descriptor() ([]byte, []int)deprecated
- func (x *MsgAddToTopicCreationWhitelist) GetAddress() string
- func (x *MsgAddToTopicCreationWhitelist) GetSender() string
- func (*MsgAddToTopicCreationWhitelist) ProtoMessage()
- func (x *MsgAddToTopicCreationWhitelist) ProtoReflect() protoreflect.Message
- func (x *MsgAddToTopicCreationWhitelist) Reset()
- func (x *MsgAddToTopicCreationWhitelist) String() string
- type MsgAddToTopicCreationWhitelistResponse
- func (*MsgAddToTopicCreationWhitelistResponse) Descriptor() ([]byte, []int)deprecated
- func (*MsgAddToTopicCreationWhitelistResponse) ProtoMessage()
- func (x *MsgAddToTopicCreationWhitelistResponse) ProtoReflect() protoreflect.Message
- func (x *MsgAddToTopicCreationWhitelistResponse) Reset()
- func (x *MsgAddToTopicCreationWhitelistResponse) String() string
- type MsgAddToWeightSettingWhitelist
- func (*MsgAddToWeightSettingWhitelist) Descriptor() ([]byte, []int)deprecated
- func (x *MsgAddToWeightSettingWhitelist) GetAddress() string
- func (x *MsgAddToWeightSettingWhitelist) GetSender() string
- func (*MsgAddToWeightSettingWhitelist) ProtoMessage()
- func (x *MsgAddToWeightSettingWhitelist) ProtoReflect() protoreflect.Message
- func (x *MsgAddToWeightSettingWhitelist) Reset()
- func (x *MsgAddToWeightSettingWhitelist) String() string
- type MsgAddToWeightSettingWhitelistResponse
- func (*MsgAddToWeightSettingWhitelistResponse) Descriptor() ([]byte, []int)deprecated
- func (*MsgAddToWeightSettingWhitelistResponse) ProtoMessage()
- func (x *MsgAddToWeightSettingWhitelistResponse) ProtoReflect() protoreflect.Message
- func (x *MsgAddToWeightSettingWhitelistResponse) Reset()
- func (x *MsgAddToWeightSettingWhitelistResponse) String() string
- type MsgAddToWhitelistAdmin
- func (*MsgAddToWhitelistAdmin) Descriptor() ([]byte, []int)deprecated
- func (x *MsgAddToWhitelistAdmin) GetAddress() string
- func (x *MsgAddToWhitelistAdmin) GetSender() string
- func (*MsgAddToWhitelistAdmin) ProtoMessage()
- func (x *MsgAddToWhitelistAdmin) ProtoReflect() protoreflect.Message
- func (x *MsgAddToWhitelistAdmin) Reset()
- func (x *MsgAddToWhitelistAdmin) String() string
- type MsgAddToWhitelistAdminResponse
- func (*MsgAddToWhitelistAdminResponse) Descriptor() ([]byte, []int)deprecated
- func (*MsgAddToWhitelistAdminResponse) ProtoMessage()
- func (x *MsgAddToWhitelistAdminResponse) ProtoReflect() protoreflect.Message
- func (x *MsgAddToWhitelistAdminResponse) Reset()
- func (x *MsgAddToWhitelistAdminResponse) String() string
- type MsgClient
- type MsgConfirmRemoveStake
- func (*MsgConfirmRemoveStake) Descriptor() ([]byte, []int)deprecated
- func (x *MsgConfirmRemoveStake) GetSender() string
- func (*MsgConfirmRemoveStake) ProtoMessage()
- func (x *MsgConfirmRemoveStake) ProtoReflect() protoreflect.Message
- func (x *MsgConfirmRemoveStake) Reset()
- func (x *MsgConfirmRemoveStake) String() string
- type MsgConfirmRemoveStakeResponse
- func (*MsgConfirmRemoveStakeResponse) Descriptor() ([]byte, []int)deprecated
- func (*MsgConfirmRemoveStakeResponse) ProtoMessage()
- func (x *MsgConfirmRemoveStakeResponse) ProtoReflect() protoreflect.Message
- func (x *MsgConfirmRemoveStakeResponse) Reset()
- func (x *MsgConfirmRemoveStakeResponse) String() string
- type MsgCreateNewTopic
- func (*MsgCreateNewTopic) Descriptor() ([]byte, []int)deprecated
- func (x *MsgCreateNewTopic) GetCreator() string
- func (x *MsgCreateNewTopic) GetDefaultArg() string
- func (x *MsgCreateNewTopic) GetInferenceCadence() uint64
- func (x *MsgCreateNewTopic) GetInferenceLogic() string
- func (x *MsgCreateNewTopic) GetInferenceMethod() string
- func (x *MsgCreateNewTopic) GetMetadata() string
- func (x *MsgCreateNewTopic) GetWeightCadence() uint64
- func (x *MsgCreateNewTopic) GetWeightLogic() string
- func (x *MsgCreateNewTopic) GetWeightMethod() string
- func (*MsgCreateNewTopic) ProtoMessage()
- func (x *MsgCreateNewTopic) ProtoReflect() protoreflect.Message
- func (x *MsgCreateNewTopic) Reset()
- func (x *MsgCreateNewTopic) String() string
- type MsgCreateNewTopicResponse
- func (*MsgCreateNewTopicResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgCreateNewTopicResponse) GetTopicId() uint64
- func (*MsgCreateNewTopicResponse) ProtoMessage()
- func (x *MsgCreateNewTopicResponse) ProtoReflect() protoreflect.Message
- func (x *MsgCreateNewTopicResponse) Reset()
- func (x *MsgCreateNewTopicResponse) String() string
- type MsgModifyStake
- func (*MsgModifyStake) Descriptor() ([]byte, []int)deprecated
- func (x *MsgModifyStake) GetPlacementsAdd() []*StakePlacement
- func (x *MsgModifyStake) GetPlacementsRemove() []*StakePlacement
- func (x *MsgModifyStake) GetSender() string
- func (*MsgModifyStake) ProtoMessage()
- func (x *MsgModifyStake) ProtoReflect() protoreflect.Message
- func (x *MsgModifyStake) Reset()
- func (x *MsgModifyStake) String() string
- type MsgModifyStakeResponse
- type MsgProcessInferences
- func (*MsgProcessInferences) Descriptor() ([]byte, []int)deprecated
- func (x *MsgProcessInferences) GetInferences() []*Inference
- func (x *MsgProcessInferences) GetSender() string
- func (*MsgProcessInferences) ProtoMessage()
- func (x *MsgProcessInferences) ProtoReflect() protoreflect.Message
- func (x *MsgProcessInferences) Reset()
- func (x *MsgProcessInferences) String() string
- type MsgProcessInferencesResponse
- func (*MsgProcessInferencesResponse) Descriptor() ([]byte, []int)deprecated
- func (*MsgProcessInferencesResponse) ProtoMessage()
- func (x *MsgProcessInferencesResponse) ProtoReflect() protoreflect.Message
- func (x *MsgProcessInferencesResponse) Reset()
- func (x *MsgProcessInferencesResponse) String() string
- type MsgReactivateTopic
- func (*MsgReactivateTopic) Descriptor() ([]byte, []int)deprecated
- func (x *MsgReactivateTopic) GetSender() string
- func (x *MsgReactivateTopic) GetTopicId() uint64
- func (*MsgReactivateTopic) ProtoMessage()
- func (x *MsgReactivateTopic) ProtoReflect() protoreflect.Message
- func (x *MsgReactivateTopic) Reset()
- func (x *MsgReactivateTopic) String() string
- type MsgReactivateTopicResponse
- func (*MsgReactivateTopicResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgReactivateTopicResponse) GetSuccess() bool
- func (*MsgReactivateTopicResponse) ProtoMessage()
- func (x *MsgReactivateTopicResponse) ProtoReflect() protoreflect.Message
- func (x *MsgReactivateTopicResponse) Reset()
- func (x *MsgReactivateTopicResponse) String() string
- type MsgRegister
- func (*MsgRegister) Descriptor() ([]byte, []int)deprecated
- func (x *MsgRegister) GetCreator() string
- func (x *MsgRegister) GetInitialStake() string
- func (x *MsgRegister) GetIsReputer() bool
- func (x *MsgRegister) GetLibP2PKey() string
- func (x *MsgRegister) GetMultiAddress() string
- func (x *MsgRegister) GetOwner() string
- func (x *MsgRegister) GetTopicIds() []uint64
- func (*MsgRegister) ProtoMessage()
- func (x *MsgRegister) ProtoReflect() protoreflect.Message
- func (x *MsgRegister) Reset()
- func (x *MsgRegister) String() string
- type MsgRegisterResponse
- func (*MsgRegisterResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgRegisterResponse) GetMessage() string
- func (x *MsgRegisterResponse) GetSuccess() bool
- func (*MsgRegisterResponse) ProtoMessage()
- func (x *MsgRegisterResponse) ProtoReflect() protoreflect.Message
- func (x *MsgRegisterResponse) Reset()
- func (x *MsgRegisterResponse) String() string
- type MsgRemoveFromTopicCreationWhitelist
- func (*MsgRemoveFromTopicCreationWhitelist) Descriptor() ([]byte, []int)deprecated
- func (x *MsgRemoveFromTopicCreationWhitelist) GetAddress() string
- func (x *MsgRemoveFromTopicCreationWhitelist) GetSender() string
- func (*MsgRemoveFromTopicCreationWhitelist) ProtoMessage()
- func (x *MsgRemoveFromTopicCreationWhitelist) ProtoReflect() protoreflect.Message
- func (x *MsgRemoveFromTopicCreationWhitelist) Reset()
- func (x *MsgRemoveFromTopicCreationWhitelist) String() string
- type MsgRemoveFromTopicCreationWhitelistResponse
- func (*MsgRemoveFromTopicCreationWhitelistResponse) Descriptor() ([]byte, []int)deprecated
- func (*MsgRemoveFromTopicCreationWhitelistResponse) ProtoMessage()
- func (x *MsgRemoveFromTopicCreationWhitelistResponse) ProtoReflect() protoreflect.Message
- func (x *MsgRemoveFromTopicCreationWhitelistResponse) Reset()
- func (x *MsgRemoveFromTopicCreationWhitelistResponse) String() string
- type MsgRemoveFromWeightSettingWhitelist
- func (*MsgRemoveFromWeightSettingWhitelist) Descriptor() ([]byte, []int)deprecated
- func (x *MsgRemoveFromWeightSettingWhitelist) GetAddress() string
- func (x *MsgRemoveFromWeightSettingWhitelist) GetSender() string
- func (*MsgRemoveFromWeightSettingWhitelist) ProtoMessage()
- func (x *MsgRemoveFromWeightSettingWhitelist) ProtoReflect() protoreflect.Message
- func (x *MsgRemoveFromWeightSettingWhitelist) Reset()
- func (x *MsgRemoveFromWeightSettingWhitelist) String() string
- type MsgRemoveFromWeightSettingWhitelistResponse
- func (*MsgRemoveFromWeightSettingWhitelistResponse) Descriptor() ([]byte, []int)deprecated
- func (*MsgRemoveFromWeightSettingWhitelistResponse) ProtoMessage()
- func (x *MsgRemoveFromWeightSettingWhitelistResponse) ProtoReflect() protoreflect.Message
- func (x *MsgRemoveFromWeightSettingWhitelistResponse) Reset()
- func (x *MsgRemoveFromWeightSettingWhitelistResponse) String() string
- type MsgRemoveFromWhitelistAdmin
- func (*MsgRemoveFromWhitelistAdmin) Descriptor() ([]byte, []int)deprecated
- func (x *MsgRemoveFromWhitelistAdmin) GetAddress() string
- func (x *MsgRemoveFromWhitelistAdmin) GetSender() string
- func (*MsgRemoveFromWhitelistAdmin) ProtoMessage()
- func (x *MsgRemoveFromWhitelistAdmin) ProtoReflect() protoreflect.Message
- func (x *MsgRemoveFromWhitelistAdmin) Reset()
- func (x *MsgRemoveFromWhitelistAdmin) String() string
- type MsgRemoveFromWhitelistAdminResponse
- func (*MsgRemoveFromWhitelistAdminResponse) Descriptor() ([]byte, []int)deprecated
- func (*MsgRemoveFromWhitelistAdminResponse) ProtoMessage()
- func (x *MsgRemoveFromWhitelistAdminResponse) ProtoReflect() protoreflect.Message
- func (x *MsgRemoveFromWhitelistAdminResponse) Reset()
- func (x *MsgRemoveFromWhitelistAdminResponse) String() string
- type MsgRemoveRegistration
- func (*MsgRemoveRegistration) Descriptor() ([]byte, []int)deprecated
- func (x *MsgRemoveRegistration) GetCreator() string
- func (x *MsgRemoveRegistration) GetIsReputer() bool
- func (x *MsgRemoveRegistration) GetTopicId() uint64
- func (*MsgRemoveRegistration) ProtoMessage()
- func (x *MsgRemoveRegistration) ProtoReflect() protoreflect.Message
- func (x *MsgRemoveRegistration) Reset()
- func (x *MsgRemoveRegistration) String() string
- type MsgRemoveRegistrationResponse
- func (*MsgRemoveRegistrationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgRemoveRegistrationResponse) GetMessage() string
- func (x *MsgRemoveRegistrationResponse) GetSuccess() bool
- func (*MsgRemoveRegistrationResponse) ProtoMessage()
- func (x *MsgRemoveRegistrationResponse) ProtoReflect() protoreflect.Message
- func (x *MsgRemoveRegistrationResponse) Reset()
- func (x *MsgRemoveRegistrationResponse) String() string
- type MsgRequestInference
- func (*MsgRequestInference) Descriptor() ([]byte, []int)deprecated
- func (x *MsgRequestInference) GetRequests() []*RequestInferenceListItem
- func (x *MsgRequestInference) GetSender() string
- func (*MsgRequestInference) ProtoMessage()
- func (x *MsgRequestInference) ProtoReflect() protoreflect.Message
- func (x *MsgRequestInference) Reset()
- func (x *MsgRequestInference) String() string
- type MsgRequestInferenceResponse
- type MsgServer
- type MsgSetWeights
- func (*MsgSetWeights) Descriptor() ([]byte, []int)deprecated
- func (x *MsgSetWeights) GetSender() string
- func (x *MsgSetWeights) GetWeights() []*Weight
- func (*MsgSetWeights) ProtoMessage()
- func (x *MsgSetWeights) ProtoReflect() protoreflect.Message
- func (x *MsgSetWeights) Reset()
- func (x *MsgSetWeights) String() string
- type MsgSetWeightsResponse
- type MsgStartRemoveAllStake
- func (*MsgStartRemoveAllStake) Descriptor() ([]byte, []int)deprecated
- func (x *MsgStartRemoveAllStake) GetSender() string
- func (*MsgStartRemoveAllStake) ProtoMessage()
- func (x *MsgStartRemoveAllStake) ProtoReflect() protoreflect.Message
- func (x *MsgStartRemoveAllStake) Reset()
- func (x *MsgStartRemoveAllStake) String() string
- type MsgStartRemoveAllStakeResponse
- func (*MsgStartRemoveAllStakeResponse) Descriptor() ([]byte, []int)deprecated
- func (*MsgStartRemoveAllStakeResponse) ProtoMessage()
- func (x *MsgStartRemoveAllStakeResponse) ProtoReflect() protoreflect.Message
- func (x *MsgStartRemoveAllStakeResponse) Reset()
- func (x *MsgStartRemoveAllStakeResponse) String() string
- type MsgStartRemoveStake
- func (*MsgStartRemoveStake) Descriptor() ([]byte, []int)deprecated
- func (x *MsgStartRemoveStake) GetPlacementsRemove() []*StakePlacement
- func (x *MsgStartRemoveStake) GetSender() string
- func (*MsgStartRemoveStake) ProtoMessage()
- func (x *MsgStartRemoveStake) ProtoReflect() protoreflect.Message
- func (x *MsgStartRemoveStake) Reset()
- func (x *MsgStartRemoveStake) String() string
- type MsgStartRemoveStakeResponse
- type MsgUpdateParams
- func (*MsgUpdateParams) Descriptor() ([]byte, []int)deprecated
- func (x *MsgUpdateParams) GetParams() *OptionalParams
- func (x *MsgUpdateParams) GetSender() string
- func (*MsgUpdateParams) ProtoMessage()
- func (x *MsgUpdateParams) ProtoReflect() protoreflect.Message
- func (x *MsgUpdateParams) Reset()
- func (x *MsgUpdateParams) String() string
- type MsgUpdateParamsResponse
- type OffchainNode
- func (*OffchainNode) Descriptor() ([]byte, []int)deprecated
- func (x *OffchainNode) GetLibP2PKey() string
- func (x *OffchainNode) GetMultiAddress() string
- func (x *OffchainNode) GetNodeAddress() string
- func (x *OffchainNode) GetNodeId() string
- func (x *OffchainNode) GetOwner() string
- func (*OffchainNode) ProtoMessage()
- func (x *OffchainNode) ProtoReflect() protoreflect.Message
- func (x *OffchainNode) Reset()
- func (x *OffchainNode) String() string
- type OffchainNodes
- type OptionalParams
- func (*OptionalParams) Descriptor() ([]byte, []int)deprecated
- func (x *OptionalParams) GetEpochLength() []int64
- func (x *OptionalParams) GetMaxInferenceRequestValidity() []uint64
- func (x *OptionalParams) GetMaxMissingInferencePercent() []string
- func (x *OptionalParams) GetMaxRequestCadence() []uint64
- func (x *OptionalParams) GetMaxTopicsPerBlock() []uint64
- func (x *OptionalParams) GetMinRequestCadence() []uint64
- func (x *OptionalParams) GetMinRequestUnmetDemand() []string
- func (x *OptionalParams) GetMinTopicUnmetDemand() []string
- func (x *OptionalParams) GetMinWeightCadence() []uint64
- func (x *OptionalParams) GetPercentRewardsReputersWorkers() []string
- func (x *OptionalParams) GetRemoveStakeDelayWindow() []uint64
- func (x *OptionalParams) GetRequiredMinimumStake() []string
- func (x *OptionalParams) GetVersion() []string
- func (*OptionalParams) ProtoMessage()
- func (x *OptionalParams) ProtoReflect() protoreflect.Message
- func (x *OptionalParams) Reset()
- func (x *OptionalParams) String() string
- type Params
- func (*Params) Descriptor() ([]byte, []int)deprecated
- func (x *Params) GetEpochLength() int64
- func (x *Params) GetMaxInferenceRequestValidity() uint64
- func (x *Params) GetMaxMissingInferencePercent() string
- func (x *Params) GetMaxRequestCadence() uint64
- func (x *Params) GetMaxTopicsPerBlock() uint64
- func (x *Params) GetMinRequestCadence() uint64
- func (x *Params) GetMinRequestUnmetDemand() string
- func (x *Params) GetMinTopicUnmetDemand() string
- func (x *Params) GetMinWeightCadence() uint64
- func (x *Params) GetPercentRewardsReputersWorkers() string
- func (x *Params) GetRemoveStakeDelayWindow() uint64
- func (x *Params) GetRequiredMinimumStake() string
- func (x *Params) GetVersion() string
- func (*Params) ProtoMessage()
- func (x *Params) ProtoReflect() protoreflect.Message
- func (x *Params) Reset()
- func (x *Params) String() string
- type QueryAccountStakeListRequest
- func (*QueryAccountStakeListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAccountStakeListRequest) GetAddress() string
- func (*QueryAccountStakeListRequest) ProtoMessage()
- func (x *QueryAccountStakeListRequest) ProtoReflect() protoreflect.Message
- func (x *QueryAccountStakeListRequest) Reset()
- func (x *QueryAccountStakeListRequest) String() string
- type QueryAccountStakeListResponse
- func (*QueryAccountStakeListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAccountStakeListResponse) GetStakes() []*StakeInfo
- func (*QueryAccountStakeListResponse) ProtoMessage()
- func (x *QueryAccountStakeListResponse) ProtoReflect() protoreflect.Message
- func (x *QueryAccountStakeListResponse) Reset()
- func (x *QueryAccountStakeListResponse) String() string
- type QueryActiveTopicsRequest
- type QueryActiveTopicsResponse
- func (*QueryActiveTopicsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryActiveTopicsResponse) GetTopics() []*Topic
- func (*QueryActiveTopicsResponse) ProtoMessage()
- func (x *QueryActiveTopicsResponse) ProtoReflect() protoreflect.Message
- func (x *QueryActiveTopicsResponse) Reset()
- func (x *QueryActiveTopicsResponse) String() string
- type QueryAllExistingInferenceRequest
- func (*QueryAllExistingInferenceRequest) Descriptor() ([]byte, []int)deprecated
- func (*QueryAllExistingInferenceRequest) ProtoMessage()
- func (x *QueryAllExistingInferenceRequest) ProtoReflect() protoreflect.Message
- func (x *QueryAllExistingInferenceRequest) Reset()
- func (x *QueryAllExistingInferenceRequest) String() string
- type QueryAllExistingInferenceResponse
- func (*QueryAllExistingInferenceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAllExistingInferenceResponse) GetInferenceRequests() []*InferenceRequestAndDemandLeft
- func (*QueryAllExistingInferenceResponse) ProtoMessage()
- func (x *QueryAllExistingInferenceResponse) ProtoReflect() protoreflect.Message
- func (x *QueryAllExistingInferenceResponse) Reset()
- func (x *QueryAllExistingInferenceResponse) String() string
- type QueryAllInferencesRequest
- func (*QueryAllInferencesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAllInferencesRequest) GetTimestamp() uint64
- func (x *QueryAllInferencesRequest) GetTopicId() uint64
- func (*QueryAllInferencesRequest) ProtoMessage()
- func (x *QueryAllInferencesRequest) ProtoReflect() protoreflect.Message
- func (x *QueryAllInferencesRequest) Reset()
- func (x *QueryAllInferencesRequest) String() string
- type QueryAllInferencesResponse
- func (*QueryAllInferencesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAllInferencesResponse) GetInferences() *Inferences
- func (*QueryAllInferencesResponse) ProtoMessage()
- func (x *QueryAllInferencesResponse) ProtoReflect() protoreflect.Message
- func (x *QueryAllInferencesResponse) Reset()
- func (x *QueryAllInferencesResponse) String() string
- type QueryAllTopicsRequest
- type QueryAllTopicsResponse
- func (*QueryAllTopicsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAllTopicsResponse) GetTopics() []*Topic
- func (*QueryAllTopicsResponse) ProtoMessage()
- func (x *QueryAllTopicsResponse) ProtoReflect() protoreflect.Message
- func (x *QueryAllTopicsResponse) Reset()
- func (x *QueryAllTopicsResponse) String() string
- type QueryClient
- type QueryExistingInferenceRequest
- func (*QueryExistingInferenceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryExistingInferenceRequest) GetRequestId() string
- func (x *QueryExistingInferenceRequest) GetTopicId() uint64
- func (*QueryExistingInferenceRequest) ProtoMessage()
- func (x *QueryExistingInferenceRequest) ProtoReflect() protoreflect.Message
- func (x *QueryExistingInferenceRequest) Reset()
- func (x *QueryExistingInferenceRequest) String() string
- type QueryExistingInferenceResponse
- func (*QueryExistingInferenceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryExistingInferenceResponse) GetDemandLeft() string
- func (x *QueryExistingInferenceResponse) GetInferenceRequest() *InferenceRequest
- func (*QueryExistingInferenceResponse) ProtoMessage()
- func (x *QueryExistingInferenceResponse) ProtoReflect() protoreflect.Message
- func (x *QueryExistingInferenceResponse) Reset()
- func (x *QueryExistingInferenceResponse) String() string
- type QueryGetTopicsByCreatorRequest
- func (*QueryGetTopicsByCreatorRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryGetTopicsByCreatorRequest) GetCreator() string
- func (*QueryGetTopicsByCreatorRequest) ProtoMessage()
- func (x *QueryGetTopicsByCreatorRequest) ProtoReflect() protoreflect.Message
- func (x *QueryGetTopicsByCreatorRequest) Reset()
- func (x *QueryGetTopicsByCreatorRequest) String() string
- type QueryGetTopicsByCreatorResponse
- func (*QueryGetTopicsByCreatorResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryGetTopicsByCreatorResponse) GetTopics() []*Topic
- func (*QueryGetTopicsByCreatorResponse) ProtoMessage()
- func (x *QueryGetTopicsByCreatorResponse) ProtoReflect() protoreflect.Message
- func (x *QueryGetTopicsByCreatorResponse) Reset()
- func (x *QueryGetTopicsByCreatorResponse) String() string
- type QueryInferencesToScoreRequest
- func (*QueryInferencesToScoreRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryInferencesToScoreRequest) GetTopicId() uint64
- func (*QueryInferencesToScoreRequest) ProtoMessage()
- func (x *QueryInferencesToScoreRequest) ProtoReflect() protoreflect.Message
- func (x *QueryInferencesToScoreRequest) Reset()
- func (x *QueryInferencesToScoreRequest) String() string
- type QueryInferencesToScoreResponse
- func (*QueryInferencesToScoreResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryInferencesToScoreResponse) GetInferences() []*InferenceSetForScoring
- func (*QueryInferencesToScoreResponse) ProtoMessage()
- func (x *QueryInferencesToScoreResponse) ProtoReflect() protoreflect.Message
- func (x *QueryInferencesToScoreResponse) Reset()
- func (x *QueryInferencesToScoreResponse) String() string
- type QueryLastRewardsUpdateRequest
- func (*QueryLastRewardsUpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (*QueryLastRewardsUpdateRequest) ProtoMessage()
- func (x *QueryLastRewardsUpdateRequest) ProtoReflect() protoreflect.Message
- func (x *QueryLastRewardsUpdateRequest) Reset()
- func (x *QueryLastRewardsUpdateRequest) String() string
- type QueryLastRewardsUpdateResponse
- func (*QueryLastRewardsUpdateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryLastRewardsUpdateResponse) GetLastRewardsUpdate() int64
- func (*QueryLastRewardsUpdateResponse) ProtoMessage()
- func (x *QueryLastRewardsUpdateResponse) ProtoReflect() protoreflect.Message
- func (x *QueryLastRewardsUpdateResponse) Reset()
- func (x *QueryLastRewardsUpdateResponse) String() string
- type QueryNextTopicIdRequest
- type QueryNextTopicIdResponse
- func (*QueryNextTopicIdResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryNextTopicIdResponse) GetNextTopicId() uint64
- func (*QueryNextTopicIdResponse) ProtoMessage()
- func (x *QueryNextTopicIdResponse) ProtoReflect() protoreflect.Message
- func (x *QueryNextTopicIdResponse) Reset()
- func (x *QueryNextTopicIdResponse) String() string
- type QueryParamsRequest
- type QueryParamsResponse
- func (*QueryParamsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryParamsResponse) GetParams() *Params
- func (*QueryParamsResponse) ProtoMessage()
- func (x *QueryParamsResponse) ProtoReflect() protoreflect.Message
- func (x *QueryParamsResponse) Reset()
- func (x *QueryParamsResponse) String() string
- type QueryRegisteredTopicIdsRequest
- func (*QueryRegisteredTopicIdsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRegisteredTopicIdsRequest) GetAddress() string
- func (x *QueryRegisteredTopicIdsRequest) GetIsReputer() bool
- func (*QueryRegisteredTopicIdsRequest) ProtoMessage()
- func (x *QueryRegisteredTopicIdsRequest) ProtoReflect() protoreflect.Message
- func (x *QueryRegisteredTopicIdsRequest) Reset()
- func (x *QueryRegisteredTopicIdsRequest) String() string
- type QueryRegisteredTopicIdsResponse
- func (*QueryRegisteredTopicIdsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRegisteredTopicIdsResponse) GetTopicIds() []uint64
- func (*QueryRegisteredTopicIdsResponse) ProtoMessage()
- func (x *QueryRegisteredTopicIdsResponse) ProtoReflect() protoreflect.Message
- func (x *QueryRegisteredTopicIdsResponse) Reset()
- func (x *QueryRegisteredTopicIdsResponse) String() string
- type QueryRegisteredWorkerNodesRequest
- func (*QueryRegisteredWorkerNodesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRegisteredWorkerNodesRequest) GetNodeId() string
- func (*QueryRegisteredWorkerNodesRequest) ProtoMessage()
- func (x *QueryRegisteredWorkerNodesRequest) ProtoReflect() protoreflect.Message
- func (x *QueryRegisteredWorkerNodesRequest) Reset()
- func (x *QueryRegisteredWorkerNodesRequest) String() string
- type QueryRegisteredWorkerNodesResponse
- func (*QueryRegisteredWorkerNodesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryRegisteredWorkerNodesResponse) GetNodes() []*OffchainNode
- func (*QueryRegisteredWorkerNodesResponse) ProtoMessage()
- func (x *QueryRegisteredWorkerNodesResponse) ProtoReflect() protoreflect.Message
- func (x *QueryRegisteredWorkerNodesResponse) Reset()
- func (x *QueryRegisteredWorkerNodesResponse) String() string
- type QueryServer
- type QueryTopicRequest
- type QueryTopicResponse
- func (*QueryTopicResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryTopicResponse) GetTopic() *Topic
- func (*QueryTopicResponse) ProtoMessage()
- func (x *QueryTopicResponse) ProtoReflect() protoreflect.Message
- func (x *QueryTopicResponse) Reset()
- func (x *QueryTopicResponse) String() string
- type QueryTopicUnmetDemandRequest
- func (*QueryTopicUnmetDemandRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryTopicUnmetDemandRequest) GetTopicId() uint64
- func (*QueryTopicUnmetDemandRequest) ProtoMessage()
- func (x *QueryTopicUnmetDemandRequest) ProtoReflect() protoreflect.Message
- func (x *QueryTopicUnmetDemandRequest) Reset()
- func (x *QueryTopicUnmetDemandRequest) String() string
- type QueryTopicUnmetDemandResponse
- func (*QueryTopicUnmetDemandResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryTopicUnmetDemandResponse) GetDemandLeft() string
- func (*QueryTopicUnmetDemandResponse) ProtoMessage()
- func (x *QueryTopicUnmetDemandResponse) ProtoReflect() protoreflect.Message
- func (x *QueryTopicUnmetDemandResponse) Reset()
- func (x *QueryTopicUnmetDemandResponse) String() string
- type QueryTotalStakeRequest
- type QueryTotalStakeResponse
- func (*QueryTotalStakeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryTotalStakeResponse) GetAmount() string
- func (*QueryTotalStakeResponse) ProtoMessage()
- func (x *QueryTotalStakeResponse) ProtoReflect() protoreflect.Message
- func (x *QueryTotalStakeResponse) Reset()
- func (x *QueryTotalStakeResponse) String() string
- type QueryWeightRequest
- func (*QueryWeightRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryWeightRequest) GetReputer() string
- func (x *QueryWeightRequest) GetTopicId() uint64
- func (x *QueryWeightRequest) GetWorker() string
- func (*QueryWeightRequest) ProtoMessage()
- func (x *QueryWeightRequest) ProtoReflect() protoreflect.Message
- func (x *QueryWeightRequest) Reset()
- func (x *QueryWeightRequest) String() string
- type QueryWeightResponse
- func (*QueryWeightResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryWeightResponse) GetAmount() string
- func (*QueryWeightResponse) ProtoMessage()
- func (x *QueryWeightResponse) ProtoReflect() protoreflect.Message
- func (x *QueryWeightResponse) Reset()
- func (x *QueryWeightResponse) String() string
- type QueryWorkerAddressByP2PKeyRequest
- func (*QueryWorkerAddressByP2PKeyRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryWorkerAddressByP2PKeyRequest) GetLibp2PKey() string
- func (*QueryWorkerAddressByP2PKeyRequest) ProtoMessage()
- func (x *QueryWorkerAddressByP2PKeyRequest) ProtoReflect() protoreflect.Message
- func (x *QueryWorkerAddressByP2PKeyRequest) Reset()
- func (x *QueryWorkerAddressByP2PKeyRequest) String() string
- type QueryWorkerAddressByP2PKeyResponse
- func (*QueryWorkerAddressByP2PKeyResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryWorkerAddressByP2PKeyResponse) GetAddress() string
- func (*QueryWorkerAddressByP2PKeyResponse) ProtoMessage()
- func (x *QueryWorkerAddressByP2PKeyResponse) ProtoReflect() protoreflect.Message
- func (x *QueryWorkerAddressByP2PKeyResponse) Reset()
- func (x *QueryWorkerAddressByP2PKeyResponse) String() string
- type QueryWorkerLatestInferenceRequest
- func (*QueryWorkerLatestInferenceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryWorkerLatestInferenceRequest) GetTopicId() uint64
- func (x *QueryWorkerLatestInferenceRequest) GetWorkerAddress() string
- func (*QueryWorkerLatestInferenceRequest) ProtoMessage()
- func (x *QueryWorkerLatestInferenceRequest) ProtoReflect() protoreflect.Message
- func (x *QueryWorkerLatestInferenceRequest) Reset()
- func (x *QueryWorkerLatestInferenceRequest) String() string
- type QueryWorkerLatestInferenceResponse
- func (*QueryWorkerLatestInferenceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryWorkerLatestInferenceResponse) GetLatestInference() *Inference
- func (*QueryWorkerLatestInferenceResponse) ProtoMessage()
- func (x *QueryWorkerLatestInferenceResponse) ProtoReflect() protoreflect.Message
- func (x *QueryWorkerLatestInferenceResponse) Reset()
- func (x *QueryWorkerLatestInferenceResponse) String() string
- type RequestInferenceListItem
- func (*RequestInferenceListItem) Descriptor() ([]byte, []int)deprecated
- func (x *RequestInferenceListItem) GetBidAmount() string
- func (x *RequestInferenceListItem) GetCadence() uint64
- func (x *RequestInferenceListItem) GetExtraData() []byte
- func (x *RequestInferenceListItem) GetMaxPricePerInference() string
- func (x *RequestInferenceListItem) GetNonce() uint64
- func (x *RequestInferenceListItem) GetTimestampValidUntil() uint64
- func (x *RequestInferenceListItem) GetTopicId() uint64
- func (*RequestInferenceListItem) ProtoMessage()
- func (x *RequestInferenceListItem) ProtoReflect() protoreflect.Message
- func (x *RequestInferenceListItem) Reset()
- func (x *RequestInferenceListItem) String() string
- type StakeInfo
- type StakePlacement
- func (*StakePlacement) Descriptor() ([]byte, []int)deprecated
- func (x *StakePlacement) GetAmount() string
- func (x *StakePlacement) GetTarget() string
- func (*StakePlacement) ProtoMessage()
- func (x *StakePlacement) ProtoReflect() protoreflect.Message
- func (x *StakePlacement) Reset()
- func (x *StakePlacement) String() string
- type StakeRemoval
- func (*StakeRemoval) Descriptor() ([]byte, []int)deprecated
- func (x *StakeRemoval) GetPlacements() []*StakeRemovalPlacement
- func (x *StakeRemoval) GetTimestampRemovalStarted() uint64
- func (*StakeRemoval) ProtoMessage()
- func (x *StakeRemoval) ProtoReflect() protoreflect.Message
- func (x *StakeRemoval) Reset()
- func (x *StakeRemoval) String() string
- type StakeRemovalPlacement
- func (*StakeRemovalPlacement) Descriptor() ([]byte, []int)deprecated
- func (x *StakeRemovalPlacement) GetAmount() string
- func (x *StakeRemovalPlacement) GetTarget() string
- func (x *StakeRemovalPlacement) GetTopicIds() []uint64
- func (*StakeRemovalPlacement) ProtoMessage()
- func (x *StakeRemovalPlacement) ProtoReflect() protoreflect.Message
- func (x *StakeRemovalPlacement) Reset()
- func (x *StakeRemovalPlacement) String() string
- type Topic
- func (*Topic) Descriptor() ([]byte, []int)deprecated
- func (x *Topic) GetActive() bool
- func (x *Topic) GetCreator() string
- func (x *Topic) GetDefaultArg() string
- func (x *Topic) GetId() uint64
- func (x *Topic) GetInferenceCadence() uint64
- func (x *Topic) GetInferenceLastRan() uint64
- func (x *Topic) GetInferenceLogic() string
- func (x *Topic) GetInferenceMethod() string
- func (x *Topic) GetMetadata() string
- func (x *Topic) GetWeightCadence() uint64
- func (x *Topic) GetWeightLastRan() uint64
- func (x *Topic) GetWeightLogic() string
- func (x *Topic) GetWeightMethod() string
- func (*Topic) ProtoMessage()
- func (x *Topic) ProtoReflect() protoreflect.Message
- func (x *Topic) Reset()
- func (x *Topic) String() string
- type TopicList
- type UnimplementedMsgServer
- func (UnimplementedMsgServer) AddNewRegistration(context.Context, *MsgAddNewRegistration) (*MsgAddNewRegistrationResponse, error)
- func (UnimplementedMsgServer) AddStake(context.Context, *MsgAddStake) (*MsgAddStakeResponse, error)
- func (UnimplementedMsgServer) AddToTopicCreationWhitelist(context.Context, *MsgAddToTopicCreationWhitelist) (*MsgAddToTopicCreationWhitelistResponse, error)
- func (UnimplementedMsgServer) AddToWeightSettingWhitelist(context.Context, *MsgAddToWeightSettingWhitelist) (*MsgAddToWeightSettingWhitelistResponse, error)
- func (UnimplementedMsgServer) AddToWhitelistAdmin(context.Context, *MsgAddToWhitelistAdmin) (*MsgAddToWhitelistAdminResponse, error)
- func (UnimplementedMsgServer) ConfirmRemoveStake(context.Context, *MsgConfirmRemoveStake) (*MsgConfirmRemoveStakeResponse, error)
- func (UnimplementedMsgServer) CreateNewTopic(context.Context, *MsgCreateNewTopic) (*MsgCreateNewTopicResponse, error)
- func (UnimplementedMsgServer) ModifyStake(context.Context, *MsgModifyStake) (*MsgModifyStakeResponse, error)
- func (UnimplementedMsgServer) ProcessInferences(context.Context, *MsgProcessInferences) (*MsgProcessInferencesResponse, error)
- func (UnimplementedMsgServer) ReactivateTopic(context.Context, *MsgReactivateTopic) (*MsgReactivateTopicResponse, error)
- func (UnimplementedMsgServer) Register(context.Context, *MsgRegister) (*MsgRegisterResponse, error)
- func (UnimplementedMsgServer) RemoveFromTopicCreationWhitelist(context.Context, *MsgRemoveFromTopicCreationWhitelist) (*MsgRemoveFromTopicCreationWhitelistResponse, error)
- func (UnimplementedMsgServer) RemoveFromWeightSettingWhitelist(context.Context, *MsgRemoveFromWeightSettingWhitelist) (*MsgRemoveFromWeightSettingWhitelistResponse, error)
- func (UnimplementedMsgServer) RemoveFromWhitelistAdmin(context.Context, *MsgRemoveFromWhitelistAdmin) (*MsgRemoveFromWhitelistAdminResponse, error)
- func (UnimplementedMsgServer) RemoveRegistration(context.Context, *MsgRemoveRegistration) (*MsgRemoveRegistrationResponse, error)
- func (UnimplementedMsgServer) RequestInference(context.Context, *MsgRequestInference) (*MsgRequestInferenceResponse, error)
- func (UnimplementedMsgServer) SetWeights(context.Context, *MsgSetWeights) (*MsgSetWeightsResponse, error)
- func (UnimplementedMsgServer) StartRemoveAllStake(context.Context, *MsgStartRemoveAllStake) (*MsgStartRemoveAllStakeResponse, error)
- func (UnimplementedMsgServer) StartRemoveStake(context.Context, *MsgStartRemoveStake) (*MsgStartRemoveStakeResponse, error)
- func (UnimplementedMsgServer) UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
- type UnimplementedQueryServer
- func (UnimplementedQueryServer) GetAccountStakeList(context.Context, *QueryAccountStakeListRequest) (*QueryAccountStakeListResponse, error)
- func (UnimplementedQueryServer) GetActiveTopics(context.Context, *QueryActiveTopicsRequest) (*QueryActiveTopicsResponse, error)
- func (UnimplementedQueryServer) GetAllExistingInferenceRequests(context.Context, *QueryAllExistingInferenceRequest) (*QueryAllExistingInferenceResponse, error)
- func (UnimplementedQueryServer) GetAllInferences(context.Context, *QueryAllInferencesRequest) (*QueryAllInferencesResponse, error)
- func (UnimplementedQueryServer) GetAllTopics(context.Context, *QueryAllTopicsRequest) (*QueryAllTopicsResponse, error)
- func (UnimplementedQueryServer) GetExistingInferenceRequest(context.Context, *QueryExistingInferenceRequest) (*QueryExistingInferenceResponse, error)
- func (UnimplementedQueryServer) GetInferencesToScore(context.Context, *QueryInferencesToScoreRequest) (*QueryInferencesToScoreResponse, error)
- func (UnimplementedQueryServer) GetLastRewardsUpdate(context.Context, *QueryLastRewardsUpdateRequest) (*QueryLastRewardsUpdateResponse, error)
- func (UnimplementedQueryServer) GetNextTopicId(context.Context, *QueryNextTopicIdRequest) (*QueryNextTopicIdResponse, error)
- func (UnimplementedQueryServer) GetRegisteredTopicIds(context.Context, *QueryRegisteredTopicIdsRequest) (*QueryRegisteredTopicIdsResponse, error)
- func (UnimplementedQueryServer) GetTopic(context.Context, *QueryTopicRequest) (*QueryTopicResponse, error)
- func (UnimplementedQueryServer) GetTopicUnmetDemand(context.Context, *QueryTopicUnmetDemandRequest) (*QueryTopicUnmetDemandResponse, error)
- func (UnimplementedQueryServer) GetTopicsByCreator(context.Context, *QueryGetTopicsByCreatorRequest) (*QueryGetTopicsByCreatorResponse, error)
- func (UnimplementedQueryServer) GetTotalStake(context.Context, *QueryTotalStakeRequest) (*QueryTotalStakeResponse, error)
- func (UnimplementedQueryServer) GetWeight(context.Context, *QueryWeightRequest) (*QueryWeightResponse, error)
- func (UnimplementedQueryServer) GetWorkerAddressByP2PKey(context.Context, *QueryWorkerAddressByP2PKeyRequest) (*QueryWorkerAddressByP2PKeyResponse, error)
- func (UnimplementedQueryServer) GetWorkerLatestInferenceByTopicId(context.Context, *QueryWorkerLatestInferenceRequest) (*QueryWorkerLatestInferenceResponse, error)
- func (UnimplementedQueryServer) GetWorkerNodeRegistration(context.Context, *QueryRegisteredWorkerNodesRequest) (*QueryRegisteredWorkerNodesResponse, error)
- func (UnimplementedQueryServer) Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
- type UnsafeMsgServer
- type UnsafeQueryServer
- type Weight
- func (*Weight) Descriptor() ([]byte, []int)deprecated
- func (x *Weight) GetReputer() string
- func (x *Weight) GetTopicId() uint64
- func (x *Weight) GetWeight() string
- func (x *Weight) GetWorker() string
- func (*Weight) ProtoMessage()
- func (x *Weight) ProtoReflect() protoreflect.Message
- func (x *Weight) Reset()
- func (x *Weight) String() string
- type Weights
Constants ¶
const ( Query_Params_FullMethodName = "/emissions.state.v1.Query/Params" Query_GetLastRewardsUpdate_FullMethodName = "/emissions.state.v1.Query/GetLastRewardsUpdate" Query_GetNextTopicId_FullMethodName = "/emissions.state.v1.Query/GetNextTopicId" Query_GetTopic_FullMethodName = "/emissions.state.v1.Query/GetTopic" Query_GetActiveTopics_FullMethodName = "/emissions.state.v1.Query/GetActiveTopics" Query_GetAllTopics_FullMethodName = "/emissions.state.v1.Query/GetAllTopics" Query_GetTopicsByCreator_FullMethodName = "/emissions.state.v1.Query/GetTopicsByCreator" Query_GetWeight_FullMethodName = "/emissions.state.v1.Query/GetWeight" Query_GetExistingInferenceRequest_FullMethodName = "/emissions.state.v1.Query/GetExistingInferenceRequest" Query_GetAllExistingInferenceRequests_FullMethodName = "/emissions.state.v1.Query/GetAllExistingInferenceRequests" Query_GetTopicUnmetDemand_FullMethodName = "/emissions.state.v1.Query/GetTopicUnmetDemand" Query_GetWorkerLatestInferenceByTopicId_FullMethodName = "/emissions.state.v1.Query/GetWorkerLatestInferenceByTopicId" Query_GetAllInferences_FullMethodName = "/emissions.state.v1.Query/GetAllInferences" Query_GetInferencesToScore_FullMethodName = "/emissions.state.v1.Query/GetInferencesToScore" Query_GetTotalStake_FullMethodName = "/emissions.state.v1.Query/GetTotalStake" Query_GetAccountStakeList_FullMethodName = "/emissions.state.v1.Query/GetAccountStakeList" Query_GetWorkerNodeRegistration_FullMethodName = "/emissions.state.v1.Query/GetWorkerNodeRegistration" Query_GetWorkerAddressByP2PKey_FullMethodName = "/emissions.state.v1.Query/GetWorkerAddressByP2PKey" Query_GetRegisteredTopicIds_FullMethodName = "/emissions.state.v1.Query/GetRegisteredTopicIds" )
const ( Msg_UpdateParams_FullMethodName = "/emissions.state.v1.Msg/UpdateParams" Msg_ProcessInferences_FullMethodName = "/emissions.state.v1.Msg/ProcessInferences" Msg_SetWeights_FullMethodName = "/emissions.state.v1.Msg/SetWeights" Msg_CreateNewTopic_FullMethodName = "/emissions.state.v1.Msg/CreateNewTopic" Msg_ReactivateTopic_FullMethodName = "/emissions.state.v1.Msg/ReactivateTopic" Msg_Register_FullMethodName = "/emissions.state.v1.Msg/Register" Msg_AddNewRegistration_FullMethodName = "/emissions.state.v1.Msg/AddNewRegistration" Msg_RemoveRegistration_FullMethodName = "/emissions.state.v1.Msg/RemoveRegistration" Msg_AddStake_FullMethodName = "/emissions.state.v1.Msg/AddStake" Msg_ModifyStake_FullMethodName = "/emissions.state.v1.Msg/ModifyStake" Msg_StartRemoveStake_FullMethodName = "/emissions.state.v1.Msg/StartRemoveStake" Msg_ConfirmRemoveStake_FullMethodName = "/emissions.state.v1.Msg/ConfirmRemoveStake" Msg_StartRemoveAllStake_FullMethodName = "/emissions.state.v1.Msg/StartRemoveAllStake" Msg_RequestInference_FullMethodName = "/emissions.state.v1.Msg/RequestInference" Msg_AddToWhitelistAdmin_FullMethodName = "/emissions.state.v1.Msg/AddToWhitelistAdmin" Msg_RemoveFromWhitelistAdmin_FullMethodName = "/emissions.state.v1.Msg/RemoveFromWhitelistAdmin" Msg_AddToTopicCreationWhitelist_FullMethodName = "/emissions.state.v1.Msg/AddToTopicCreationWhitelist" Msg_RemoveFromTopicCreationWhitelist_FullMethodName = "/emissions.state.v1.Msg/RemoveFromTopicCreationWhitelist" Msg_AddToWeightSettingWhitelist_FullMethodName = "/emissions.state.v1.Msg/AddToWeightSettingWhitelist" Msg_RemoveFromWeightSettingWhitelist_FullMethodName = "/emissions.state.v1.Msg/RemoveFromWeightSettingWhitelist" )
Variables ¶
var File_emissions_state_v1_query_proto protoreflect.FileDescriptor
var File_emissions_state_v1_tx_proto protoreflect.FileDescriptor
var File_emissions_state_v1_types_proto protoreflect.FileDescriptor
var Msg_ServiceDesc = grpc.ServiceDesc{ ServiceName: "emissions.state.v1.Msg", HandlerType: (*MsgServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "UpdateParams", Handler: _Msg_UpdateParams_Handler, }, { MethodName: "ProcessInferences", Handler: _Msg_ProcessInferences_Handler, }, { MethodName: "SetWeights", Handler: _Msg_SetWeights_Handler, }, { MethodName: "CreateNewTopic", Handler: _Msg_CreateNewTopic_Handler, }, { MethodName: "ReactivateTopic", Handler: _Msg_ReactivateTopic_Handler, }, { MethodName: "Register", Handler: _Msg_Register_Handler, }, { MethodName: "AddNewRegistration", Handler: _Msg_AddNewRegistration_Handler, }, { MethodName: "RemoveRegistration", Handler: _Msg_RemoveRegistration_Handler, }, { MethodName: "AddStake", Handler: _Msg_AddStake_Handler, }, { MethodName: "ModifyStake", Handler: _Msg_ModifyStake_Handler, }, { MethodName: "StartRemoveStake", Handler: _Msg_StartRemoveStake_Handler, }, { MethodName: "ConfirmRemoveStake", Handler: _Msg_ConfirmRemoveStake_Handler, }, { MethodName: "StartRemoveAllStake", Handler: _Msg_StartRemoveAllStake_Handler, }, { MethodName: "RequestInference", Handler: _Msg_RequestInference_Handler, }, { MethodName: "AddToWhitelistAdmin", Handler: _Msg_AddToWhitelistAdmin_Handler, }, { MethodName: "RemoveFromWhitelistAdmin", Handler: _Msg_RemoveFromWhitelistAdmin_Handler, }, { MethodName: "AddToTopicCreationWhitelist", Handler: _Msg_AddToTopicCreationWhitelist_Handler, }, { MethodName: "RemoveFromTopicCreationWhitelist", Handler: _Msg_RemoveFromTopicCreationWhitelist_Handler, }, { MethodName: "AddToWeightSettingWhitelist", Handler: _Msg_AddToWeightSettingWhitelist_Handler, }, { MethodName: "RemoveFromWeightSettingWhitelist", Handler: _Msg_RemoveFromWeightSettingWhitelist_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "emissions/state/v1/tx.proto", }
Msg_ServiceDesc is the grpc.ServiceDesc for Msg service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Query_ServiceDesc = grpc.ServiceDesc{ ServiceName: "emissions.state.v1.Query", HandlerType: (*QueryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Params", Handler: _Query_Params_Handler, }, { MethodName: "GetLastRewardsUpdate", Handler: _Query_GetLastRewardsUpdate_Handler, }, { MethodName: "GetNextTopicId", Handler: _Query_GetNextTopicId_Handler, }, { MethodName: "GetTopic", Handler: _Query_GetTopic_Handler, }, { MethodName: "GetActiveTopics", Handler: _Query_GetActiveTopics_Handler, }, { MethodName: "GetAllTopics", Handler: _Query_GetAllTopics_Handler, }, { MethodName: "GetTopicsByCreator", Handler: _Query_GetTopicsByCreator_Handler, }, { MethodName: "GetWeight", Handler: _Query_GetWeight_Handler, }, { MethodName: "GetExistingInferenceRequest", Handler: _Query_GetExistingInferenceRequest_Handler, }, { MethodName: "GetAllExistingInferenceRequests", Handler: _Query_GetAllExistingInferenceRequests_Handler, }, { MethodName: "GetTopicUnmetDemand", Handler: _Query_GetTopicUnmetDemand_Handler, }, { MethodName: "GetWorkerLatestInferenceByTopicId", Handler: _Query_GetWorkerLatestInferenceByTopicId_Handler, }, { MethodName: "GetAllInferences", Handler: _Query_GetAllInferences_Handler, }, { MethodName: "GetInferencesToScore", Handler: _Query_GetInferencesToScore_Handler, }, { MethodName: "GetTotalStake", Handler: _Query_GetTotalStake_Handler, }, { MethodName: "GetAccountStakeList", Handler: _Query_GetAccountStakeList_Handler, }, { MethodName: "GetWorkerNodeRegistration", Handler: _Query_GetWorkerNodeRegistration_Handler, }, { MethodName: "GetWorkerAddressByP2PKey", Handler: _Query_GetWorkerAddressByP2PKey_Handler, }, { MethodName: "GetRegisteredTopicIds", Handler: _Query_GetRegisteredTopicIds_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "emissions/state/v1/query.proto", }
Query_ServiceDesc is the grpc.ServiceDesc for Query service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMsgServer ¶
func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
Types ¶
type GenesisState ¶
type GenesisState struct { // params defines all the parameters of the module. Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"` CoreTeamAddresses []string `protobuf:"bytes,2,rep,name=core_team_addresses,json=coreTeamAddresses,proto3" json:"core_team_addresses,omitempty"` // contains filtered or unexported fields }
GenesisState is the state that must be provided at genesis.
func (*GenesisState) Descriptor
deprecated
func (*GenesisState) Descriptor() ([]byte, []int)
Deprecated: Use GenesisState.ProtoReflect.Descriptor instead.
func (*GenesisState) GetCoreTeamAddresses ¶ added in v0.0.4
func (x *GenesisState) GetCoreTeamAddresses() []string
func (*GenesisState) GetParams ¶
func (x *GenesisState) GetParams() *Params
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) ProtoReflect ¶
func (x *GenesisState) ProtoReflect() protoreflect.Message
func (*GenesisState) Reset ¶
func (x *GenesisState) Reset()
func (*GenesisState) String ¶
func (x *GenesisState) String() string
type Inference ¶
type Inference struct { TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` Worker string `protobuf:"bytes,2,opt,name=worker,proto3" json:"worker,omitempty"` Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` ExtraData []byte `protobuf:"bytes,4,opt,name=extra_data,json=extraData,proto3" json:"extra_data,omitempty"` Proof string `protobuf:"bytes,5,opt,name=proof,proto3" json:"proof,omitempty"` // contains filtered or unexported fields }
func (*Inference) Descriptor
deprecated
func (*Inference) GetExtraData ¶
func (*Inference) GetTopicId ¶
func (*Inference) ProtoMessage ¶
func (*Inference) ProtoMessage()
func (*Inference) ProtoReflect ¶
func (x *Inference) ProtoReflect() protoreflect.Message
type InferenceRequest ¶
type InferenceRequest struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Nonce uint64 `protobuf:"varint,2,opt,name=nonce,proto3" json:"nonce,omitempty"` TopicId uint64 `protobuf:"varint,3,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` Cadence uint64 `protobuf:"varint,4,opt,name=cadence,proto3" json:"cadence,omitempty"` // time in seconds between inferences, zero means oneshot inference MaxPricePerInference string `protobuf:"bytes,5,opt,name=max_price_per_inference,json=maxPricePerInference,proto3" json:"max_price_per_inference,omitempty"` // the maximum price per inference that alice is willing to pay BidAmount string `protobuf:"bytes,6,opt,name=bid_amount,json=bidAmount,proto3" json:"bid_amount,omitempty"` // how many funds to send from alice with this Inference Request LastChecked uint64 `protobuf:"varint,7,opt,name=last_checked,json=lastChecked,proto3" json:"last_checked,omitempty"` // the last time the inference was checked and was possibly drawn from TimestampValidUntil uint64 `protobuf:"varint,8,opt,name=timestamp_valid_until,json=timestampValidUntil,proto3" json:"timestamp_valid_until,omitempty"` ExtraData []byte `protobuf:"bytes,9,opt,name=extra_data,json=extraData,proto3" json:"extra_data,omitempty"` // contains filtered or unexported fields }
num_inference_possible = bid_amount / max_price_per_inference, length of time this inference repeats for = num_inference_possible * cadence
func (*InferenceRequest) Descriptor
deprecated
func (*InferenceRequest) Descriptor() ([]byte, []int)
Deprecated: Use InferenceRequest.ProtoReflect.Descriptor instead.
func (*InferenceRequest) GetBidAmount ¶
func (x *InferenceRequest) GetBidAmount() string
func (*InferenceRequest) GetCadence ¶
func (x *InferenceRequest) GetCadence() uint64
func (*InferenceRequest) GetExtraData ¶
func (x *InferenceRequest) GetExtraData() []byte
func (*InferenceRequest) GetLastChecked ¶
func (x *InferenceRequest) GetLastChecked() uint64
func (*InferenceRequest) GetMaxPricePerInference ¶
func (x *InferenceRequest) GetMaxPricePerInference() string
func (*InferenceRequest) GetNonce ¶
func (x *InferenceRequest) GetNonce() uint64
func (*InferenceRequest) GetSender ¶
func (x *InferenceRequest) GetSender() string
func (*InferenceRequest) GetTimestampValidUntil ¶
func (x *InferenceRequest) GetTimestampValidUntil() uint64
func (*InferenceRequest) GetTopicId ¶
func (x *InferenceRequest) GetTopicId() uint64
func (*InferenceRequest) ProtoMessage ¶
func (*InferenceRequest) ProtoMessage()
func (*InferenceRequest) ProtoReflect ¶
func (x *InferenceRequest) ProtoReflect() protoreflect.Message
func (*InferenceRequest) Reset ¶
func (x *InferenceRequest) Reset()
func (*InferenceRequest) String ¶
func (x *InferenceRequest) String() string
type InferenceRequestAndDemandLeft ¶ added in v0.0.4
type InferenceRequestAndDemandLeft struct { InferenceRequest *InferenceRequest `protobuf:"bytes,1,opt,name=inference_request,json=inferenceRequest,proto3" json:"inference_request,omitempty"` DemandLeft string `protobuf:"bytes,2,opt,name=demand_left,json=demandLeft,proto3" json:"demand_left,omitempty"` // contains filtered or unexported fields }
func (*InferenceRequestAndDemandLeft) Descriptor
deprecated
added in
v0.0.4
func (*InferenceRequestAndDemandLeft) Descriptor() ([]byte, []int)
Deprecated: Use InferenceRequestAndDemandLeft.ProtoReflect.Descriptor instead.
func (*InferenceRequestAndDemandLeft) GetDemandLeft ¶ added in v0.0.4
func (x *InferenceRequestAndDemandLeft) GetDemandLeft() string
func (*InferenceRequestAndDemandLeft) GetInferenceRequest ¶ added in v0.0.4
func (x *InferenceRequestAndDemandLeft) GetInferenceRequest() *InferenceRequest
func (*InferenceRequestAndDemandLeft) ProtoMessage ¶ added in v0.0.4
func (*InferenceRequestAndDemandLeft) ProtoMessage()
func (*InferenceRequestAndDemandLeft) ProtoReflect ¶ added in v0.0.4
func (x *InferenceRequestAndDemandLeft) ProtoReflect() protoreflect.Message
func (*InferenceRequestAndDemandLeft) Reset ¶ added in v0.0.4
func (x *InferenceRequestAndDemandLeft) Reset()
func (*InferenceRequestAndDemandLeft) String ¶ added in v0.0.4
func (x *InferenceRequestAndDemandLeft) String() string
type InferenceSetForScoring ¶
type InferenceSetForScoring struct { TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` Inferences *Inferences `protobuf:"bytes,3,opt,name=inferences,proto3" json:"inferences,omitempty"` // contains filtered or unexported fields }
func (*InferenceSetForScoring) Descriptor
deprecated
func (*InferenceSetForScoring) Descriptor() ([]byte, []int)
Deprecated: Use InferenceSetForScoring.ProtoReflect.Descriptor instead.
func (*InferenceSetForScoring) GetInferences ¶
func (x *InferenceSetForScoring) GetInferences() *Inferences
func (*InferenceSetForScoring) GetTimestamp ¶
func (x *InferenceSetForScoring) GetTimestamp() uint64
func (*InferenceSetForScoring) GetTopicId ¶
func (x *InferenceSetForScoring) GetTopicId() uint64
func (*InferenceSetForScoring) ProtoMessage ¶
func (*InferenceSetForScoring) ProtoMessage()
func (*InferenceSetForScoring) ProtoReflect ¶
func (x *InferenceSetForScoring) ProtoReflect() protoreflect.Message
func (*InferenceSetForScoring) Reset ¶
func (x *InferenceSetForScoring) Reset()
func (*InferenceSetForScoring) String ¶
func (x *InferenceSetForScoring) String() string
type Inferences ¶
type Inferences struct { Inferences []*Inference `protobuf:"bytes,1,rep,name=inferences,proto3" json:"inferences,omitempty"` // contains filtered or unexported fields }
func (*Inferences) Descriptor
deprecated
func (*Inferences) Descriptor() ([]byte, []int)
Deprecated: Use Inferences.ProtoReflect.Descriptor instead.
func (*Inferences) GetInferences ¶
func (x *Inferences) GetInferences() []*Inference
func (*Inferences) ProtoMessage ¶
func (*Inferences) ProtoMessage()
func (*Inferences) ProtoReflect ¶
func (x *Inferences) ProtoReflect() protoreflect.Message
func (*Inferences) Reset ¶
func (x *Inferences) Reset()
func (*Inferences) String ¶
func (x *Inferences) String() string
type MsgAddNewRegistration ¶
type MsgAddNewRegistration struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` LibP2PKey string `protobuf:"bytes,2,opt,name=lib_p2p_key,json=libP2pKey,proto3" json:"lib_p2p_key,omitempty"` MultiAddress string `protobuf:"bytes,3,opt,name=multi_address,json=multiAddress,proto3" json:"multi_address,omitempty"` TopicId uint64 `protobuf:"varint,4,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` Owner string `protobuf:"bytes,5,opt,name=owner,proto3" json:"owner,omitempty"` IsReputer bool `protobuf:"varint,6,opt,name=is_reputer,json=isReputer,proto3" json:"is_reputer,omitempty"` // contains filtered or unexported fields }
func (*MsgAddNewRegistration) Descriptor
deprecated
func (*MsgAddNewRegistration) Descriptor() ([]byte, []int)
Deprecated: Use MsgAddNewRegistration.ProtoReflect.Descriptor instead.
func (*MsgAddNewRegistration) GetCreator ¶
func (x *MsgAddNewRegistration) GetCreator() string
func (*MsgAddNewRegistration) GetIsReputer ¶
func (x *MsgAddNewRegistration) GetIsReputer() bool
func (*MsgAddNewRegistration) GetLibP2PKey ¶
func (x *MsgAddNewRegistration) GetLibP2PKey() string
func (*MsgAddNewRegistration) GetMultiAddress ¶
func (x *MsgAddNewRegistration) GetMultiAddress() string
func (*MsgAddNewRegistration) GetOwner ¶
func (x *MsgAddNewRegistration) GetOwner() string
func (*MsgAddNewRegistration) GetTopicId ¶
func (x *MsgAddNewRegistration) GetTopicId() uint64
func (*MsgAddNewRegistration) ProtoMessage ¶
func (*MsgAddNewRegistration) ProtoMessage()
func (*MsgAddNewRegistration) ProtoReflect ¶
func (x *MsgAddNewRegistration) ProtoReflect() protoreflect.Message
func (*MsgAddNewRegistration) Reset ¶
func (x *MsgAddNewRegistration) Reset()
func (*MsgAddNewRegistration) String ¶
func (x *MsgAddNewRegistration) String() string
type MsgAddNewRegistrationResponse ¶
type MsgAddNewRegistrationResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*MsgAddNewRegistrationResponse) Descriptor
deprecated
func (*MsgAddNewRegistrationResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgAddNewRegistrationResponse.ProtoReflect.Descriptor instead.
func (*MsgAddNewRegistrationResponse) GetMessage ¶
func (x *MsgAddNewRegistrationResponse) GetMessage() string
func (*MsgAddNewRegistrationResponse) GetSuccess ¶
func (x *MsgAddNewRegistrationResponse) GetSuccess() bool
func (*MsgAddNewRegistrationResponse) ProtoMessage ¶
func (*MsgAddNewRegistrationResponse) ProtoMessage()
func (*MsgAddNewRegistrationResponse) ProtoReflect ¶
func (x *MsgAddNewRegistrationResponse) ProtoReflect() protoreflect.Message
func (*MsgAddNewRegistrationResponse) Reset ¶
func (x *MsgAddNewRegistrationResponse) Reset()
func (*MsgAddNewRegistrationResponse) String ¶
func (x *MsgAddNewRegistrationResponse) String() string
type MsgAddStake ¶
type MsgAddStake struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty"` StakeTarget string `protobuf:"bytes,3,opt,name=stake_target,json=stakeTarget,proto3" json:"stake_target,omitempty"` // contains filtered or unexported fields }
/ / Staking /
func (*MsgAddStake) Descriptor
deprecated
func (*MsgAddStake) Descriptor() ([]byte, []int)
Deprecated: Use MsgAddStake.ProtoReflect.Descriptor instead.
func (*MsgAddStake) GetAmount ¶
func (x *MsgAddStake) GetAmount() string
func (*MsgAddStake) GetSender ¶
func (x *MsgAddStake) GetSender() string
func (*MsgAddStake) GetStakeTarget ¶
func (x *MsgAddStake) GetStakeTarget() string
func (*MsgAddStake) ProtoMessage ¶
func (*MsgAddStake) ProtoMessage()
func (*MsgAddStake) ProtoReflect ¶
func (x *MsgAddStake) ProtoReflect() protoreflect.Message
func (*MsgAddStake) Reset ¶
func (x *MsgAddStake) Reset()
func (*MsgAddStake) String ¶
func (x *MsgAddStake) String() string
type MsgAddStakeResponse ¶
type MsgAddStakeResponse struct {
// contains filtered or unexported fields
}
func (*MsgAddStakeResponse) Descriptor
deprecated
func (*MsgAddStakeResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgAddStakeResponse.ProtoReflect.Descriptor instead.
func (*MsgAddStakeResponse) ProtoMessage ¶
func (*MsgAddStakeResponse) ProtoMessage()
func (*MsgAddStakeResponse) ProtoReflect ¶
func (x *MsgAddStakeResponse) ProtoReflect() protoreflect.Message
func (*MsgAddStakeResponse) Reset ¶
func (x *MsgAddStakeResponse) Reset()
func (*MsgAddStakeResponse) String ¶
func (x *MsgAddStakeResponse) String() string
type MsgAddToTopicCreationWhitelist ¶ added in v0.0.1
type MsgAddToTopicCreationWhitelist struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*MsgAddToTopicCreationWhitelist) Descriptor
deprecated
added in
v0.0.1
func (*MsgAddToTopicCreationWhitelist) Descriptor() ([]byte, []int)
Deprecated: Use MsgAddToTopicCreationWhitelist.ProtoReflect.Descriptor instead.
func (*MsgAddToTopicCreationWhitelist) GetAddress ¶ added in v0.0.1
func (x *MsgAddToTopicCreationWhitelist) GetAddress() string
func (*MsgAddToTopicCreationWhitelist) GetSender ¶ added in v0.0.1
func (x *MsgAddToTopicCreationWhitelist) GetSender() string
func (*MsgAddToTopicCreationWhitelist) ProtoMessage ¶ added in v0.0.1
func (*MsgAddToTopicCreationWhitelist) ProtoMessage()
func (*MsgAddToTopicCreationWhitelist) ProtoReflect ¶ added in v0.0.1
func (x *MsgAddToTopicCreationWhitelist) ProtoReflect() protoreflect.Message
func (*MsgAddToTopicCreationWhitelist) Reset ¶ added in v0.0.1
func (x *MsgAddToTopicCreationWhitelist) Reset()
func (*MsgAddToTopicCreationWhitelist) String ¶ added in v0.0.1
func (x *MsgAddToTopicCreationWhitelist) String() string
type MsgAddToTopicCreationWhitelistResponse ¶ added in v0.0.1
type MsgAddToTopicCreationWhitelistResponse struct {
// contains filtered or unexported fields
}
func (*MsgAddToTopicCreationWhitelistResponse) Descriptor
deprecated
added in
v0.0.1
func (*MsgAddToTopicCreationWhitelistResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgAddToTopicCreationWhitelistResponse.ProtoReflect.Descriptor instead.
func (*MsgAddToTopicCreationWhitelistResponse) ProtoMessage ¶ added in v0.0.1
func (*MsgAddToTopicCreationWhitelistResponse) ProtoMessage()
func (*MsgAddToTopicCreationWhitelistResponse) ProtoReflect ¶ added in v0.0.1
func (x *MsgAddToTopicCreationWhitelistResponse) ProtoReflect() protoreflect.Message
func (*MsgAddToTopicCreationWhitelistResponse) Reset ¶ added in v0.0.1
func (x *MsgAddToTopicCreationWhitelistResponse) Reset()
func (*MsgAddToTopicCreationWhitelistResponse) String ¶ added in v0.0.1
func (x *MsgAddToTopicCreationWhitelistResponse) String() string
type MsgAddToWeightSettingWhitelist ¶ added in v0.0.1
type MsgAddToWeightSettingWhitelist struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*MsgAddToWeightSettingWhitelist) Descriptor
deprecated
added in
v0.0.1
func (*MsgAddToWeightSettingWhitelist) Descriptor() ([]byte, []int)
Deprecated: Use MsgAddToWeightSettingWhitelist.ProtoReflect.Descriptor instead.
func (*MsgAddToWeightSettingWhitelist) GetAddress ¶ added in v0.0.1
func (x *MsgAddToWeightSettingWhitelist) GetAddress() string
func (*MsgAddToWeightSettingWhitelist) GetSender ¶ added in v0.0.1
func (x *MsgAddToWeightSettingWhitelist) GetSender() string
func (*MsgAddToWeightSettingWhitelist) ProtoMessage ¶ added in v0.0.1
func (*MsgAddToWeightSettingWhitelist) ProtoMessage()
func (*MsgAddToWeightSettingWhitelist) ProtoReflect ¶ added in v0.0.1
func (x *MsgAddToWeightSettingWhitelist) ProtoReflect() protoreflect.Message
func (*MsgAddToWeightSettingWhitelist) Reset ¶ added in v0.0.1
func (x *MsgAddToWeightSettingWhitelist) Reset()
func (*MsgAddToWeightSettingWhitelist) String ¶ added in v0.0.1
func (x *MsgAddToWeightSettingWhitelist) String() string
type MsgAddToWeightSettingWhitelistResponse ¶ added in v0.0.1
type MsgAddToWeightSettingWhitelistResponse struct {
// contains filtered or unexported fields
}
func (*MsgAddToWeightSettingWhitelistResponse) Descriptor
deprecated
added in
v0.0.1
func (*MsgAddToWeightSettingWhitelistResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgAddToWeightSettingWhitelistResponse.ProtoReflect.Descriptor instead.
func (*MsgAddToWeightSettingWhitelistResponse) ProtoMessage ¶ added in v0.0.1
func (*MsgAddToWeightSettingWhitelistResponse) ProtoMessage()
func (*MsgAddToWeightSettingWhitelistResponse) ProtoReflect ¶ added in v0.0.1
func (x *MsgAddToWeightSettingWhitelistResponse) ProtoReflect() protoreflect.Message
func (*MsgAddToWeightSettingWhitelistResponse) Reset ¶ added in v0.0.1
func (x *MsgAddToWeightSettingWhitelistResponse) Reset()
func (*MsgAddToWeightSettingWhitelistResponse) String ¶ added in v0.0.1
func (x *MsgAddToWeightSettingWhitelistResponse) String() string
type MsgAddToWhitelistAdmin ¶ added in v0.0.1
type MsgAddToWhitelistAdmin struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*MsgAddToWhitelistAdmin) Descriptor
deprecated
added in
v0.0.1
func (*MsgAddToWhitelistAdmin) Descriptor() ([]byte, []int)
Deprecated: Use MsgAddToWhitelistAdmin.ProtoReflect.Descriptor instead.
func (*MsgAddToWhitelistAdmin) GetAddress ¶ added in v0.0.1
func (x *MsgAddToWhitelistAdmin) GetAddress() string
func (*MsgAddToWhitelistAdmin) GetSender ¶ added in v0.0.1
func (x *MsgAddToWhitelistAdmin) GetSender() string
func (*MsgAddToWhitelistAdmin) ProtoMessage ¶ added in v0.0.1
func (*MsgAddToWhitelistAdmin) ProtoMessage()
func (*MsgAddToWhitelistAdmin) ProtoReflect ¶ added in v0.0.1
func (x *MsgAddToWhitelistAdmin) ProtoReflect() protoreflect.Message
func (*MsgAddToWhitelistAdmin) Reset ¶ added in v0.0.1
func (x *MsgAddToWhitelistAdmin) Reset()
func (*MsgAddToWhitelistAdmin) String ¶ added in v0.0.1
func (x *MsgAddToWhitelistAdmin) String() string
type MsgAddToWhitelistAdminResponse ¶ added in v0.0.1
type MsgAddToWhitelistAdminResponse struct {
// contains filtered or unexported fields
}
func (*MsgAddToWhitelistAdminResponse) Descriptor
deprecated
added in
v0.0.1
func (*MsgAddToWhitelistAdminResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgAddToWhitelistAdminResponse.ProtoReflect.Descriptor instead.
func (*MsgAddToWhitelistAdminResponse) ProtoMessage ¶ added in v0.0.1
func (*MsgAddToWhitelistAdminResponse) ProtoMessage()
func (*MsgAddToWhitelistAdminResponse) ProtoReflect ¶ added in v0.0.1
func (x *MsgAddToWhitelistAdminResponse) ProtoReflect() protoreflect.Message
func (*MsgAddToWhitelistAdminResponse) Reset ¶ added in v0.0.1
func (x *MsgAddToWhitelistAdminResponse) Reset()
func (*MsgAddToWhitelistAdminResponse) String ¶ added in v0.0.1
func (x *MsgAddToWhitelistAdminResponse) String() string
type MsgClient ¶
type MsgClient interface { UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error) ProcessInferences(ctx context.Context, in *MsgProcessInferences, opts ...grpc.CallOption) (*MsgProcessInferencesResponse, error) SetWeights(ctx context.Context, in *MsgSetWeights, opts ...grpc.CallOption) (*MsgSetWeightsResponse, error) CreateNewTopic(ctx context.Context, in *MsgCreateNewTopic, opts ...grpc.CallOption) (*MsgCreateNewTopicResponse, error) ReactivateTopic(ctx context.Context, in *MsgReactivateTopic, opts ...grpc.CallOption) (*MsgReactivateTopicResponse, error) Register(ctx context.Context, in *MsgRegister, opts ...grpc.CallOption) (*MsgRegisterResponse, error) AddNewRegistration(ctx context.Context, in *MsgAddNewRegistration, opts ...grpc.CallOption) (*MsgAddNewRegistrationResponse, error) RemoveRegistration(ctx context.Context, in *MsgRemoveRegistration, opts ...grpc.CallOption) (*MsgRemoveRegistrationResponse, error) AddStake(ctx context.Context, in *MsgAddStake, opts ...grpc.CallOption) (*MsgAddStakeResponse, error) ModifyStake(ctx context.Context, in *MsgModifyStake, opts ...grpc.CallOption) (*MsgModifyStakeResponse, error) StartRemoveStake(ctx context.Context, in *MsgStartRemoveStake, opts ...grpc.CallOption) (*MsgStartRemoveStakeResponse, error) ConfirmRemoveStake(ctx context.Context, in *MsgConfirmRemoveStake, opts ...grpc.CallOption) (*MsgConfirmRemoveStakeResponse, error) StartRemoveAllStake(ctx context.Context, in *MsgStartRemoveAllStake, opts ...grpc.CallOption) (*MsgStartRemoveAllStakeResponse, error) RequestInference(ctx context.Context, in *MsgRequestInference, opts ...grpc.CallOption) (*MsgRequestInferenceResponse, error) AddToWhitelistAdmin(ctx context.Context, in *MsgAddToWhitelistAdmin, opts ...grpc.CallOption) (*MsgAddToWhitelistAdminResponse, error) RemoveFromWhitelistAdmin(ctx context.Context, in *MsgRemoveFromWhitelistAdmin, opts ...grpc.CallOption) (*MsgRemoveFromWhitelistAdminResponse, error) AddToTopicCreationWhitelist(ctx context.Context, in *MsgAddToTopicCreationWhitelist, opts ...grpc.CallOption) (*MsgAddToTopicCreationWhitelistResponse, error) RemoveFromTopicCreationWhitelist(ctx context.Context, in *MsgRemoveFromTopicCreationWhitelist, opts ...grpc.CallOption) (*MsgRemoveFromTopicCreationWhitelistResponse, error) AddToWeightSettingWhitelist(ctx context.Context, in *MsgAddToWeightSettingWhitelist, opts ...grpc.CallOption) (*MsgAddToWeightSettingWhitelistResponse, error) RemoveFromWeightSettingWhitelist(ctx context.Context, in *MsgRemoveFromWeightSettingWhitelist, opts ...grpc.CallOption) (*MsgRemoveFromWeightSettingWhitelistResponse, error) }
MsgClient is the client API for Msg service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMsgClient ¶
func NewMsgClient(cc grpc.ClientConnInterface) MsgClient
type MsgConfirmRemoveStake ¶
type MsgConfirmRemoveStake struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` // contains filtered or unexported fields }
func (*MsgConfirmRemoveStake) Descriptor
deprecated
func (*MsgConfirmRemoveStake) Descriptor() ([]byte, []int)
Deprecated: Use MsgConfirmRemoveStake.ProtoReflect.Descriptor instead.
func (*MsgConfirmRemoveStake) GetSender ¶
func (x *MsgConfirmRemoveStake) GetSender() string
func (*MsgConfirmRemoveStake) ProtoMessage ¶
func (*MsgConfirmRemoveStake) ProtoMessage()
func (*MsgConfirmRemoveStake) ProtoReflect ¶
func (x *MsgConfirmRemoveStake) ProtoReflect() protoreflect.Message
func (*MsgConfirmRemoveStake) Reset ¶
func (x *MsgConfirmRemoveStake) Reset()
func (*MsgConfirmRemoveStake) String ¶
func (x *MsgConfirmRemoveStake) String() string
type MsgConfirmRemoveStakeResponse ¶
type MsgConfirmRemoveStakeResponse struct {
// contains filtered or unexported fields
}
func (*MsgConfirmRemoveStakeResponse) Descriptor
deprecated
func (*MsgConfirmRemoveStakeResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgConfirmRemoveStakeResponse.ProtoReflect.Descriptor instead.
func (*MsgConfirmRemoveStakeResponse) ProtoMessage ¶
func (*MsgConfirmRemoveStakeResponse) ProtoMessage()
func (*MsgConfirmRemoveStakeResponse) ProtoReflect ¶
func (x *MsgConfirmRemoveStakeResponse) ProtoReflect() protoreflect.Message
func (*MsgConfirmRemoveStakeResponse) Reset ¶
func (x *MsgConfirmRemoveStakeResponse) Reset()
func (*MsgConfirmRemoveStakeResponse) String ¶
func (x *MsgConfirmRemoveStakeResponse) String() string
type MsgCreateNewTopic ¶
type MsgCreateNewTopic struct { // creator is the message sender. Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` Metadata string `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"` WeightLogic string `protobuf:"bytes,3,opt,name=weight_logic,json=weightLogic,proto3" json:"weight_logic,omitempty"` WeightMethod string `protobuf:"bytes,4,opt,name=weight_method,json=weightMethod,proto3" json:"weight_method,omitempty"` WeightCadence uint64 `protobuf:"varint,5,opt,name=weight_cadence,json=weightCadence,proto3" json:"weight_cadence,omitempty"` InferenceLogic string `protobuf:"bytes,6,opt,name=inference_logic,json=inferenceLogic,proto3" json:"inference_logic,omitempty"` InferenceMethod string `protobuf:"bytes,7,opt,name=inference_method,json=inferenceMethod,proto3" json:"inference_method,omitempty"` InferenceCadence uint64 `protobuf:"varint,8,opt,name=inference_cadence,json=inferenceCadence,proto3" json:"inference_cadence,omitempty"` DefaultArg string `protobuf:"bytes,9,opt,name=default_arg,json=defaultArg,proto3" json:"default_arg,omitempty"` // contains filtered or unexported fields }
func (*MsgCreateNewTopic) Descriptor
deprecated
func (*MsgCreateNewTopic) Descriptor() ([]byte, []int)
Deprecated: Use MsgCreateNewTopic.ProtoReflect.Descriptor instead.
func (*MsgCreateNewTopic) GetCreator ¶
func (x *MsgCreateNewTopic) GetCreator() string
func (*MsgCreateNewTopic) GetDefaultArg ¶
func (x *MsgCreateNewTopic) GetDefaultArg() string
func (*MsgCreateNewTopic) GetInferenceCadence ¶
func (x *MsgCreateNewTopic) GetInferenceCadence() uint64
func (*MsgCreateNewTopic) GetInferenceLogic ¶
func (x *MsgCreateNewTopic) GetInferenceLogic() string
func (*MsgCreateNewTopic) GetInferenceMethod ¶
func (x *MsgCreateNewTopic) GetInferenceMethod() string
func (*MsgCreateNewTopic) GetMetadata ¶
func (x *MsgCreateNewTopic) GetMetadata() string
func (*MsgCreateNewTopic) GetWeightCadence ¶
func (x *MsgCreateNewTopic) GetWeightCadence() uint64
func (*MsgCreateNewTopic) GetWeightLogic ¶
func (x *MsgCreateNewTopic) GetWeightLogic() string
func (*MsgCreateNewTopic) GetWeightMethod ¶
func (x *MsgCreateNewTopic) GetWeightMethod() string
func (*MsgCreateNewTopic) ProtoMessage ¶
func (*MsgCreateNewTopic) ProtoMessage()
func (*MsgCreateNewTopic) ProtoReflect ¶
func (x *MsgCreateNewTopic) ProtoReflect() protoreflect.Message
func (*MsgCreateNewTopic) Reset ¶
func (x *MsgCreateNewTopic) Reset()
func (*MsgCreateNewTopic) String ¶
func (x *MsgCreateNewTopic) String() string
type MsgCreateNewTopicResponse ¶
type MsgCreateNewTopicResponse struct { TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` // contains filtered or unexported fields }
func (*MsgCreateNewTopicResponse) Descriptor
deprecated
func (*MsgCreateNewTopicResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgCreateNewTopicResponse.ProtoReflect.Descriptor instead.
func (*MsgCreateNewTopicResponse) GetTopicId ¶
func (x *MsgCreateNewTopicResponse) GetTopicId() uint64
func (*MsgCreateNewTopicResponse) ProtoMessage ¶
func (*MsgCreateNewTopicResponse) ProtoMessage()
func (*MsgCreateNewTopicResponse) ProtoReflect ¶
func (x *MsgCreateNewTopicResponse) ProtoReflect() protoreflect.Message
func (*MsgCreateNewTopicResponse) Reset ¶
func (x *MsgCreateNewTopicResponse) Reset()
func (*MsgCreateNewTopicResponse) String ¶
func (x *MsgCreateNewTopicResponse) String() string
type MsgModifyStake ¶
type MsgModifyStake struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` PlacementsRemove []*StakePlacement `protobuf:"bytes,2,rep,name=placements_remove,json=placementsRemove,proto3" json:"placements_remove,omitempty"` PlacementsAdd []*StakePlacement `protobuf:"bytes,3,rep,name=placements_add,json=placementsAdd,proto3" json:"placements_add,omitempty"` // contains filtered or unexported fields }
func (*MsgModifyStake) Descriptor
deprecated
func (*MsgModifyStake) Descriptor() ([]byte, []int)
Deprecated: Use MsgModifyStake.ProtoReflect.Descriptor instead.
func (*MsgModifyStake) GetPlacementsAdd ¶
func (x *MsgModifyStake) GetPlacementsAdd() []*StakePlacement
func (*MsgModifyStake) GetPlacementsRemove ¶
func (x *MsgModifyStake) GetPlacementsRemove() []*StakePlacement
func (*MsgModifyStake) GetSender ¶
func (x *MsgModifyStake) GetSender() string
func (*MsgModifyStake) ProtoMessage ¶
func (*MsgModifyStake) ProtoMessage()
func (*MsgModifyStake) ProtoReflect ¶
func (x *MsgModifyStake) ProtoReflect() protoreflect.Message
func (*MsgModifyStake) Reset ¶
func (x *MsgModifyStake) Reset()
func (*MsgModifyStake) String ¶
func (x *MsgModifyStake) String() string
type MsgModifyStakeResponse ¶
type MsgModifyStakeResponse struct {
// contains filtered or unexported fields
}
func (*MsgModifyStakeResponse) Descriptor
deprecated
func (*MsgModifyStakeResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgModifyStakeResponse.ProtoReflect.Descriptor instead.
func (*MsgModifyStakeResponse) ProtoMessage ¶
func (*MsgModifyStakeResponse) ProtoMessage()
func (*MsgModifyStakeResponse) ProtoReflect ¶
func (x *MsgModifyStakeResponse) ProtoReflect() protoreflect.Message
func (*MsgModifyStakeResponse) Reset ¶
func (x *MsgModifyStakeResponse) Reset()
func (*MsgModifyStakeResponse) String ¶
func (x *MsgModifyStakeResponse) String() string
type MsgProcessInferences ¶
type MsgProcessInferences struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Inferences []*Inference `protobuf:"bytes,2,rep,name=inferences,proto3" json:"inferences,omitempty"` // contains filtered or unexported fields }
func (*MsgProcessInferences) Descriptor
deprecated
func (*MsgProcessInferences) Descriptor() ([]byte, []int)
Deprecated: Use MsgProcessInferences.ProtoReflect.Descriptor instead.
func (*MsgProcessInferences) GetInferences ¶
func (x *MsgProcessInferences) GetInferences() []*Inference
func (*MsgProcessInferences) GetSender ¶
func (x *MsgProcessInferences) GetSender() string
func (*MsgProcessInferences) ProtoMessage ¶
func (*MsgProcessInferences) ProtoMessage()
func (*MsgProcessInferences) ProtoReflect ¶
func (x *MsgProcessInferences) ProtoReflect() protoreflect.Message
func (*MsgProcessInferences) Reset ¶
func (x *MsgProcessInferences) Reset()
func (*MsgProcessInferences) String ¶
func (x *MsgProcessInferences) String() string
type MsgProcessInferencesResponse ¶
type MsgProcessInferencesResponse struct {
// contains filtered or unexported fields
}
func (*MsgProcessInferencesResponse) Descriptor
deprecated
func (*MsgProcessInferencesResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgProcessInferencesResponse.ProtoReflect.Descriptor instead.
func (*MsgProcessInferencesResponse) ProtoMessage ¶
func (*MsgProcessInferencesResponse) ProtoMessage()
func (*MsgProcessInferencesResponse) ProtoReflect ¶
func (x *MsgProcessInferencesResponse) ProtoReflect() protoreflect.Message
func (*MsgProcessInferencesResponse) Reset ¶
func (x *MsgProcessInferencesResponse) Reset()
func (*MsgProcessInferencesResponse) String ¶
func (x *MsgProcessInferencesResponse) String() string
type MsgReactivateTopic ¶ added in v0.0.1
type MsgReactivateTopic struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` TopicId uint64 `protobuf:"varint,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` // contains filtered or unexported fields }
func (*MsgReactivateTopic) Descriptor
deprecated
added in
v0.0.1
func (*MsgReactivateTopic) Descriptor() ([]byte, []int)
Deprecated: Use MsgReactivateTopic.ProtoReflect.Descriptor instead.
func (*MsgReactivateTopic) GetSender ¶ added in v0.0.1
func (x *MsgReactivateTopic) GetSender() string
func (*MsgReactivateTopic) GetTopicId ¶ added in v0.0.1
func (x *MsgReactivateTopic) GetTopicId() uint64
func (*MsgReactivateTopic) ProtoMessage ¶ added in v0.0.1
func (*MsgReactivateTopic) ProtoMessage()
func (*MsgReactivateTopic) ProtoReflect ¶ added in v0.0.1
func (x *MsgReactivateTopic) ProtoReflect() protoreflect.Message
func (*MsgReactivateTopic) Reset ¶ added in v0.0.1
func (x *MsgReactivateTopic) Reset()
func (*MsgReactivateTopic) String ¶ added in v0.0.1
func (x *MsgReactivateTopic) String() string
type MsgReactivateTopicResponse ¶ added in v0.0.1
type MsgReactivateTopicResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` // contains filtered or unexported fields }
func (*MsgReactivateTopicResponse) Descriptor
deprecated
added in
v0.0.1
func (*MsgReactivateTopicResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgReactivateTopicResponse.ProtoReflect.Descriptor instead.
func (*MsgReactivateTopicResponse) GetSuccess ¶ added in v0.0.1
func (x *MsgReactivateTopicResponse) GetSuccess() bool
func (*MsgReactivateTopicResponse) ProtoMessage ¶ added in v0.0.1
func (*MsgReactivateTopicResponse) ProtoMessage()
func (*MsgReactivateTopicResponse) ProtoReflect ¶ added in v0.0.1
func (x *MsgReactivateTopicResponse) ProtoReflect() protoreflect.Message
func (*MsgReactivateTopicResponse) Reset ¶ added in v0.0.1
func (x *MsgReactivateTopicResponse) Reset()
func (*MsgReactivateTopicResponse) String ¶ added in v0.0.1
func (x *MsgReactivateTopicResponse) String() string
type MsgRegister ¶
type MsgRegister struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` LibP2PKey string `protobuf:"bytes,2,opt,name=lib_p2p_key,json=libP2pKey,proto3" json:"lib_p2p_key,omitempty"` MultiAddress string `protobuf:"bytes,3,opt,name=multi_address,json=multiAddress,proto3" json:"multi_address,omitempty"` TopicIds []uint64 `protobuf:"varint,4,rep,packed,name=topic_ids,json=topicIds,proto3" json:"topic_ids,omitempty"` InitialStake string `protobuf:"bytes,5,opt,name=initial_stake,json=initialStake,proto3" json:"initial_stake,omitempty"` Owner string `protobuf:"bytes,6,opt,name=owner,proto3" json:"owner,omitempty"` IsReputer bool `protobuf:"varint,7,opt,name=is_reputer,json=isReputer,proto3" json:"is_reputer,omitempty"` // contains filtered or unexported fields }
/ / Inference Node Registration /
func (*MsgRegister) Descriptor
deprecated
func (*MsgRegister) Descriptor() ([]byte, []int)
Deprecated: Use MsgRegister.ProtoReflect.Descriptor instead.
func (*MsgRegister) GetCreator ¶
func (x *MsgRegister) GetCreator() string
func (*MsgRegister) GetInitialStake ¶
func (x *MsgRegister) GetInitialStake() string
func (*MsgRegister) GetIsReputer ¶
func (x *MsgRegister) GetIsReputer() bool
func (*MsgRegister) GetLibP2PKey ¶
func (x *MsgRegister) GetLibP2PKey() string
func (*MsgRegister) GetMultiAddress ¶
func (x *MsgRegister) GetMultiAddress() string
func (*MsgRegister) GetOwner ¶
func (x *MsgRegister) GetOwner() string
func (*MsgRegister) GetTopicIds ¶ added in v0.0.4
func (x *MsgRegister) GetTopicIds() []uint64
func (*MsgRegister) ProtoMessage ¶
func (*MsgRegister) ProtoMessage()
func (*MsgRegister) ProtoReflect ¶
func (x *MsgRegister) ProtoReflect() protoreflect.Message
func (*MsgRegister) Reset ¶
func (x *MsgRegister) Reset()
func (*MsgRegister) String ¶
func (x *MsgRegister) String() string
type MsgRegisterResponse ¶
type MsgRegisterResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*MsgRegisterResponse) Descriptor
deprecated
func (*MsgRegisterResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgRegisterResponse.ProtoReflect.Descriptor instead.
func (*MsgRegisterResponse) GetMessage ¶
func (x *MsgRegisterResponse) GetMessage() string
func (*MsgRegisterResponse) GetSuccess ¶
func (x *MsgRegisterResponse) GetSuccess() bool
func (*MsgRegisterResponse) ProtoMessage ¶
func (*MsgRegisterResponse) ProtoMessage()
func (*MsgRegisterResponse) ProtoReflect ¶
func (x *MsgRegisterResponse) ProtoReflect() protoreflect.Message
func (*MsgRegisterResponse) Reset ¶
func (x *MsgRegisterResponse) Reset()
func (*MsgRegisterResponse) String ¶
func (x *MsgRegisterResponse) String() string
type MsgRemoveFromTopicCreationWhitelist ¶ added in v0.0.1
type MsgRemoveFromTopicCreationWhitelist struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*MsgRemoveFromTopicCreationWhitelist) Descriptor
deprecated
added in
v0.0.1
func (*MsgRemoveFromTopicCreationWhitelist) Descriptor() ([]byte, []int)
Deprecated: Use MsgRemoveFromTopicCreationWhitelist.ProtoReflect.Descriptor instead.
func (*MsgRemoveFromTopicCreationWhitelist) GetAddress ¶ added in v0.0.1
func (x *MsgRemoveFromTopicCreationWhitelist) GetAddress() string
func (*MsgRemoveFromTopicCreationWhitelist) GetSender ¶ added in v0.0.1
func (x *MsgRemoveFromTopicCreationWhitelist) GetSender() string
func (*MsgRemoveFromTopicCreationWhitelist) ProtoMessage ¶ added in v0.0.1
func (*MsgRemoveFromTopicCreationWhitelist) ProtoMessage()
func (*MsgRemoveFromTopicCreationWhitelist) ProtoReflect ¶ added in v0.0.1
func (x *MsgRemoveFromTopicCreationWhitelist) ProtoReflect() protoreflect.Message
func (*MsgRemoveFromTopicCreationWhitelist) Reset ¶ added in v0.0.1
func (x *MsgRemoveFromTopicCreationWhitelist) Reset()
func (*MsgRemoveFromTopicCreationWhitelist) String ¶ added in v0.0.1
func (x *MsgRemoveFromTopicCreationWhitelist) String() string
type MsgRemoveFromTopicCreationWhitelistResponse ¶ added in v0.0.1
type MsgRemoveFromTopicCreationWhitelistResponse struct {
// contains filtered or unexported fields
}
func (*MsgRemoveFromTopicCreationWhitelistResponse) Descriptor
deprecated
added in
v0.0.1
func (*MsgRemoveFromTopicCreationWhitelistResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgRemoveFromTopicCreationWhitelistResponse.ProtoReflect.Descriptor instead.
func (*MsgRemoveFromTopicCreationWhitelistResponse) ProtoMessage ¶ added in v0.0.1
func (*MsgRemoveFromTopicCreationWhitelistResponse) ProtoMessage()
func (*MsgRemoveFromTopicCreationWhitelistResponse) ProtoReflect ¶ added in v0.0.1
func (x *MsgRemoveFromTopicCreationWhitelistResponse) ProtoReflect() protoreflect.Message
func (*MsgRemoveFromTopicCreationWhitelistResponse) Reset ¶ added in v0.0.1
func (x *MsgRemoveFromTopicCreationWhitelistResponse) Reset()
func (*MsgRemoveFromTopicCreationWhitelistResponse) String ¶ added in v0.0.1
func (x *MsgRemoveFromTopicCreationWhitelistResponse) String() string
type MsgRemoveFromWeightSettingWhitelist ¶ added in v0.0.1
type MsgRemoveFromWeightSettingWhitelist struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*MsgRemoveFromWeightSettingWhitelist) Descriptor
deprecated
added in
v0.0.1
func (*MsgRemoveFromWeightSettingWhitelist) Descriptor() ([]byte, []int)
Deprecated: Use MsgRemoveFromWeightSettingWhitelist.ProtoReflect.Descriptor instead.
func (*MsgRemoveFromWeightSettingWhitelist) GetAddress ¶ added in v0.0.1
func (x *MsgRemoveFromWeightSettingWhitelist) GetAddress() string
func (*MsgRemoveFromWeightSettingWhitelist) GetSender ¶ added in v0.0.1
func (x *MsgRemoveFromWeightSettingWhitelist) GetSender() string
func (*MsgRemoveFromWeightSettingWhitelist) ProtoMessage ¶ added in v0.0.1
func (*MsgRemoveFromWeightSettingWhitelist) ProtoMessage()
func (*MsgRemoveFromWeightSettingWhitelist) ProtoReflect ¶ added in v0.0.1
func (x *MsgRemoveFromWeightSettingWhitelist) ProtoReflect() protoreflect.Message
func (*MsgRemoveFromWeightSettingWhitelist) Reset ¶ added in v0.0.1
func (x *MsgRemoveFromWeightSettingWhitelist) Reset()
func (*MsgRemoveFromWeightSettingWhitelist) String ¶ added in v0.0.1
func (x *MsgRemoveFromWeightSettingWhitelist) String() string
type MsgRemoveFromWeightSettingWhitelistResponse ¶ added in v0.0.1
type MsgRemoveFromWeightSettingWhitelistResponse struct {
// contains filtered or unexported fields
}
func (*MsgRemoveFromWeightSettingWhitelistResponse) Descriptor
deprecated
added in
v0.0.1
func (*MsgRemoveFromWeightSettingWhitelistResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgRemoveFromWeightSettingWhitelistResponse.ProtoReflect.Descriptor instead.
func (*MsgRemoveFromWeightSettingWhitelistResponse) ProtoMessage ¶ added in v0.0.1
func (*MsgRemoveFromWeightSettingWhitelistResponse) ProtoMessage()
func (*MsgRemoveFromWeightSettingWhitelistResponse) ProtoReflect ¶ added in v0.0.1
func (x *MsgRemoveFromWeightSettingWhitelistResponse) ProtoReflect() protoreflect.Message
func (*MsgRemoveFromWeightSettingWhitelistResponse) Reset ¶ added in v0.0.1
func (x *MsgRemoveFromWeightSettingWhitelistResponse) Reset()
func (*MsgRemoveFromWeightSettingWhitelistResponse) String ¶ added in v0.0.1
func (x *MsgRemoveFromWeightSettingWhitelistResponse) String() string
type MsgRemoveFromWhitelistAdmin ¶ added in v0.0.1
type MsgRemoveFromWhitelistAdmin struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*MsgRemoveFromWhitelistAdmin) Descriptor
deprecated
added in
v0.0.1
func (*MsgRemoveFromWhitelistAdmin) Descriptor() ([]byte, []int)
Deprecated: Use MsgRemoveFromWhitelistAdmin.ProtoReflect.Descriptor instead.
func (*MsgRemoveFromWhitelistAdmin) GetAddress ¶ added in v0.0.1
func (x *MsgRemoveFromWhitelistAdmin) GetAddress() string
func (*MsgRemoveFromWhitelistAdmin) GetSender ¶ added in v0.0.1
func (x *MsgRemoveFromWhitelistAdmin) GetSender() string
func (*MsgRemoveFromWhitelistAdmin) ProtoMessage ¶ added in v0.0.1
func (*MsgRemoveFromWhitelistAdmin) ProtoMessage()
func (*MsgRemoveFromWhitelistAdmin) ProtoReflect ¶ added in v0.0.1
func (x *MsgRemoveFromWhitelistAdmin) ProtoReflect() protoreflect.Message
func (*MsgRemoveFromWhitelistAdmin) Reset ¶ added in v0.0.1
func (x *MsgRemoveFromWhitelistAdmin) Reset()
func (*MsgRemoveFromWhitelistAdmin) String ¶ added in v0.0.1
func (x *MsgRemoveFromWhitelistAdmin) String() string
type MsgRemoveFromWhitelistAdminResponse ¶ added in v0.0.1
type MsgRemoveFromWhitelistAdminResponse struct {
// contains filtered or unexported fields
}
func (*MsgRemoveFromWhitelistAdminResponse) Descriptor
deprecated
added in
v0.0.1
func (*MsgRemoveFromWhitelistAdminResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgRemoveFromWhitelistAdminResponse.ProtoReflect.Descriptor instead.
func (*MsgRemoveFromWhitelistAdminResponse) ProtoMessage ¶ added in v0.0.1
func (*MsgRemoveFromWhitelistAdminResponse) ProtoMessage()
func (*MsgRemoveFromWhitelistAdminResponse) ProtoReflect ¶ added in v0.0.1
func (x *MsgRemoveFromWhitelistAdminResponse) ProtoReflect() protoreflect.Message
func (*MsgRemoveFromWhitelistAdminResponse) Reset ¶ added in v0.0.1
func (x *MsgRemoveFromWhitelistAdminResponse) Reset()
func (*MsgRemoveFromWhitelistAdminResponse) String ¶ added in v0.0.1
func (x *MsgRemoveFromWhitelistAdminResponse) String() string
type MsgRemoveRegistration ¶
type MsgRemoveRegistration struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` TopicId uint64 `protobuf:"varint,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` IsReputer bool `protobuf:"varint,3,opt,name=is_reputer,json=isReputer,proto3" json:"is_reputer,omitempty"` // contains filtered or unexported fields }
func (*MsgRemoveRegistration) Descriptor
deprecated
func (*MsgRemoveRegistration) Descriptor() ([]byte, []int)
Deprecated: Use MsgRemoveRegistration.ProtoReflect.Descriptor instead.
func (*MsgRemoveRegistration) GetCreator ¶
func (x *MsgRemoveRegistration) GetCreator() string
func (*MsgRemoveRegistration) GetIsReputer ¶
func (x *MsgRemoveRegistration) GetIsReputer() bool
func (*MsgRemoveRegistration) GetTopicId ¶
func (x *MsgRemoveRegistration) GetTopicId() uint64
func (*MsgRemoveRegistration) ProtoMessage ¶
func (*MsgRemoveRegistration) ProtoMessage()
func (*MsgRemoveRegistration) ProtoReflect ¶
func (x *MsgRemoveRegistration) ProtoReflect() protoreflect.Message
func (*MsgRemoveRegistration) Reset ¶
func (x *MsgRemoveRegistration) Reset()
func (*MsgRemoveRegistration) String ¶
func (x *MsgRemoveRegistration) String() string
type MsgRemoveRegistrationResponse ¶
type MsgRemoveRegistrationResponse struct { Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*MsgRemoveRegistrationResponse) Descriptor
deprecated
func (*MsgRemoveRegistrationResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgRemoveRegistrationResponse.ProtoReflect.Descriptor instead.
func (*MsgRemoveRegistrationResponse) GetMessage ¶
func (x *MsgRemoveRegistrationResponse) GetMessage() string
func (*MsgRemoveRegistrationResponse) GetSuccess ¶
func (x *MsgRemoveRegistrationResponse) GetSuccess() bool
func (*MsgRemoveRegistrationResponse) ProtoMessage ¶
func (*MsgRemoveRegistrationResponse) ProtoMessage()
func (*MsgRemoveRegistrationResponse) ProtoReflect ¶
func (x *MsgRemoveRegistrationResponse) ProtoReflect() protoreflect.Message
func (*MsgRemoveRegistrationResponse) Reset ¶
func (x *MsgRemoveRegistrationResponse) Reset()
func (*MsgRemoveRegistrationResponse) String ¶
func (x *MsgRemoveRegistrationResponse) String() string
type MsgRequestInference ¶
type MsgRequestInference struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Requests []*RequestInferenceListItem `protobuf:"bytes,2,rep,name=requests,proto3" json:"requests,omitempty"` // contains filtered or unexported fields }
func (*MsgRequestInference) Descriptor
deprecated
func (*MsgRequestInference) Descriptor() ([]byte, []int)
Deprecated: Use MsgRequestInference.ProtoReflect.Descriptor instead.
func (*MsgRequestInference) GetRequests ¶
func (x *MsgRequestInference) GetRequests() []*RequestInferenceListItem
func (*MsgRequestInference) GetSender ¶
func (x *MsgRequestInference) GetSender() string
func (*MsgRequestInference) ProtoMessage ¶
func (*MsgRequestInference) ProtoMessage()
func (*MsgRequestInference) ProtoReflect ¶
func (x *MsgRequestInference) ProtoReflect() protoreflect.Message
func (*MsgRequestInference) Reset ¶
func (x *MsgRequestInference) Reset()
func (*MsgRequestInference) String ¶
func (x *MsgRequestInference) String() string
type MsgRequestInferenceResponse ¶
type MsgRequestInferenceResponse struct {
// contains filtered or unexported fields
}
func (*MsgRequestInferenceResponse) Descriptor
deprecated
func (*MsgRequestInferenceResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgRequestInferenceResponse.ProtoReflect.Descriptor instead.
func (*MsgRequestInferenceResponse) ProtoMessage ¶
func (*MsgRequestInferenceResponse) ProtoMessage()
func (*MsgRequestInferenceResponse) ProtoReflect ¶
func (x *MsgRequestInferenceResponse) ProtoReflect() protoreflect.Message
func (*MsgRequestInferenceResponse) Reset ¶
func (x *MsgRequestInferenceResponse) Reset()
func (*MsgRequestInferenceResponse) String ¶
func (x *MsgRequestInferenceResponse) String() string
type MsgServer ¶
type MsgServer interface { UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error) ProcessInferences(context.Context, *MsgProcessInferences) (*MsgProcessInferencesResponse, error) SetWeights(context.Context, *MsgSetWeights) (*MsgSetWeightsResponse, error) CreateNewTopic(context.Context, *MsgCreateNewTopic) (*MsgCreateNewTopicResponse, error) ReactivateTopic(context.Context, *MsgReactivateTopic) (*MsgReactivateTopicResponse, error) Register(context.Context, *MsgRegister) (*MsgRegisterResponse, error) AddNewRegistration(context.Context, *MsgAddNewRegistration) (*MsgAddNewRegistrationResponse, error) RemoveRegistration(context.Context, *MsgRemoveRegistration) (*MsgRemoveRegistrationResponse, error) AddStake(context.Context, *MsgAddStake) (*MsgAddStakeResponse, error) ModifyStake(context.Context, *MsgModifyStake) (*MsgModifyStakeResponse, error) StartRemoveStake(context.Context, *MsgStartRemoveStake) (*MsgStartRemoveStakeResponse, error) ConfirmRemoveStake(context.Context, *MsgConfirmRemoveStake) (*MsgConfirmRemoveStakeResponse, error) StartRemoveAllStake(context.Context, *MsgStartRemoveAllStake) (*MsgStartRemoveAllStakeResponse, error) RequestInference(context.Context, *MsgRequestInference) (*MsgRequestInferenceResponse, error) AddToWhitelistAdmin(context.Context, *MsgAddToWhitelistAdmin) (*MsgAddToWhitelistAdminResponse, error) RemoveFromWhitelistAdmin(context.Context, *MsgRemoveFromWhitelistAdmin) (*MsgRemoveFromWhitelistAdminResponse, error) AddToTopicCreationWhitelist(context.Context, *MsgAddToTopicCreationWhitelist) (*MsgAddToTopicCreationWhitelistResponse, error) RemoveFromTopicCreationWhitelist(context.Context, *MsgRemoveFromTopicCreationWhitelist) (*MsgRemoveFromTopicCreationWhitelistResponse, error) AddToWeightSettingWhitelist(context.Context, *MsgAddToWeightSettingWhitelist) (*MsgAddToWeightSettingWhitelistResponse, error) RemoveFromWeightSettingWhitelist(context.Context, *MsgRemoveFromWeightSettingWhitelist) (*MsgRemoveFromWeightSettingWhitelistResponse, error) // contains filtered or unexported methods }
MsgServer is the server API for Msg service. All implementations must embed UnimplementedMsgServer for forward compatibility
type MsgSetWeights ¶
type MsgSetWeights struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Weights []*Weight `protobuf:"bytes,2,rep,name=weights,proto3" json:"weights,omitempty"` // contains filtered or unexported fields }
MsgSetWeights sets the weights for a given validator.
func (*MsgSetWeights) Descriptor
deprecated
func (*MsgSetWeights) Descriptor() ([]byte, []int)
Deprecated: Use MsgSetWeights.ProtoReflect.Descriptor instead.
func (*MsgSetWeights) GetSender ¶
func (x *MsgSetWeights) GetSender() string
func (*MsgSetWeights) GetWeights ¶
func (x *MsgSetWeights) GetWeights() []*Weight
func (*MsgSetWeights) ProtoMessage ¶
func (*MsgSetWeights) ProtoMessage()
func (*MsgSetWeights) ProtoReflect ¶
func (x *MsgSetWeights) ProtoReflect() protoreflect.Message
func (*MsgSetWeights) Reset ¶
func (x *MsgSetWeights) Reset()
func (*MsgSetWeights) String ¶
func (x *MsgSetWeights) String() string
type MsgSetWeightsResponse ¶
type MsgSetWeightsResponse struct {
// contains filtered or unexported fields
}
func (*MsgSetWeightsResponse) Descriptor
deprecated
func (*MsgSetWeightsResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgSetWeightsResponse.ProtoReflect.Descriptor instead.
func (*MsgSetWeightsResponse) ProtoMessage ¶
func (*MsgSetWeightsResponse) ProtoMessage()
func (*MsgSetWeightsResponse) ProtoReflect ¶
func (x *MsgSetWeightsResponse) ProtoReflect() protoreflect.Message
func (*MsgSetWeightsResponse) Reset ¶
func (x *MsgSetWeightsResponse) Reset()
func (*MsgSetWeightsResponse) String ¶
func (x *MsgSetWeightsResponse) String() string
type MsgStartRemoveAllStake ¶
type MsgStartRemoveAllStake struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` // contains filtered or unexported fields }
func (*MsgStartRemoveAllStake) Descriptor
deprecated
func (*MsgStartRemoveAllStake) Descriptor() ([]byte, []int)
Deprecated: Use MsgStartRemoveAllStake.ProtoReflect.Descriptor instead.
func (*MsgStartRemoveAllStake) GetSender ¶
func (x *MsgStartRemoveAllStake) GetSender() string
func (*MsgStartRemoveAllStake) ProtoMessage ¶
func (*MsgStartRemoveAllStake) ProtoMessage()
func (*MsgStartRemoveAllStake) ProtoReflect ¶
func (x *MsgStartRemoveAllStake) ProtoReflect() protoreflect.Message
func (*MsgStartRemoveAllStake) Reset ¶
func (x *MsgStartRemoveAllStake) Reset()
func (*MsgStartRemoveAllStake) String ¶
func (x *MsgStartRemoveAllStake) String() string
type MsgStartRemoveAllStakeResponse ¶
type MsgStartRemoveAllStakeResponse struct {
// contains filtered or unexported fields
}
func (*MsgStartRemoveAllStakeResponse) Descriptor
deprecated
func (*MsgStartRemoveAllStakeResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgStartRemoveAllStakeResponse.ProtoReflect.Descriptor instead.
func (*MsgStartRemoveAllStakeResponse) ProtoMessage ¶
func (*MsgStartRemoveAllStakeResponse) ProtoMessage()
func (*MsgStartRemoveAllStakeResponse) ProtoReflect ¶
func (x *MsgStartRemoveAllStakeResponse) ProtoReflect() protoreflect.Message
func (*MsgStartRemoveAllStakeResponse) Reset ¶
func (x *MsgStartRemoveAllStakeResponse) Reset()
func (*MsgStartRemoveAllStakeResponse) String ¶
func (x *MsgStartRemoveAllStakeResponse) String() string
type MsgStartRemoveStake ¶
type MsgStartRemoveStake struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` PlacementsRemove []*StakePlacement `protobuf:"bytes,2,rep,name=placements_remove,json=placementsRemove,proto3" json:"placements_remove,omitempty"` // contains filtered or unexported fields }
func (*MsgStartRemoveStake) Descriptor
deprecated
func (*MsgStartRemoveStake) Descriptor() ([]byte, []int)
Deprecated: Use MsgStartRemoveStake.ProtoReflect.Descriptor instead.
func (*MsgStartRemoveStake) GetPlacementsRemove ¶
func (x *MsgStartRemoveStake) GetPlacementsRemove() []*StakePlacement
func (*MsgStartRemoveStake) GetSender ¶
func (x *MsgStartRemoveStake) GetSender() string
func (*MsgStartRemoveStake) ProtoMessage ¶
func (*MsgStartRemoveStake) ProtoMessage()
func (*MsgStartRemoveStake) ProtoReflect ¶
func (x *MsgStartRemoveStake) ProtoReflect() protoreflect.Message
func (*MsgStartRemoveStake) Reset ¶
func (x *MsgStartRemoveStake) Reset()
func (*MsgStartRemoveStake) String ¶
func (x *MsgStartRemoveStake) String() string
type MsgStartRemoveStakeResponse ¶
type MsgStartRemoveStakeResponse struct {
// contains filtered or unexported fields
}
func (*MsgStartRemoveStakeResponse) Descriptor
deprecated
func (*MsgStartRemoveStakeResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgStartRemoveStakeResponse.ProtoReflect.Descriptor instead.
func (*MsgStartRemoveStakeResponse) ProtoMessage ¶
func (*MsgStartRemoveStakeResponse) ProtoMessage()
func (*MsgStartRemoveStakeResponse) ProtoReflect ¶
func (x *MsgStartRemoveStakeResponse) ProtoReflect() protoreflect.Message
func (*MsgStartRemoveStakeResponse) Reset ¶
func (x *MsgStartRemoveStakeResponse) Reset()
func (*MsgStartRemoveStakeResponse) String ¶
func (x *MsgStartRemoveStakeResponse) String() string
type MsgUpdateParams ¶ added in v0.0.4
type MsgUpdateParams struct { Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"` Params *OptionalParams `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"` // contains filtered or unexported fields }
func (*MsgUpdateParams) Descriptor
deprecated
added in
v0.0.4
func (*MsgUpdateParams) Descriptor() ([]byte, []int)
Deprecated: Use MsgUpdateParams.ProtoReflect.Descriptor instead.
func (*MsgUpdateParams) GetParams ¶ added in v0.0.4
func (x *MsgUpdateParams) GetParams() *OptionalParams
func (*MsgUpdateParams) GetSender ¶ added in v0.0.4
func (x *MsgUpdateParams) GetSender() string
func (*MsgUpdateParams) ProtoMessage ¶ added in v0.0.4
func (*MsgUpdateParams) ProtoMessage()
func (*MsgUpdateParams) ProtoReflect ¶ added in v0.0.4
func (x *MsgUpdateParams) ProtoReflect() protoreflect.Message
func (*MsgUpdateParams) Reset ¶ added in v0.0.4
func (x *MsgUpdateParams) Reset()
func (*MsgUpdateParams) String ¶ added in v0.0.4
func (x *MsgUpdateParams) String() string
type MsgUpdateParamsResponse ¶ added in v0.0.4
type MsgUpdateParamsResponse struct {
// contains filtered or unexported fields
}
func (*MsgUpdateParamsResponse) Descriptor
deprecated
added in
v0.0.4
func (*MsgUpdateParamsResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgUpdateParamsResponse.ProtoReflect.Descriptor instead.
func (*MsgUpdateParamsResponse) ProtoMessage ¶ added in v0.0.4
func (*MsgUpdateParamsResponse) ProtoMessage()
func (*MsgUpdateParamsResponse) ProtoReflect ¶ added in v0.0.4
func (x *MsgUpdateParamsResponse) ProtoReflect() protoreflect.Message
func (*MsgUpdateParamsResponse) Reset ¶ added in v0.0.4
func (x *MsgUpdateParamsResponse) Reset()
func (*MsgUpdateParamsResponse) String ¶ added in v0.0.4
func (x *MsgUpdateParamsResponse) String() string
type OffchainNode ¶
type OffchainNode struct { LibP2PKey string `protobuf:"bytes,1,opt,name=lib_p2p_key,json=libP2pKey,proto3" json:"lib_p2p_key,omitempty"` // LibP2P key of the node MultiAddress string `protobuf:"bytes,2,opt,name=multi_address,json=multiAddress,proto3" json:"multi_address,omitempty"` // Network address for accessing the node Owner string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` NodeAddress string `protobuf:"bytes,4,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"` NodeId string `protobuf:"bytes,5,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // contains filtered or unexported fields }
func (*OffchainNode) Descriptor
deprecated
func (*OffchainNode) Descriptor() ([]byte, []int)
Deprecated: Use OffchainNode.ProtoReflect.Descriptor instead.
func (*OffchainNode) GetLibP2PKey ¶
func (x *OffchainNode) GetLibP2PKey() string
func (*OffchainNode) GetMultiAddress ¶
func (x *OffchainNode) GetMultiAddress() string
func (*OffchainNode) GetNodeAddress ¶
func (x *OffchainNode) GetNodeAddress() string
func (*OffchainNode) GetNodeId ¶
func (x *OffchainNode) GetNodeId() string
func (*OffchainNode) GetOwner ¶
func (x *OffchainNode) GetOwner() string
func (*OffchainNode) ProtoMessage ¶
func (*OffchainNode) ProtoMessage()
func (*OffchainNode) ProtoReflect ¶
func (x *OffchainNode) ProtoReflect() protoreflect.Message
func (*OffchainNode) Reset ¶
func (x *OffchainNode) Reset()
func (*OffchainNode) String ¶
func (x *OffchainNode) String() string
type OffchainNodes ¶
type OffchainNodes struct { OffchainNode []*Inference `protobuf:"bytes,1,rep,name=offchain_node,json=offchainNode,proto3" json:"offchain_node,omitempty"` // contains filtered or unexported fields }
func (*OffchainNodes) Descriptor
deprecated
func (*OffchainNodes) Descriptor() ([]byte, []int)
Deprecated: Use OffchainNodes.ProtoReflect.Descriptor instead.
func (*OffchainNodes) GetOffchainNode ¶
func (x *OffchainNodes) GetOffchainNode() []*Inference
func (*OffchainNodes) ProtoMessage ¶
func (*OffchainNodes) ProtoMessage()
func (*OffchainNodes) ProtoReflect ¶
func (x *OffchainNodes) ProtoReflect() protoreflect.Message
func (*OffchainNodes) Reset ¶
func (x *OffchainNodes) Reset()
func (*OffchainNodes) String ¶
func (x *OffchainNodes) String() string
type OptionalParams ¶ added in v0.0.4
type OptionalParams struct { Version []string `protobuf:"bytes,1,rep,name=version,proto3" json:"version,omitempty"` // version of the protocol should be in lockstep with github release tag version EpochLength []int64 `protobuf:"varint,2,rep,packed,name=epoch_length,json=epochLength,proto3" json:"epoch_length,omitempty"` // length of an "epoch" for rewards payouts in blocks MinTopicUnmetDemand []string `protobuf:"bytes,3,rep,name=min_topic_unmet_demand,json=minTopicUnmetDemand,proto3" json:"min_topic_unmet_demand,omitempty"` // total unmet demand for a topic < this => don't run inference solicatation or weight-adjustment MaxTopicsPerBlock []uint64 `protobuf:"varint,4,rep,packed,name=max_topics_per_block,json=maxTopicsPerBlock,proto3" json:"max_topics_per_block,omitempty"` // max number of topics to run cadence for per block MinRequestUnmetDemand []string `` // delete requests if they have below this demand remaining /* 128-byte string literal not displayed */ MaxMissingInferencePercent []string `` // if worker has this percentage of inferences missing penalize them /* 143-byte string literal not displayed */ RequiredMinimumStake []string `protobuf:"bytes,7,rep,name=required_minimum_stake,json=requiredMinimumStake,proto3" json:"required_minimum_stake,omitempty"` // minimum amount of tokens to send to stake as a reputer or worker RemoveStakeDelayWindow []uint64 `` // how long to wait before allowed to remove stake /* 139-byte string literal not displayed */ MinRequestCadence []uint64 `protobuf:"varint,9,rep,packed,name=min_request_cadence,json=minRequestCadence,proto3" json:"min_request_cadence,omitempty"` // Fastest allowed cadence of a repeating inference request MinWeightCadence []uint64 `protobuf:"varint,10,rep,packed,name=min_weight_cadence,json=minWeightCadence,proto3" json:"min_weight_cadence,omitempty"` // Fastest allowed cadence of uploading weights MaxInferenceRequestValidity []uint64 `` // longest time a subscription is allowed to be valid /* 155-byte string literal not displayed */ MaxRequestCadence []uint64 `protobuf:"varint,12,rep,packed,name=max_request_cadence,json=maxRequestCadence,proto3" json:"max_request_cadence,omitempty"` // slowest/largest amount of time subscription can take between inferences PercentRewardsReputersWorkers []string `` // rewards (tx fees + inflation) paid to workers/reputers. Validators get the rest /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
Because gocosmos, grpc-gateway, and go-pulsar do not support optional fields and including google themselves https://cloud.google.com/apis/design/design_patterns.md#optional_primitive_fields we instead use a repeated field with a single element to represent an optional field and if the repeated field is empty, it is considered to be the same as if the field was not set
func (*OptionalParams) Descriptor
deprecated
added in
v0.0.4
func (*OptionalParams) Descriptor() ([]byte, []int)
Deprecated: Use OptionalParams.ProtoReflect.Descriptor instead.
func (*OptionalParams) GetEpochLength ¶ added in v0.0.4
func (x *OptionalParams) GetEpochLength() []int64
func (*OptionalParams) GetMaxInferenceRequestValidity ¶ added in v0.0.4
func (x *OptionalParams) GetMaxInferenceRequestValidity() []uint64
func (*OptionalParams) GetMaxMissingInferencePercent ¶ added in v0.0.4
func (x *OptionalParams) GetMaxMissingInferencePercent() []string
func (*OptionalParams) GetMaxRequestCadence ¶ added in v0.0.4
func (x *OptionalParams) GetMaxRequestCadence() []uint64
func (*OptionalParams) GetMaxTopicsPerBlock ¶ added in v0.0.4
func (x *OptionalParams) GetMaxTopicsPerBlock() []uint64
func (*OptionalParams) GetMinRequestCadence ¶ added in v0.0.4
func (x *OptionalParams) GetMinRequestCadence() []uint64
func (*OptionalParams) GetMinRequestUnmetDemand ¶ added in v0.0.4
func (x *OptionalParams) GetMinRequestUnmetDemand() []string
func (*OptionalParams) GetMinTopicUnmetDemand ¶ added in v0.0.4
func (x *OptionalParams) GetMinTopicUnmetDemand() []string
func (*OptionalParams) GetMinWeightCadence ¶ added in v0.0.4
func (x *OptionalParams) GetMinWeightCadence() []uint64
func (*OptionalParams) GetPercentRewardsReputersWorkers ¶ added in v0.0.4
func (x *OptionalParams) GetPercentRewardsReputersWorkers() []string
func (*OptionalParams) GetRemoveStakeDelayWindow ¶ added in v0.0.4
func (x *OptionalParams) GetRemoveStakeDelayWindow() []uint64
func (*OptionalParams) GetRequiredMinimumStake ¶ added in v0.0.4
func (x *OptionalParams) GetRequiredMinimumStake() []string
func (*OptionalParams) GetVersion ¶ added in v0.0.4
func (x *OptionalParams) GetVersion() []string
func (*OptionalParams) ProtoMessage ¶ added in v0.0.4
func (*OptionalParams) ProtoMessage()
func (*OptionalParams) ProtoReflect ¶ added in v0.0.4
func (x *OptionalParams) ProtoReflect() protoreflect.Message
func (*OptionalParams) Reset ¶ added in v0.0.4
func (x *OptionalParams) Reset()
func (*OptionalParams) String ¶ added in v0.0.4
func (x *OptionalParams) String() string
type Params ¶
type Params struct { Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"` // version of the protocol should be in lockstep with github release tag version EpochLength int64 `protobuf:"varint,2,opt,name=epoch_length,json=epochLength,proto3" json:"epoch_length,omitempty"` // length of an "epoch" for rewards payouts in blocks MinTopicUnmetDemand string `protobuf:"bytes,3,opt,name=min_topic_unmet_demand,json=minTopicUnmetDemand,proto3" json:"min_topic_unmet_demand,omitempty"` // total unmet demand for a topic < this => don't run inference solicatation or weight-adjustment MaxTopicsPerBlock uint64 `protobuf:"varint,4,opt,name=max_topics_per_block,json=maxTopicsPerBlock,proto3" json:"max_topics_per_block,omitempty"` // max number of topics to run cadence for per block MinRequestUnmetDemand string `` // delete requests if they have below this demand remaining /* 128-byte string literal not displayed */ MaxMissingInferencePercent string `` // if a worker has this percentage of inferences missing, penalize them /* 143-byte string literal not displayed */ RequiredMinimumStake string `protobuf:"bytes,7,opt,name=required_minimum_stake,json=requiredMinimumStake,proto3" json:"required_minimum_stake,omitempty"` // minimum amount of tokens to send to stake as a reputer or worker RemoveStakeDelayWindow uint64 `` // how long to wait before allowed to remove stake /* 132-byte string literal not displayed */ MinRequestCadence uint64 `protobuf:"varint,9,opt,name=min_request_cadence,json=minRequestCadence,proto3" json:"min_request_cadence,omitempty"` // Fastest allowed cadence of a repeating inference request MinWeightCadence uint64 `protobuf:"varint,10,opt,name=min_weight_cadence,json=minWeightCadence,proto3" json:"min_weight_cadence,omitempty"` // Fastest allowed cadence of uploading weights MaxInferenceRequestValidity uint64 `` // longest time a subscription of inferences is allowed to be valid /* 148-byte string literal not displayed */ MaxRequestCadence uint64 `protobuf:"varint,12,opt,name=max_request_cadence,json=maxRequestCadence,proto3" json:"max_request_cadence,omitempty"` // slowest (largest) amount of time a subscription can take between inferences PercentRewardsReputersWorkers string `` // rewards (tx fees + inflation) paid to workers/reputers. Validators get the rest /* 153-byte string literal not displayed */ // contains filtered or unexported fields }
Params defines the parameters of the module.
func (*Params) Descriptor
deprecated
func (*Params) GetEpochLength ¶ added in v0.0.4
func (*Params) GetMaxInferenceRequestValidity ¶ added in v0.0.4
func (*Params) GetMaxMissingInferencePercent ¶ added in v0.0.4
func (*Params) GetMaxRequestCadence ¶ added in v0.0.4
func (*Params) GetMaxTopicsPerBlock ¶ added in v0.0.4
func (*Params) GetMinRequestCadence ¶ added in v0.0.4
func (*Params) GetMinRequestUnmetDemand ¶ added in v0.0.4
func (*Params) GetMinTopicUnmetDemand ¶ added in v0.0.4
func (*Params) GetMinWeightCadence ¶ added in v0.0.4
func (*Params) GetPercentRewardsReputersWorkers ¶ added in v0.0.4
func (*Params) GetRemoveStakeDelayWindow ¶ added in v0.0.4
func (*Params) GetRequiredMinimumStake ¶ added in v0.0.4
func (*Params) GetVersion ¶
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (*Params) ProtoReflect ¶
func (x *Params) ProtoReflect() protoreflect.Message
type QueryAccountStakeListRequest ¶
type QueryAccountStakeListRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*QueryAccountStakeListRequest) Descriptor
deprecated
func (*QueryAccountStakeListRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryAccountStakeListRequest.ProtoReflect.Descriptor instead.
func (*QueryAccountStakeListRequest) GetAddress ¶
func (x *QueryAccountStakeListRequest) GetAddress() string
func (*QueryAccountStakeListRequest) ProtoMessage ¶
func (*QueryAccountStakeListRequest) ProtoMessage()
func (*QueryAccountStakeListRequest) ProtoReflect ¶
func (x *QueryAccountStakeListRequest) ProtoReflect() protoreflect.Message
func (*QueryAccountStakeListRequest) Reset ¶
func (x *QueryAccountStakeListRequest) Reset()
func (*QueryAccountStakeListRequest) String ¶
func (x *QueryAccountStakeListRequest) String() string
type QueryAccountStakeListResponse ¶
type QueryAccountStakeListResponse struct { Stakes []*StakeInfo `protobuf:"bytes,1,rep,name=stakes,proto3" json:"stakes,omitempty"` // contains filtered or unexported fields }
func (*QueryAccountStakeListResponse) Descriptor
deprecated
func (*QueryAccountStakeListResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryAccountStakeListResponse.ProtoReflect.Descriptor instead.
func (*QueryAccountStakeListResponse) GetStakes ¶
func (x *QueryAccountStakeListResponse) GetStakes() []*StakeInfo
func (*QueryAccountStakeListResponse) ProtoMessage ¶
func (*QueryAccountStakeListResponse) ProtoMessage()
func (*QueryAccountStakeListResponse) ProtoReflect ¶
func (x *QueryAccountStakeListResponse) ProtoReflect() protoreflect.Message
func (*QueryAccountStakeListResponse) Reset ¶
func (x *QueryAccountStakeListResponse) Reset()
func (*QueryAccountStakeListResponse) String ¶
func (x *QueryAccountStakeListResponse) String() string
type QueryActiveTopicsRequest ¶
type QueryActiveTopicsRequest struct {
// contains filtered or unexported fields
}
func (*QueryActiveTopicsRequest) Descriptor
deprecated
func (*QueryActiveTopicsRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryActiveTopicsRequest.ProtoReflect.Descriptor instead.
func (*QueryActiveTopicsRequest) ProtoMessage ¶
func (*QueryActiveTopicsRequest) ProtoMessage()
func (*QueryActiveTopicsRequest) ProtoReflect ¶
func (x *QueryActiveTopicsRequest) ProtoReflect() protoreflect.Message
func (*QueryActiveTopicsRequest) Reset ¶
func (x *QueryActiveTopicsRequest) Reset()
func (*QueryActiveTopicsRequest) String ¶
func (x *QueryActiveTopicsRequest) String() string
type QueryActiveTopicsResponse ¶
type QueryActiveTopicsResponse struct { Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"` // contains filtered or unexported fields }
func (*QueryActiveTopicsResponse) Descriptor
deprecated
func (*QueryActiveTopicsResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryActiveTopicsResponse.ProtoReflect.Descriptor instead.
func (*QueryActiveTopicsResponse) GetTopics ¶
func (x *QueryActiveTopicsResponse) GetTopics() []*Topic
func (*QueryActiveTopicsResponse) ProtoMessage ¶
func (*QueryActiveTopicsResponse) ProtoMessage()
func (*QueryActiveTopicsResponse) ProtoReflect ¶
func (x *QueryActiveTopicsResponse) ProtoReflect() protoreflect.Message
func (*QueryActiveTopicsResponse) Reset ¶
func (x *QueryActiveTopicsResponse) Reset()
func (*QueryActiveTopicsResponse) String ¶
func (x *QueryActiveTopicsResponse) String() string
type QueryAllExistingInferenceRequest ¶ added in v0.0.4
type QueryAllExistingInferenceRequest struct {
// contains filtered or unexported fields
}
func (*QueryAllExistingInferenceRequest) Descriptor
deprecated
added in
v0.0.4
func (*QueryAllExistingInferenceRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryAllExistingInferenceRequest.ProtoReflect.Descriptor instead.
func (*QueryAllExistingInferenceRequest) ProtoMessage ¶ added in v0.0.4
func (*QueryAllExistingInferenceRequest) ProtoMessage()
func (*QueryAllExistingInferenceRequest) ProtoReflect ¶ added in v0.0.4
func (x *QueryAllExistingInferenceRequest) ProtoReflect() protoreflect.Message
func (*QueryAllExistingInferenceRequest) Reset ¶ added in v0.0.4
func (x *QueryAllExistingInferenceRequest) Reset()
func (*QueryAllExistingInferenceRequest) String ¶ added in v0.0.4
func (x *QueryAllExistingInferenceRequest) String() string
type QueryAllExistingInferenceResponse ¶ added in v0.0.4
type QueryAllExistingInferenceResponse struct { InferenceRequests []*InferenceRequestAndDemandLeft `protobuf:"bytes,1,rep,name=inference_requests,json=inferenceRequests,proto3" json:"inference_requests,omitempty"` // contains filtered or unexported fields }
func (*QueryAllExistingInferenceResponse) Descriptor
deprecated
added in
v0.0.4
func (*QueryAllExistingInferenceResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryAllExistingInferenceResponse.ProtoReflect.Descriptor instead.
func (*QueryAllExistingInferenceResponse) GetInferenceRequests ¶ added in v0.0.4
func (x *QueryAllExistingInferenceResponse) GetInferenceRequests() []*InferenceRequestAndDemandLeft
func (*QueryAllExistingInferenceResponse) ProtoMessage ¶ added in v0.0.4
func (*QueryAllExistingInferenceResponse) ProtoMessage()
func (*QueryAllExistingInferenceResponse) ProtoReflect ¶ added in v0.0.4
func (x *QueryAllExistingInferenceResponse) ProtoReflect() protoreflect.Message
func (*QueryAllExistingInferenceResponse) Reset ¶ added in v0.0.4
func (x *QueryAllExistingInferenceResponse) Reset()
func (*QueryAllExistingInferenceResponse) String ¶ added in v0.0.4
func (x *QueryAllExistingInferenceResponse) String() string
type QueryAllInferencesRequest ¶ added in v0.0.4
type QueryAllInferencesRequest struct { TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // contains filtered or unexported fields }
Returns the latest inference on a topic from a worker
func (*QueryAllInferencesRequest) Descriptor
deprecated
added in
v0.0.4
func (*QueryAllInferencesRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryAllInferencesRequest.ProtoReflect.Descriptor instead.
func (*QueryAllInferencesRequest) GetTimestamp ¶ added in v0.0.4
func (x *QueryAllInferencesRequest) GetTimestamp() uint64
func (*QueryAllInferencesRequest) GetTopicId ¶ added in v0.0.4
func (x *QueryAllInferencesRequest) GetTopicId() uint64
func (*QueryAllInferencesRequest) ProtoMessage ¶ added in v0.0.4
func (*QueryAllInferencesRequest) ProtoMessage()
func (*QueryAllInferencesRequest) ProtoReflect ¶ added in v0.0.4
func (x *QueryAllInferencesRequest) ProtoReflect() protoreflect.Message
func (*QueryAllInferencesRequest) Reset ¶ added in v0.0.4
func (x *QueryAllInferencesRequest) Reset()
func (*QueryAllInferencesRequest) String ¶ added in v0.0.4
func (x *QueryAllInferencesRequest) String() string
type QueryAllInferencesResponse ¶ added in v0.0.4
type QueryAllInferencesResponse struct { Inferences *Inferences `protobuf:"bytes,1,opt,name=inferences,proto3" json:"inferences,omitempty"` // contains filtered or unexported fields }
Returns the latest inference on a topic from a worker
NOTE: The amount field is a Uint which implements the custom method signatures required by gogoproto.
func (*QueryAllInferencesResponse) Descriptor
deprecated
added in
v0.0.4
func (*QueryAllInferencesResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryAllInferencesResponse.ProtoReflect.Descriptor instead.
func (*QueryAllInferencesResponse) GetInferences ¶ added in v0.0.4
func (x *QueryAllInferencesResponse) GetInferences() *Inferences
func (*QueryAllInferencesResponse) ProtoMessage ¶ added in v0.0.4
func (*QueryAllInferencesResponse) ProtoMessage()
func (*QueryAllInferencesResponse) ProtoReflect ¶ added in v0.0.4
func (x *QueryAllInferencesResponse) ProtoReflect() protoreflect.Message
func (*QueryAllInferencesResponse) Reset ¶ added in v0.0.4
func (x *QueryAllInferencesResponse) Reset()
func (*QueryAllInferencesResponse) String ¶ added in v0.0.4
func (x *QueryAllInferencesResponse) String() string
type QueryAllTopicsRequest ¶ added in v0.0.4
type QueryAllTopicsRequest struct {
// contains filtered or unexported fields
}
func (*QueryAllTopicsRequest) Descriptor
deprecated
added in
v0.0.4
func (*QueryAllTopicsRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryAllTopicsRequest.ProtoReflect.Descriptor instead.
func (*QueryAllTopicsRequest) ProtoMessage ¶ added in v0.0.4
func (*QueryAllTopicsRequest) ProtoMessage()
func (*QueryAllTopicsRequest) ProtoReflect ¶ added in v0.0.4
func (x *QueryAllTopicsRequest) ProtoReflect() protoreflect.Message
func (*QueryAllTopicsRequest) Reset ¶ added in v0.0.4
func (x *QueryAllTopicsRequest) Reset()
func (*QueryAllTopicsRequest) String ¶ added in v0.0.4
func (x *QueryAllTopicsRequest) String() string
type QueryAllTopicsResponse ¶ added in v0.0.4
type QueryAllTopicsResponse struct { Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"` // contains filtered or unexported fields }
func (*QueryAllTopicsResponse) Descriptor
deprecated
added in
v0.0.4
func (*QueryAllTopicsResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryAllTopicsResponse.ProtoReflect.Descriptor instead.
func (*QueryAllTopicsResponse) GetTopics ¶ added in v0.0.4
func (x *QueryAllTopicsResponse) GetTopics() []*Topic
func (*QueryAllTopicsResponse) ProtoMessage ¶ added in v0.0.4
func (*QueryAllTopicsResponse) ProtoMessage()
func (*QueryAllTopicsResponse) ProtoReflect ¶ added in v0.0.4
func (x *QueryAllTopicsResponse) ProtoReflect() protoreflect.Message
func (*QueryAllTopicsResponse) Reset ¶ added in v0.0.4
func (x *QueryAllTopicsResponse) Reset()
func (*QueryAllTopicsResponse) String ¶ added in v0.0.4
func (x *QueryAllTopicsResponse) String() string
type QueryClient ¶
type QueryClient interface { // Params returns the module parameters. Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error) GetLastRewardsUpdate(ctx context.Context, in *QueryLastRewardsUpdateRequest, opts ...grpc.CallOption) (*QueryLastRewardsUpdateResponse, error) GetNextTopicId(ctx context.Context, in *QueryNextTopicIdRequest, opts ...grpc.CallOption) (*QueryNextTopicIdResponse, error) GetTopic(ctx context.Context, in *QueryTopicRequest, opts ...grpc.CallOption) (*QueryTopicResponse, error) GetActiveTopics(ctx context.Context, in *QueryActiveTopicsRequest, opts ...grpc.CallOption) (*QueryActiveTopicsResponse, error) GetAllTopics(ctx context.Context, in *QueryAllTopicsRequest, opts ...grpc.CallOption) (*QueryAllTopicsResponse, error) GetTopicsByCreator(ctx context.Context, in *QueryGetTopicsByCreatorRequest, opts ...grpc.CallOption) (*QueryGetTopicsByCreatorResponse, error) GetWeight(ctx context.Context, in *QueryWeightRequest, opts ...grpc.CallOption) (*QueryWeightResponse, error) GetExistingInferenceRequest(ctx context.Context, in *QueryExistingInferenceRequest, opts ...grpc.CallOption) (*QueryExistingInferenceResponse, error) GetAllExistingInferenceRequests(ctx context.Context, in *QueryAllExistingInferenceRequest, opts ...grpc.CallOption) (*QueryAllExistingInferenceResponse, error) GetTopicUnmetDemand(ctx context.Context, in *QueryTopicUnmetDemandRequest, opts ...grpc.CallOption) (*QueryTopicUnmetDemandResponse, error) GetWorkerLatestInferenceByTopicId(ctx context.Context, in *QueryWorkerLatestInferenceRequest, opts ...grpc.CallOption) (*QueryWorkerLatestInferenceResponse, error) GetAllInferences(ctx context.Context, in *QueryAllInferencesRequest, opts ...grpc.CallOption) (*QueryAllInferencesResponse, error) GetInferencesToScore(ctx context.Context, in *QueryInferencesToScoreRequest, opts ...grpc.CallOption) (*QueryInferencesToScoreResponse, error) GetTotalStake(ctx context.Context, in *QueryTotalStakeRequest, opts ...grpc.CallOption) (*QueryTotalStakeResponse, error) GetAccountStakeList(ctx context.Context, in *QueryAccountStakeListRequest, opts ...grpc.CallOption) (*QueryAccountStakeListResponse, error) GetWorkerNodeRegistration(ctx context.Context, in *QueryRegisteredWorkerNodesRequest, opts ...grpc.CallOption) (*QueryRegisteredWorkerNodesResponse, error) GetWorkerAddressByP2PKey(ctx context.Context, in *QueryWorkerAddressByP2PKeyRequest, opts ...grpc.CallOption) (*QueryWorkerAddressByP2PKeyResponse, error) GetRegisteredTopicIds(ctx context.Context, in *QueryRegisteredTopicIdsRequest, opts ...grpc.CallOption) (*QueryRegisteredTopicIdsResponse, error) }
QueryClient is the client API for Query service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewQueryClient ¶
func NewQueryClient(cc grpc.ClientConnInterface) QueryClient
type QueryExistingInferenceRequest ¶ added in v0.0.4
type QueryExistingInferenceRequest struct { RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` TopicId uint64 `protobuf:"varint,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` // contains filtered or unexported fields }
func (*QueryExistingInferenceRequest) Descriptor
deprecated
added in
v0.0.4
func (*QueryExistingInferenceRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryExistingInferenceRequest.ProtoReflect.Descriptor instead.
func (*QueryExistingInferenceRequest) GetRequestId ¶ added in v0.0.4
func (x *QueryExistingInferenceRequest) GetRequestId() string
func (*QueryExistingInferenceRequest) GetTopicId ¶ added in v0.0.4
func (x *QueryExistingInferenceRequest) GetTopicId() uint64
func (*QueryExistingInferenceRequest) ProtoMessage ¶ added in v0.0.4
func (*QueryExistingInferenceRequest) ProtoMessage()
func (*QueryExistingInferenceRequest) ProtoReflect ¶ added in v0.0.4
func (x *QueryExistingInferenceRequest) ProtoReflect() protoreflect.Message
func (*QueryExistingInferenceRequest) Reset ¶ added in v0.0.4
func (x *QueryExistingInferenceRequest) Reset()
func (*QueryExistingInferenceRequest) String ¶ added in v0.0.4
func (x *QueryExistingInferenceRequest) String() string
type QueryExistingInferenceResponse ¶ added in v0.0.4
type QueryExistingInferenceResponse struct { InferenceRequest *InferenceRequest `protobuf:"bytes,1,opt,name=inference_request,json=inferenceRequest,proto3" json:"inference_request,omitempty"` DemandLeft string `protobuf:"bytes,2,opt,name=demand_left,json=demandLeft,proto3" json:"demand_left,omitempty"` // contains filtered or unexported fields }
func (*QueryExistingInferenceResponse) Descriptor
deprecated
added in
v0.0.4
func (*QueryExistingInferenceResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryExistingInferenceResponse.ProtoReflect.Descriptor instead.
func (*QueryExistingInferenceResponse) GetDemandLeft ¶ added in v0.0.4
func (x *QueryExistingInferenceResponse) GetDemandLeft() string
func (*QueryExistingInferenceResponse) GetInferenceRequest ¶ added in v0.0.4
func (x *QueryExistingInferenceResponse) GetInferenceRequest() *InferenceRequest
func (*QueryExistingInferenceResponse) ProtoMessage ¶ added in v0.0.4
func (*QueryExistingInferenceResponse) ProtoMessage()
func (*QueryExistingInferenceResponse) ProtoReflect ¶ added in v0.0.4
func (x *QueryExistingInferenceResponse) ProtoReflect() protoreflect.Message
func (*QueryExistingInferenceResponse) Reset ¶ added in v0.0.4
func (x *QueryExistingInferenceResponse) Reset()
func (*QueryExistingInferenceResponse) String ¶ added in v0.0.4
func (x *QueryExistingInferenceResponse) String() string
type QueryGetTopicsByCreatorRequest ¶
type QueryGetTopicsByCreatorRequest struct { Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"` // contains filtered or unexported fields }
func (*QueryGetTopicsByCreatorRequest) Descriptor
deprecated
func (*QueryGetTopicsByCreatorRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryGetTopicsByCreatorRequest.ProtoReflect.Descriptor instead.
func (*QueryGetTopicsByCreatorRequest) GetCreator ¶
func (x *QueryGetTopicsByCreatorRequest) GetCreator() string
func (*QueryGetTopicsByCreatorRequest) ProtoMessage ¶
func (*QueryGetTopicsByCreatorRequest) ProtoMessage()
func (*QueryGetTopicsByCreatorRequest) ProtoReflect ¶
func (x *QueryGetTopicsByCreatorRequest) ProtoReflect() protoreflect.Message
func (*QueryGetTopicsByCreatorRequest) Reset ¶
func (x *QueryGetTopicsByCreatorRequest) Reset()
func (*QueryGetTopicsByCreatorRequest) String ¶
func (x *QueryGetTopicsByCreatorRequest) String() string
type QueryGetTopicsByCreatorResponse ¶
type QueryGetTopicsByCreatorResponse struct { Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"` // contains filtered or unexported fields }
func (*QueryGetTopicsByCreatorResponse) Descriptor
deprecated
func (*QueryGetTopicsByCreatorResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryGetTopicsByCreatorResponse.ProtoReflect.Descriptor instead.
func (*QueryGetTopicsByCreatorResponse) GetTopics ¶
func (x *QueryGetTopicsByCreatorResponse) GetTopics() []*Topic
func (*QueryGetTopicsByCreatorResponse) ProtoMessage ¶
func (*QueryGetTopicsByCreatorResponse) ProtoMessage()
func (*QueryGetTopicsByCreatorResponse) ProtoReflect ¶
func (x *QueryGetTopicsByCreatorResponse) ProtoReflect() protoreflect.Message
func (*QueryGetTopicsByCreatorResponse) Reset ¶
func (x *QueryGetTopicsByCreatorResponse) Reset()
func (*QueryGetTopicsByCreatorResponse) String ¶
func (x *QueryGetTopicsByCreatorResponse) String() string
type QueryInferencesToScoreRequest ¶
type QueryInferencesToScoreRequest struct { TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` // contains filtered or unexported fields }
func (*QueryInferencesToScoreRequest) Descriptor
deprecated
func (*QueryInferencesToScoreRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryInferencesToScoreRequest.ProtoReflect.Descriptor instead.
func (*QueryInferencesToScoreRequest) GetTopicId ¶
func (x *QueryInferencesToScoreRequest) GetTopicId() uint64
func (*QueryInferencesToScoreRequest) ProtoMessage ¶
func (*QueryInferencesToScoreRequest) ProtoMessage()
func (*QueryInferencesToScoreRequest) ProtoReflect ¶
func (x *QueryInferencesToScoreRequest) ProtoReflect() protoreflect.Message
func (*QueryInferencesToScoreRequest) Reset ¶
func (x *QueryInferencesToScoreRequest) Reset()
func (*QueryInferencesToScoreRequest) String ¶
func (x *QueryInferencesToScoreRequest) String() string
type QueryInferencesToScoreResponse ¶
type QueryInferencesToScoreResponse struct { Inferences []*InferenceSetForScoring `protobuf:"bytes,1,rep,name=inferences,proto3" json:"inferences,omitempty"` // contains filtered or unexported fields }
func (*QueryInferencesToScoreResponse) Descriptor
deprecated
func (*QueryInferencesToScoreResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryInferencesToScoreResponse.ProtoReflect.Descriptor instead.
func (*QueryInferencesToScoreResponse) GetInferences ¶
func (x *QueryInferencesToScoreResponse) GetInferences() []*InferenceSetForScoring
func (*QueryInferencesToScoreResponse) ProtoMessage ¶
func (*QueryInferencesToScoreResponse) ProtoMessage()
func (*QueryInferencesToScoreResponse) ProtoReflect ¶
func (x *QueryInferencesToScoreResponse) ProtoReflect() protoreflect.Message
func (*QueryInferencesToScoreResponse) Reset ¶
func (x *QueryInferencesToScoreResponse) Reset()
func (*QueryInferencesToScoreResponse) String ¶
func (x *QueryInferencesToScoreResponse) String() string
type QueryLastRewardsUpdateRequest ¶
type QueryLastRewardsUpdateRequest struct {
// contains filtered or unexported fields
}
returns the last time the rewards inflation calculation ran
func (*QueryLastRewardsUpdateRequest) Descriptor
deprecated
func (*QueryLastRewardsUpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryLastRewardsUpdateRequest.ProtoReflect.Descriptor instead.
func (*QueryLastRewardsUpdateRequest) ProtoMessage ¶
func (*QueryLastRewardsUpdateRequest) ProtoMessage()
func (*QueryLastRewardsUpdateRequest) ProtoReflect ¶
func (x *QueryLastRewardsUpdateRequest) ProtoReflect() protoreflect.Message
func (*QueryLastRewardsUpdateRequest) Reset ¶
func (x *QueryLastRewardsUpdateRequest) Reset()
func (*QueryLastRewardsUpdateRequest) String ¶
func (x *QueryLastRewardsUpdateRequest) String() string
type QueryLastRewardsUpdateResponse ¶
type QueryLastRewardsUpdateResponse struct { LastRewardsUpdate int64 `protobuf:"varint,1,opt,name=last_rewards_update,json=lastRewardsUpdate,proto3" json:"last_rewards_update,omitempty"` // contains filtered or unexported fields }
returns the last time the rewards inflation calculation ran last_rewards_update is an int64 because it is a block number
func (*QueryLastRewardsUpdateResponse) Descriptor
deprecated
func (*QueryLastRewardsUpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryLastRewardsUpdateResponse.ProtoReflect.Descriptor instead.
func (*QueryLastRewardsUpdateResponse) GetLastRewardsUpdate ¶
func (x *QueryLastRewardsUpdateResponse) GetLastRewardsUpdate() int64
func (*QueryLastRewardsUpdateResponse) ProtoMessage ¶
func (*QueryLastRewardsUpdateResponse) ProtoMessage()
func (*QueryLastRewardsUpdateResponse) ProtoReflect ¶
func (x *QueryLastRewardsUpdateResponse) ProtoReflect() protoreflect.Message
func (*QueryLastRewardsUpdateResponse) Reset ¶
func (x *QueryLastRewardsUpdateResponse) Reset()
func (*QueryLastRewardsUpdateResponse) String ¶
func (x *QueryLastRewardsUpdateResponse) String() string
type QueryNextTopicIdRequest ¶
type QueryNextTopicIdRequest struct {
// contains filtered or unexported fields
}
func (*QueryNextTopicIdRequest) Descriptor
deprecated
func (*QueryNextTopicIdRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryNextTopicIdRequest.ProtoReflect.Descriptor instead.
func (*QueryNextTopicIdRequest) ProtoMessage ¶
func (*QueryNextTopicIdRequest) ProtoMessage()
func (*QueryNextTopicIdRequest) ProtoReflect ¶
func (x *QueryNextTopicIdRequest) ProtoReflect() protoreflect.Message
func (*QueryNextTopicIdRequest) Reset ¶
func (x *QueryNextTopicIdRequest) Reset()
func (*QueryNextTopicIdRequest) String ¶
func (x *QueryNextTopicIdRequest) String() string
type QueryNextTopicIdResponse ¶
type QueryNextTopicIdResponse struct { NextTopicId uint64 `protobuf:"varint,1,opt,name=next_topic_id,json=nextTopicId,proto3" json:"next_topic_id,omitempty"` // contains filtered or unexported fields }
func (*QueryNextTopicIdResponse) Descriptor
deprecated
func (*QueryNextTopicIdResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryNextTopicIdResponse.ProtoReflect.Descriptor instead.
func (*QueryNextTopicIdResponse) GetNextTopicId ¶
func (x *QueryNextTopicIdResponse) GetNextTopicId() uint64
func (*QueryNextTopicIdResponse) ProtoMessage ¶
func (*QueryNextTopicIdResponse) ProtoMessage()
func (*QueryNextTopicIdResponse) ProtoReflect ¶
func (x *QueryNextTopicIdResponse) ProtoReflect() protoreflect.Message
func (*QueryNextTopicIdResponse) Reset ¶
func (x *QueryNextTopicIdResponse) Reset()
func (*QueryNextTopicIdResponse) String ¶
func (x *QueryNextTopicIdResponse) String() string
type QueryParamsRequest ¶
type QueryParamsRequest struct {
// contains filtered or unexported fields
}
QueryParamsRequest is the request type for the Query/Params RPC method.
func (*QueryParamsRequest) Descriptor
deprecated
func (*QueryParamsRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryParamsRequest.ProtoReflect.Descriptor instead.
func (*QueryParamsRequest) ProtoMessage ¶
func (*QueryParamsRequest) ProtoMessage()
func (*QueryParamsRequest) ProtoReflect ¶
func (x *QueryParamsRequest) ProtoReflect() protoreflect.Message
func (*QueryParamsRequest) Reset ¶
func (x *QueryParamsRequest) Reset()
func (*QueryParamsRequest) String ¶
func (x *QueryParamsRequest) String() string
type QueryParamsResponse ¶
type QueryParamsResponse struct { // params defines the parameters of the module. Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"` // contains filtered or unexported fields }
QueryParamsResponse is the response type for the Query/Params RPC method.
func (*QueryParamsResponse) Descriptor
deprecated
func (*QueryParamsResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryParamsResponse.ProtoReflect.Descriptor instead.
func (*QueryParamsResponse) GetParams ¶
func (x *QueryParamsResponse) GetParams() *Params
func (*QueryParamsResponse) ProtoMessage ¶
func (*QueryParamsResponse) ProtoMessage()
func (*QueryParamsResponse) ProtoReflect ¶
func (x *QueryParamsResponse) ProtoReflect() protoreflect.Message
func (*QueryParamsResponse) Reset ¶
func (x *QueryParamsResponse) Reset()
func (*QueryParamsResponse) String ¶
func (x *QueryParamsResponse) String() string
type QueryRegisteredTopicIdsRequest ¶ added in v0.0.4
type QueryRegisteredTopicIdsRequest struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` IsReputer bool `protobuf:"varint,2,opt,name=is_reputer,json=isReputer,proto3" json:"is_reputer,omitempty"` // contains filtered or unexported fields }
func (*QueryRegisteredTopicIdsRequest) Descriptor
deprecated
added in
v0.0.4
func (*QueryRegisteredTopicIdsRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRegisteredTopicIdsRequest.ProtoReflect.Descriptor instead.
func (*QueryRegisteredTopicIdsRequest) GetAddress ¶ added in v0.0.4
func (x *QueryRegisteredTopicIdsRequest) GetAddress() string
func (*QueryRegisteredTopicIdsRequest) GetIsReputer ¶ added in v0.0.4
func (x *QueryRegisteredTopicIdsRequest) GetIsReputer() bool
func (*QueryRegisteredTopicIdsRequest) ProtoMessage ¶ added in v0.0.4
func (*QueryRegisteredTopicIdsRequest) ProtoMessage()
func (*QueryRegisteredTopicIdsRequest) ProtoReflect ¶ added in v0.0.4
func (x *QueryRegisteredTopicIdsRequest) ProtoReflect() protoreflect.Message
func (*QueryRegisteredTopicIdsRequest) Reset ¶ added in v0.0.4
func (x *QueryRegisteredTopicIdsRequest) Reset()
func (*QueryRegisteredTopicIdsRequest) String ¶ added in v0.0.4
func (x *QueryRegisteredTopicIdsRequest) String() string
type QueryRegisteredTopicIdsResponse ¶ added in v0.0.4
type QueryRegisteredTopicIdsResponse struct { TopicIds []uint64 `protobuf:"varint,1,rep,packed,name=topic_ids,json=topicIds,proto3" json:"topic_ids,omitempty"` // contains filtered or unexported fields }
func (*QueryRegisteredTopicIdsResponse) Descriptor
deprecated
added in
v0.0.4
func (*QueryRegisteredTopicIdsResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryRegisteredTopicIdsResponse.ProtoReflect.Descriptor instead.
func (*QueryRegisteredTopicIdsResponse) GetTopicIds ¶ added in v0.0.4
func (x *QueryRegisteredTopicIdsResponse) GetTopicIds() []uint64
func (*QueryRegisteredTopicIdsResponse) ProtoMessage ¶ added in v0.0.4
func (*QueryRegisteredTopicIdsResponse) ProtoMessage()
func (*QueryRegisteredTopicIdsResponse) ProtoReflect ¶ added in v0.0.4
func (x *QueryRegisteredTopicIdsResponse) ProtoReflect() protoreflect.Message
func (*QueryRegisteredTopicIdsResponse) Reset ¶ added in v0.0.4
func (x *QueryRegisteredTopicIdsResponse) Reset()
func (*QueryRegisteredTopicIdsResponse) String ¶ added in v0.0.4
func (x *QueryRegisteredTopicIdsResponse) String() string
type QueryRegisteredWorkerNodesRequest ¶
type QueryRegisteredWorkerNodesRequest struct { NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"` // contains filtered or unexported fields }
func (*QueryRegisteredWorkerNodesRequest) Descriptor
deprecated
func (*QueryRegisteredWorkerNodesRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryRegisteredWorkerNodesRequest.ProtoReflect.Descriptor instead.
func (*QueryRegisteredWorkerNodesRequest) GetNodeId ¶
func (x *QueryRegisteredWorkerNodesRequest) GetNodeId() string
func (*QueryRegisteredWorkerNodesRequest) ProtoMessage ¶
func (*QueryRegisteredWorkerNodesRequest) ProtoMessage()
func (*QueryRegisteredWorkerNodesRequest) ProtoReflect ¶
func (x *QueryRegisteredWorkerNodesRequest) ProtoReflect() protoreflect.Message
func (*QueryRegisteredWorkerNodesRequest) Reset ¶
func (x *QueryRegisteredWorkerNodesRequest) Reset()
func (*QueryRegisteredWorkerNodesRequest) String ¶
func (x *QueryRegisteredWorkerNodesRequest) String() string
type QueryRegisteredWorkerNodesResponse ¶
type QueryRegisteredWorkerNodesResponse struct { Nodes []*OffchainNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"` // contains filtered or unexported fields }
func (*QueryRegisteredWorkerNodesResponse) Descriptor
deprecated
func (*QueryRegisteredWorkerNodesResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryRegisteredWorkerNodesResponse.ProtoReflect.Descriptor instead.
func (*QueryRegisteredWorkerNodesResponse) GetNodes ¶
func (x *QueryRegisteredWorkerNodesResponse) GetNodes() []*OffchainNode
func (*QueryRegisteredWorkerNodesResponse) ProtoMessage ¶
func (*QueryRegisteredWorkerNodesResponse) ProtoMessage()
func (*QueryRegisteredWorkerNodesResponse) ProtoReflect ¶
func (x *QueryRegisteredWorkerNodesResponse) ProtoReflect() protoreflect.Message
func (*QueryRegisteredWorkerNodesResponse) Reset ¶
func (x *QueryRegisteredWorkerNodesResponse) Reset()
func (*QueryRegisteredWorkerNodesResponse) String ¶
func (x *QueryRegisteredWorkerNodesResponse) String() string
type QueryServer ¶
type QueryServer interface { // Params returns the module parameters. Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error) GetLastRewardsUpdate(context.Context, *QueryLastRewardsUpdateRequest) (*QueryLastRewardsUpdateResponse, error) GetNextTopicId(context.Context, *QueryNextTopicIdRequest) (*QueryNextTopicIdResponse, error) GetTopic(context.Context, *QueryTopicRequest) (*QueryTopicResponse, error) GetActiveTopics(context.Context, *QueryActiveTopicsRequest) (*QueryActiveTopicsResponse, error) GetAllTopics(context.Context, *QueryAllTopicsRequest) (*QueryAllTopicsResponse, error) GetTopicsByCreator(context.Context, *QueryGetTopicsByCreatorRequest) (*QueryGetTopicsByCreatorResponse, error) GetWeight(context.Context, *QueryWeightRequest) (*QueryWeightResponse, error) GetExistingInferenceRequest(context.Context, *QueryExistingInferenceRequest) (*QueryExistingInferenceResponse, error) GetAllExistingInferenceRequests(context.Context, *QueryAllExistingInferenceRequest) (*QueryAllExistingInferenceResponse, error) GetTopicUnmetDemand(context.Context, *QueryTopicUnmetDemandRequest) (*QueryTopicUnmetDemandResponse, error) GetWorkerLatestInferenceByTopicId(context.Context, *QueryWorkerLatestInferenceRequest) (*QueryWorkerLatestInferenceResponse, error) GetAllInferences(context.Context, *QueryAllInferencesRequest) (*QueryAllInferencesResponse, error) GetInferencesToScore(context.Context, *QueryInferencesToScoreRequest) (*QueryInferencesToScoreResponse, error) GetTotalStake(context.Context, *QueryTotalStakeRequest) (*QueryTotalStakeResponse, error) GetAccountStakeList(context.Context, *QueryAccountStakeListRequest) (*QueryAccountStakeListResponse, error) GetWorkerNodeRegistration(context.Context, *QueryRegisteredWorkerNodesRequest) (*QueryRegisteredWorkerNodesResponse, error) GetWorkerAddressByP2PKey(context.Context, *QueryWorkerAddressByP2PKeyRequest) (*QueryWorkerAddressByP2PKeyResponse, error) GetRegisteredTopicIds(context.Context, *QueryRegisteredTopicIdsRequest) (*QueryRegisteredTopicIdsResponse, error) // contains filtered or unexported methods }
QueryServer is the server API for Query service. All implementations must embed UnimplementedQueryServer for forward compatibility
type QueryTopicRequest ¶
type QueryTopicRequest struct { TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` // contains filtered or unexported fields }
func (*QueryTopicRequest) Descriptor
deprecated
func (*QueryTopicRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryTopicRequest.ProtoReflect.Descriptor instead.
func (*QueryTopicRequest) GetTopicId ¶
func (x *QueryTopicRequest) GetTopicId() uint64
func (*QueryTopicRequest) ProtoMessage ¶
func (*QueryTopicRequest) ProtoMessage()
func (*QueryTopicRequest) ProtoReflect ¶
func (x *QueryTopicRequest) ProtoReflect() protoreflect.Message
func (*QueryTopicRequest) Reset ¶
func (x *QueryTopicRequest) Reset()
func (*QueryTopicRequest) String ¶
func (x *QueryTopicRequest) String() string
type QueryTopicResponse ¶
type QueryTopicResponse struct { Topic *Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"` // contains filtered or unexported fields }
func (*QueryTopicResponse) Descriptor
deprecated
func (*QueryTopicResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryTopicResponse.ProtoReflect.Descriptor instead.
func (*QueryTopicResponse) GetTopic ¶
func (x *QueryTopicResponse) GetTopic() *Topic
func (*QueryTopicResponse) ProtoMessage ¶
func (*QueryTopicResponse) ProtoMessage()
func (*QueryTopicResponse) ProtoReflect ¶
func (x *QueryTopicResponse) ProtoReflect() protoreflect.Message
func (*QueryTopicResponse) Reset ¶
func (x *QueryTopicResponse) Reset()
func (*QueryTopicResponse) String ¶
func (x *QueryTopicResponse) String() string
type QueryTopicUnmetDemandRequest ¶ added in v0.0.4
type QueryTopicUnmetDemandRequest struct { TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` // contains filtered or unexported fields }
func (*QueryTopicUnmetDemandRequest) Descriptor
deprecated
added in
v0.0.4
func (*QueryTopicUnmetDemandRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryTopicUnmetDemandRequest.ProtoReflect.Descriptor instead.
func (*QueryTopicUnmetDemandRequest) GetTopicId ¶ added in v0.0.4
func (x *QueryTopicUnmetDemandRequest) GetTopicId() uint64
func (*QueryTopicUnmetDemandRequest) ProtoMessage ¶ added in v0.0.4
func (*QueryTopicUnmetDemandRequest) ProtoMessage()
func (*QueryTopicUnmetDemandRequest) ProtoReflect ¶ added in v0.0.4
func (x *QueryTopicUnmetDemandRequest) ProtoReflect() protoreflect.Message
func (*QueryTopicUnmetDemandRequest) Reset ¶ added in v0.0.4
func (x *QueryTopicUnmetDemandRequest) Reset()
func (*QueryTopicUnmetDemandRequest) String ¶ added in v0.0.4
func (x *QueryTopicUnmetDemandRequest) String() string
type QueryTopicUnmetDemandResponse ¶ added in v0.0.4
type QueryTopicUnmetDemandResponse struct { DemandLeft string `protobuf:"bytes,1,opt,name=demand_left,json=demandLeft,proto3" json:"demand_left,omitempty"` // contains filtered or unexported fields }
func (*QueryTopicUnmetDemandResponse) Descriptor
deprecated
added in
v0.0.4
func (*QueryTopicUnmetDemandResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryTopicUnmetDemandResponse.ProtoReflect.Descriptor instead.
func (*QueryTopicUnmetDemandResponse) GetDemandLeft ¶ added in v0.0.4
func (x *QueryTopicUnmetDemandResponse) GetDemandLeft() string
func (*QueryTopicUnmetDemandResponse) ProtoMessage ¶ added in v0.0.4
func (*QueryTopicUnmetDemandResponse) ProtoMessage()
func (*QueryTopicUnmetDemandResponse) ProtoReflect ¶ added in v0.0.4
func (x *QueryTopicUnmetDemandResponse) ProtoReflect() protoreflect.Message
func (*QueryTopicUnmetDemandResponse) Reset ¶ added in v0.0.4
func (x *QueryTopicUnmetDemandResponse) Reset()
func (*QueryTopicUnmetDemandResponse) String ¶ added in v0.0.4
func (x *QueryTopicUnmetDemandResponse) String() string
type QueryTotalStakeRequest ¶
type QueryTotalStakeRequest struct {
// contains filtered or unexported fields
}
Total Stake returns the total amount of stake in the system
func (*QueryTotalStakeRequest) Descriptor
deprecated
func (*QueryTotalStakeRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryTotalStakeRequest.ProtoReflect.Descriptor instead.
func (*QueryTotalStakeRequest) ProtoMessage ¶
func (*QueryTotalStakeRequest) ProtoMessage()
func (*QueryTotalStakeRequest) ProtoReflect ¶
func (x *QueryTotalStakeRequest) ProtoReflect() protoreflect.Message
func (*QueryTotalStakeRequest) Reset ¶
func (x *QueryTotalStakeRequest) Reset()
func (*QueryTotalStakeRequest) String ¶
func (x *QueryTotalStakeRequest) String() string
type QueryTotalStakeResponse ¶
type QueryTotalStakeResponse struct { Amount string `protobuf:"bytes,1,opt,name=amount,proto3" json:"amount,omitempty"` // contains filtered or unexported fields }
Total Stake returns the total amount of stake in the system
NOTE: The amount field is a Uint which implements the custom method signatures required by gogoproto.
func (*QueryTotalStakeResponse) Descriptor
deprecated
func (*QueryTotalStakeResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryTotalStakeResponse.ProtoReflect.Descriptor instead.
func (*QueryTotalStakeResponse) GetAmount ¶
func (x *QueryTotalStakeResponse) GetAmount() string
func (*QueryTotalStakeResponse) ProtoMessage ¶
func (*QueryTotalStakeResponse) ProtoMessage()
func (*QueryTotalStakeResponse) ProtoReflect ¶
func (x *QueryTotalStakeResponse) ProtoReflect() protoreflect.Message
func (*QueryTotalStakeResponse) Reset ¶
func (x *QueryTotalStakeResponse) Reset()
func (*QueryTotalStakeResponse) String ¶
func (x *QueryTotalStakeResponse) String() string
type QueryWeightRequest ¶
type QueryWeightRequest struct { TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` Reputer string `protobuf:"bytes,2,opt,name=reputer,proto3" json:"reputer,omitempty"` Worker string `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"` // contains filtered or unexported fields }
Returns the weight assigned by a reputer onto a worker for a given topic
func (*QueryWeightRequest) Descriptor
deprecated
func (*QueryWeightRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryWeightRequest.ProtoReflect.Descriptor instead.
func (*QueryWeightRequest) GetReputer ¶
func (x *QueryWeightRequest) GetReputer() string
func (*QueryWeightRequest) GetTopicId ¶
func (x *QueryWeightRequest) GetTopicId() uint64
func (*QueryWeightRequest) GetWorker ¶
func (x *QueryWeightRequest) GetWorker() string
func (*QueryWeightRequest) ProtoMessage ¶
func (*QueryWeightRequest) ProtoMessage()
func (*QueryWeightRequest) ProtoReflect ¶
func (x *QueryWeightRequest) ProtoReflect() protoreflect.Message
func (*QueryWeightRequest) Reset ¶
func (x *QueryWeightRequest) Reset()
func (*QueryWeightRequest) String ¶
func (x *QueryWeightRequest) String() string
type QueryWeightResponse ¶
type QueryWeightResponse struct { Amount string `protobuf:"bytes,1,opt,name=amount,proto3" json:"amount,omitempty"` // contains filtered or unexported fields }
Returns the weight assigned by a reputer onto a worker for a given topic
NOTE: The amount field is a Uint which implements the custom method signatures required by gogoproto.
func (*QueryWeightResponse) Descriptor
deprecated
func (*QueryWeightResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryWeightResponse.ProtoReflect.Descriptor instead.
func (*QueryWeightResponse) GetAmount ¶
func (x *QueryWeightResponse) GetAmount() string
func (*QueryWeightResponse) ProtoMessage ¶
func (*QueryWeightResponse) ProtoMessage()
func (*QueryWeightResponse) ProtoReflect ¶
func (x *QueryWeightResponse) ProtoReflect() protoreflect.Message
func (*QueryWeightResponse) Reset ¶
func (x *QueryWeightResponse) Reset()
func (*QueryWeightResponse) String ¶
func (x *QueryWeightResponse) String() string
type QueryWorkerAddressByP2PKeyRequest ¶
type QueryWorkerAddressByP2PKeyRequest struct { Libp2PKey string `protobuf:"bytes,1,opt,name=libp2p_key,json=libp2pKey,proto3" json:"libp2p_key,omitempty"` // contains filtered or unexported fields }
func (*QueryWorkerAddressByP2PKeyRequest) Descriptor
deprecated
func (*QueryWorkerAddressByP2PKeyRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryWorkerAddressByP2PKeyRequest.ProtoReflect.Descriptor instead.
func (*QueryWorkerAddressByP2PKeyRequest) GetLibp2PKey ¶
func (x *QueryWorkerAddressByP2PKeyRequest) GetLibp2PKey() string
func (*QueryWorkerAddressByP2PKeyRequest) ProtoMessage ¶
func (*QueryWorkerAddressByP2PKeyRequest) ProtoMessage()
func (*QueryWorkerAddressByP2PKeyRequest) ProtoReflect ¶
func (x *QueryWorkerAddressByP2PKeyRequest) ProtoReflect() protoreflect.Message
func (*QueryWorkerAddressByP2PKeyRequest) Reset ¶
func (x *QueryWorkerAddressByP2PKeyRequest) Reset()
func (*QueryWorkerAddressByP2PKeyRequest) String ¶
func (x *QueryWorkerAddressByP2PKeyRequest) String() string
type QueryWorkerAddressByP2PKeyResponse ¶
type QueryWorkerAddressByP2PKeyResponse struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` // contains filtered or unexported fields }
func (*QueryWorkerAddressByP2PKeyResponse) Descriptor
deprecated
func (*QueryWorkerAddressByP2PKeyResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryWorkerAddressByP2PKeyResponse.ProtoReflect.Descriptor instead.
func (*QueryWorkerAddressByP2PKeyResponse) GetAddress ¶
func (x *QueryWorkerAddressByP2PKeyResponse) GetAddress() string
func (*QueryWorkerAddressByP2PKeyResponse) ProtoMessage ¶
func (*QueryWorkerAddressByP2PKeyResponse) ProtoMessage()
func (*QueryWorkerAddressByP2PKeyResponse) ProtoReflect ¶
func (x *QueryWorkerAddressByP2PKeyResponse) ProtoReflect() protoreflect.Message
func (*QueryWorkerAddressByP2PKeyResponse) Reset ¶
func (x *QueryWorkerAddressByP2PKeyResponse) Reset()
func (*QueryWorkerAddressByP2PKeyResponse) String ¶
func (x *QueryWorkerAddressByP2PKeyResponse) String() string
type QueryWorkerLatestInferenceRequest ¶ added in v0.0.4
type QueryWorkerLatestInferenceRequest struct { TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` WorkerAddress string `protobuf:"bytes,2,opt,name=worker_address,json=workerAddress,proto3" json:"worker_address,omitempty"` // contains filtered or unexported fields }
func (*QueryWorkerLatestInferenceRequest) Descriptor
deprecated
added in
v0.0.4
func (*QueryWorkerLatestInferenceRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryWorkerLatestInferenceRequest.ProtoReflect.Descriptor instead.
func (*QueryWorkerLatestInferenceRequest) GetTopicId ¶ added in v0.0.4
func (x *QueryWorkerLatestInferenceRequest) GetTopicId() uint64
func (*QueryWorkerLatestInferenceRequest) GetWorkerAddress ¶ added in v0.0.4
func (x *QueryWorkerLatestInferenceRequest) GetWorkerAddress() string
func (*QueryWorkerLatestInferenceRequest) ProtoMessage ¶ added in v0.0.4
func (*QueryWorkerLatestInferenceRequest) ProtoMessage()
func (*QueryWorkerLatestInferenceRequest) ProtoReflect ¶ added in v0.0.4
func (x *QueryWorkerLatestInferenceRequest) ProtoReflect() protoreflect.Message
func (*QueryWorkerLatestInferenceRequest) Reset ¶ added in v0.0.4
func (x *QueryWorkerLatestInferenceRequest) Reset()
func (*QueryWorkerLatestInferenceRequest) String ¶ added in v0.0.4
func (x *QueryWorkerLatestInferenceRequest) String() string
type QueryWorkerLatestInferenceResponse ¶ added in v0.0.4
type QueryWorkerLatestInferenceResponse struct { LatestInference *Inference `protobuf:"bytes,1,opt,name=latest_inference,json=latestInference,proto3" json:"latest_inference,omitempty"` // contains filtered or unexported fields }
func (*QueryWorkerLatestInferenceResponse) Descriptor
deprecated
added in
v0.0.4
func (*QueryWorkerLatestInferenceResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryWorkerLatestInferenceResponse.ProtoReflect.Descriptor instead.
func (*QueryWorkerLatestInferenceResponse) GetLatestInference ¶ added in v0.0.4
func (x *QueryWorkerLatestInferenceResponse) GetLatestInference() *Inference
func (*QueryWorkerLatestInferenceResponse) ProtoMessage ¶ added in v0.0.4
func (*QueryWorkerLatestInferenceResponse) ProtoMessage()
func (*QueryWorkerLatestInferenceResponse) ProtoReflect ¶ added in v0.0.4
func (x *QueryWorkerLatestInferenceResponse) ProtoReflect() protoreflect.Message
func (*QueryWorkerLatestInferenceResponse) Reset ¶ added in v0.0.4
func (x *QueryWorkerLatestInferenceResponse) Reset()
func (*QueryWorkerLatestInferenceResponse) String ¶ added in v0.0.4
func (x *QueryWorkerLatestInferenceResponse) String() string
type RequestInferenceListItem ¶
type RequestInferenceListItem struct { Nonce uint64 `protobuf:"varint,1,opt,name=nonce,proto3" json:"nonce,omitempty"` TopicId uint64 `protobuf:"varint,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` Cadence uint64 `protobuf:"varint,3,opt,name=cadence,proto3" json:"cadence,omitempty"` // time in seconds between inferences, zero means oneshot inference MaxPricePerInference string `protobuf:"bytes,4,opt,name=max_price_per_inference,json=maxPricePerInference,proto3" json:"max_price_per_inference,omitempty"` // the maximum price per inference that alice is willing to pay BidAmount string `protobuf:"bytes,5,opt,name=bid_amount,json=bidAmount,proto3" json:"bid_amount,omitempty"` // how many funds to send from alice with this Inference Request TimestampValidUntil uint64 `protobuf:"varint,6,opt,name=timestamp_valid_until,json=timestampValidUntil,proto3" json:"timestamp_valid_until,omitempty"` ExtraData []byte `protobuf:"bytes,7,opt,name=extra_data,json=extraData,proto3" json:"extra_data,omitempty"` // contains filtered or unexported fields }
func (*RequestInferenceListItem) Descriptor
deprecated
func (*RequestInferenceListItem) Descriptor() ([]byte, []int)
Deprecated: Use RequestInferenceListItem.ProtoReflect.Descriptor instead.
func (*RequestInferenceListItem) GetBidAmount ¶
func (x *RequestInferenceListItem) GetBidAmount() string
func (*RequestInferenceListItem) GetCadence ¶
func (x *RequestInferenceListItem) GetCadence() uint64
func (*RequestInferenceListItem) GetExtraData ¶
func (x *RequestInferenceListItem) GetExtraData() []byte
func (*RequestInferenceListItem) GetMaxPricePerInference ¶
func (x *RequestInferenceListItem) GetMaxPricePerInference() string
func (*RequestInferenceListItem) GetNonce ¶
func (x *RequestInferenceListItem) GetNonce() uint64
func (*RequestInferenceListItem) GetTimestampValidUntil ¶
func (x *RequestInferenceListItem) GetTimestampValidUntil() uint64
func (*RequestInferenceListItem) GetTopicId ¶
func (x *RequestInferenceListItem) GetTopicId() uint64
func (*RequestInferenceListItem) ProtoMessage ¶
func (*RequestInferenceListItem) ProtoMessage()
func (*RequestInferenceListItem) ProtoReflect ¶
func (x *RequestInferenceListItem) ProtoReflect() protoreflect.Message
func (*RequestInferenceListItem) Reset ¶
func (x *RequestInferenceListItem) Reset()
func (*RequestInferenceListItem) String ¶
func (x *RequestInferenceListItem) String() string
type StakeInfo ¶
type StakeInfo struct { Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"` Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty"` // contains filtered or unexported fields }
func (*StakeInfo) Descriptor
deprecated
func (*StakeInfo) GetAddress ¶
func (*StakeInfo) ProtoMessage ¶
func (*StakeInfo) ProtoMessage()
func (*StakeInfo) ProtoReflect ¶
func (x *StakeInfo) ProtoReflect() protoreflect.Message
type StakePlacement ¶
type StakePlacement struct { Target string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` Amount string `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty"` // contains filtered or unexported fields }
func (*StakePlacement) Descriptor
deprecated
func (*StakePlacement) Descriptor() ([]byte, []int)
Deprecated: Use StakePlacement.ProtoReflect.Descriptor instead.
func (*StakePlacement) GetAmount ¶
func (x *StakePlacement) GetAmount() string
func (*StakePlacement) GetTarget ¶
func (x *StakePlacement) GetTarget() string
func (*StakePlacement) ProtoMessage ¶
func (*StakePlacement) ProtoMessage()
func (*StakePlacement) ProtoReflect ¶
func (x *StakePlacement) ProtoReflect() protoreflect.Message
func (*StakePlacement) Reset ¶
func (x *StakePlacement) Reset()
func (*StakePlacement) String ¶
func (x *StakePlacement) String() string
type StakeRemoval ¶
type StakeRemoval struct { TimestampRemovalStarted uint64 `` /* 133-byte string literal not displayed */ Placements []*StakeRemovalPlacement `protobuf:"bytes,3,rep,name=placements,proto3" json:"placements,omitempty"` // contains filtered or unexported fields }
func (*StakeRemoval) Descriptor
deprecated
func (*StakeRemoval) Descriptor() ([]byte, []int)
Deprecated: Use StakeRemoval.ProtoReflect.Descriptor instead.
func (*StakeRemoval) GetPlacements ¶
func (x *StakeRemoval) GetPlacements() []*StakeRemovalPlacement
func (*StakeRemoval) GetTimestampRemovalStarted ¶
func (x *StakeRemoval) GetTimestampRemovalStarted() uint64
func (*StakeRemoval) ProtoMessage ¶
func (*StakeRemoval) ProtoMessage()
func (*StakeRemoval) ProtoReflect ¶
func (x *StakeRemoval) ProtoReflect() protoreflect.Message
func (*StakeRemoval) Reset ¶
func (x *StakeRemoval) Reset()
func (*StakeRemoval) String ¶
func (x *StakeRemoval) String() string
type StakeRemovalPlacement ¶
type StakeRemovalPlacement struct { TopicIds []uint64 `protobuf:"varint,1,rep,packed,name=topic_ids,json=topicIds,proto3" json:"topic_ids,omitempty"` Target string `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"` Amount string `protobuf:"bytes,3,opt,name=amount,proto3" json:"amount,omitempty"` // contains filtered or unexported fields }
func (*StakeRemovalPlacement) Descriptor
deprecated
func (*StakeRemovalPlacement) Descriptor() ([]byte, []int)
Deprecated: Use StakeRemovalPlacement.ProtoReflect.Descriptor instead.
func (*StakeRemovalPlacement) GetAmount ¶
func (x *StakeRemovalPlacement) GetAmount() string
func (*StakeRemovalPlacement) GetTarget ¶
func (x *StakeRemovalPlacement) GetTarget() string
func (*StakeRemovalPlacement) GetTopicIds ¶ added in v0.0.4
func (x *StakeRemovalPlacement) GetTopicIds() []uint64
func (*StakeRemovalPlacement) ProtoMessage ¶
func (*StakeRemovalPlacement) ProtoMessage()
func (*StakeRemovalPlacement) ProtoReflect ¶
func (x *StakeRemovalPlacement) ProtoReflect() protoreflect.Message
func (*StakeRemovalPlacement) Reset ¶
func (x *StakeRemovalPlacement) Reset()
func (*StakeRemovalPlacement) String ¶
func (x *StakeRemovalPlacement) String() string
type Topic ¶
type Topic struct { Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"` Creator string `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty"` Metadata string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"` WeightLogic string `protobuf:"bytes,4,opt,name=weight_logic,json=weightLogic,proto3" json:"weight_logic,omitempty"` WeightMethod string `protobuf:"bytes,5,opt,name=weight_method,json=weightMethod,proto3" json:"weight_method,omitempty"` WeightCadence uint64 `protobuf:"varint,6,opt,name=weight_cadence,json=weightCadence,proto3" json:"weight_cadence,omitempty"` WeightLastRan uint64 `protobuf:"varint,7,opt,name=weight_last_ran,json=weightLastRan,proto3" json:"weight_last_ran,omitempty"` InferenceLogic string `protobuf:"bytes,8,opt,name=inference_logic,json=inferenceLogic,proto3" json:"inference_logic,omitempty"` InferenceMethod string `protobuf:"bytes,9,opt,name=inference_method,json=inferenceMethod,proto3" json:"inference_method,omitempty"` InferenceCadence uint64 `protobuf:"varint,10,opt,name=inference_cadence,json=inferenceCadence,proto3" json:"inference_cadence,omitempty"` InferenceLastRan uint64 `protobuf:"varint,11,opt,name=inference_last_ran,json=inferenceLastRan,proto3" json:"inference_last_ran,omitempty"` Active bool `protobuf:"varint,12,opt,name=active,proto3" json:"active,omitempty"` DefaultArg string `protobuf:"bytes,13,opt,name=default_arg,json=defaultArg,proto3" json:"default_arg,omitempty"` // contains filtered or unexported fields }
func (*Topic) Descriptor
deprecated
func (*Topic) GetCreator ¶
func (*Topic) GetDefaultArg ¶
func (*Topic) GetInferenceCadence ¶
func (*Topic) GetInferenceLastRan ¶
func (*Topic) GetInferenceLogic ¶
func (*Topic) GetInferenceMethod ¶
func (*Topic) GetMetadata ¶
func (*Topic) GetWeightCadence ¶
func (*Topic) GetWeightLastRan ¶
func (*Topic) GetWeightLogic ¶
func (*Topic) GetWeightMethod ¶
func (*Topic) ProtoMessage ¶
func (*Topic) ProtoMessage()
func (*Topic) ProtoReflect ¶
func (x *Topic) ProtoReflect() protoreflect.Message
type TopicList ¶ added in v0.0.4
type TopicList struct { Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"` // contains filtered or unexported fields }
func (*TopicList) Descriptor
deprecated
added in
v0.0.4
func (*TopicList) ProtoMessage ¶ added in v0.0.4
func (*TopicList) ProtoMessage()
func (*TopicList) ProtoReflect ¶ added in v0.0.4
func (x *TopicList) ProtoReflect() protoreflect.Message
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct { }
UnimplementedMsgServer must be embedded to have forward compatible implementations.
func (UnimplementedMsgServer) AddNewRegistration ¶
func (UnimplementedMsgServer) AddNewRegistration(context.Context, *MsgAddNewRegistration) (*MsgAddNewRegistrationResponse, error)
func (UnimplementedMsgServer) AddStake ¶
func (UnimplementedMsgServer) AddStake(context.Context, *MsgAddStake) (*MsgAddStakeResponse, error)
func (UnimplementedMsgServer) AddToTopicCreationWhitelist ¶ added in v0.0.1
func (UnimplementedMsgServer) AddToTopicCreationWhitelist(context.Context, *MsgAddToTopicCreationWhitelist) (*MsgAddToTopicCreationWhitelistResponse, error)
func (UnimplementedMsgServer) AddToWeightSettingWhitelist ¶ added in v0.0.1
func (UnimplementedMsgServer) AddToWeightSettingWhitelist(context.Context, *MsgAddToWeightSettingWhitelist) (*MsgAddToWeightSettingWhitelistResponse, error)
func (UnimplementedMsgServer) AddToWhitelistAdmin ¶ added in v0.0.1
func (UnimplementedMsgServer) AddToWhitelistAdmin(context.Context, *MsgAddToWhitelistAdmin) (*MsgAddToWhitelistAdminResponse, error)
func (UnimplementedMsgServer) ConfirmRemoveStake ¶
func (UnimplementedMsgServer) ConfirmRemoveStake(context.Context, *MsgConfirmRemoveStake) (*MsgConfirmRemoveStakeResponse, error)
func (UnimplementedMsgServer) CreateNewTopic ¶
func (UnimplementedMsgServer) CreateNewTopic(context.Context, *MsgCreateNewTopic) (*MsgCreateNewTopicResponse, error)
func (UnimplementedMsgServer) ModifyStake ¶
func (UnimplementedMsgServer) ModifyStake(context.Context, *MsgModifyStake) (*MsgModifyStakeResponse, error)
func (UnimplementedMsgServer) ProcessInferences ¶
func (UnimplementedMsgServer) ProcessInferences(context.Context, *MsgProcessInferences) (*MsgProcessInferencesResponse, error)
func (UnimplementedMsgServer) ReactivateTopic ¶ added in v0.0.1
func (UnimplementedMsgServer) ReactivateTopic(context.Context, *MsgReactivateTopic) (*MsgReactivateTopicResponse, error)
func (UnimplementedMsgServer) Register ¶
func (UnimplementedMsgServer) Register(context.Context, *MsgRegister) (*MsgRegisterResponse, error)
func (UnimplementedMsgServer) RemoveFromTopicCreationWhitelist ¶ added in v0.0.1
func (UnimplementedMsgServer) RemoveFromTopicCreationWhitelist(context.Context, *MsgRemoveFromTopicCreationWhitelist) (*MsgRemoveFromTopicCreationWhitelistResponse, error)
func (UnimplementedMsgServer) RemoveFromWeightSettingWhitelist ¶ added in v0.0.1
func (UnimplementedMsgServer) RemoveFromWeightSettingWhitelist(context.Context, *MsgRemoveFromWeightSettingWhitelist) (*MsgRemoveFromWeightSettingWhitelistResponse, error)
func (UnimplementedMsgServer) RemoveFromWhitelistAdmin ¶ added in v0.0.1
func (UnimplementedMsgServer) RemoveFromWhitelistAdmin(context.Context, *MsgRemoveFromWhitelistAdmin) (*MsgRemoveFromWhitelistAdminResponse, error)
func (UnimplementedMsgServer) RemoveRegistration ¶
func (UnimplementedMsgServer) RemoveRegistration(context.Context, *MsgRemoveRegistration) (*MsgRemoveRegistrationResponse, error)
func (UnimplementedMsgServer) RequestInference ¶
func (UnimplementedMsgServer) RequestInference(context.Context, *MsgRequestInference) (*MsgRequestInferenceResponse, error)
func (UnimplementedMsgServer) SetWeights ¶
func (UnimplementedMsgServer) SetWeights(context.Context, *MsgSetWeights) (*MsgSetWeightsResponse, error)
func (UnimplementedMsgServer) StartRemoveAllStake ¶
func (UnimplementedMsgServer) StartRemoveAllStake(context.Context, *MsgStartRemoveAllStake) (*MsgStartRemoveAllStakeResponse, error)
func (UnimplementedMsgServer) StartRemoveStake ¶
func (UnimplementedMsgServer) StartRemoveStake(context.Context, *MsgStartRemoveStake) (*MsgStartRemoveStakeResponse, error)
func (UnimplementedMsgServer) UpdateParams ¶ added in v0.0.4
func (UnimplementedMsgServer) UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct { }
UnimplementedQueryServer must be embedded to have forward compatible implementations.
func (UnimplementedQueryServer) GetAccountStakeList ¶
func (UnimplementedQueryServer) GetAccountStakeList(context.Context, *QueryAccountStakeListRequest) (*QueryAccountStakeListResponse, error)
func (UnimplementedQueryServer) GetActiveTopics ¶
func (UnimplementedQueryServer) GetActiveTopics(context.Context, *QueryActiveTopicsRequest) (*QueryActiveTopicsResponse, error)
func (UnimplementedQueryServer) GetAllExistingInferenceRequests ¶ added in v0.0.4
func (UnimplementedQueryServer) GetAllExistingInferenceRequests(context.Context, *QueryAllExistingInferenceRequest) (*QueryAllExistingInferenceResponse, error)
func (UnimplementedQueryServer) GetAllInferences ¶
func (UnimplementedQueryServer) GetAllInferences(context.Context, *QueryAllInferencesRequest) (*QueryAllInferencesResponse, error)
func (UnimplementedQueryServer) GetAllTopics ¶ added in v0.0.4
func (UnimplementedQueryServer) GetAllTopics(context.Context, *QueryAllTopicsRequest) (*QueryAllTopicsResponse, error)
func (UnimplementedQueryServer) GetExistingInferenceRequest ¶ added in v0.0.4
func (UnimplementedQueryServer) GetExistingInferenceRequest(context.Context, *QueryExistingInferenceRequest) (*QueryExistingInferenceResponse, error)
func (UnimplementedQueryServer) GetInferencesToScore ¶
func (UnimplementedQueryServer) GetInferencesToScore(context.Context, *QueryInferencesToScoreRequest) (*QueryInferencesToScoreResponse, error)
func (UnimplementedQueryServer) GetLastRewardsUpdate ¶
func (UnimplementedQueryServer) GetLastRewardsUpdate(context.Context, *QueryLastRewardsUpdateRequest) (*QueryLastRewardsUpdateResponse, error)
func (UnimplementedQueryServer) GetNextTopicId ¶
func (UnimplementedQueryServer) GetNextTopicId(context.Context, *QueryNextTopicIdRequest) (*QueryNextTopicIdResponse, error)
func (UnimplementedQueryServer) GetRegisteredTopicIds ¶ added in v0.0.4
func (UnimplementedQueryServer) GetRegisteredTopicIds(context.Context, *QueryRegisteredTopicIdsRequest) (*QueryRegisteredTopicIdsResponse, error)
func (UnimplementedQueryServer) GetTopic ¶
func (UnimplementedQueryServer) GetTopic(context.Context, *QueryTopicRequest) (*QueryTopicResponse, error)
func (UnimplementedQueryServer) GetTopicUnmetDemand ¶ added in v0.0.4
func (UnimplementedQueryServer) GetTopicUnmetDemand(context.Context, *QueryTopicUnmetDemandRequest) (*QueryTopicUnmetDemandResponse, error)
func (UnimplementedQueryServer) GetTopicsByCreator ¶
func (UnimplementedQueryServer) GetTopicsByCreator(context.Context, *QueryGetTopicsByCreatorRequest) (*QueryGetTopicsByCreatorResponse, error)
func (UnimplementedQueryServer) GetTotalStake ¶
func (UnimplementedQueryServer) GetTotalStake(context.Context, *QueryTotalStakeRequest) (*QueryTotalStakeResponse, error)
func (UnimplementedQueryServer) GetWeight ¶
func (UnimplementedQueryServer) GetWeight(context.Context, *QueryWeightRequest) (*QueryWeightResponse, error)
func (UnimplementedQueryServer) GetWorkerAddressByP2PKey ¶
func (UnimplementedQueryServer) GetWorkerAddressByP2PKey(context.Context, *QueryWorkerAddressByP2PKeyRequest) (*QueryWorkerAddressByP2PKeyResponse, error)
func (UnimplementedQueryServer) GetWorkerLatestInferenceByTopicId ¶ added in v0.0.4
func (UnimplementedQueryServer) GetWorkerLatestInferenceByTopicId(context.Context, *QueryWorkerLatestInferenceRequest) (*QueryWorkerLatestInferenceResponse, error)
func (UnimplementedQueryServer) GetWorkerNodeRegistration ¶
func (UnimplementedQueryServer) GetWorkerNodeRegistration(context.Context, *QueryRegisteredWorkerNodesRequest) (*QueryRegisteredWorkerNodesResponse, error)
func (UnimplementedQueryServer) Params ¶
func (UnimplementedQueryServer) Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
type UnsafeMsgServer ¶
type UnsafeMsgServer interface {
// contains filtered or unexported methods
}
UnsafeMsgServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MsgServer will result in compilation errors.
type UnsafeQueryServer ¶
type UnsafeQueryServer interface {
// contains filtered or unexported methods
}
UnsafeQueryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServer will result in compilation errors.
type Weight ¶
type Weight struct { TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"` Reputer string `protobuf:"bytes,2,opt,name=reputer,proto3" json:"reputer,omitempty"` Worker string `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"` Weight string `protobuf:"bytes,4,opt,name=weight,proto3" json:"weight,omitempty"` // contains filtered or unexported fields }
func (*Weight) Descriptor
deprecated
func (*Weight) GetReputer ¶
func (*Weight) GetTopicId ¶
func (*Weight) ProtoMessage ¶
func (*Weight) ProtoMessage()
func (*Weight) ProtoReflect ¶
func (x *Weight) ProtoReflect() protoreflect.Message
type Weights ¶
type Weights struct { Weights []*Weight `protobuf:"bytes,1,rep,name=weights,proto3" json:"weights,omitempty"` // contains filtered or unexported fields }
func (*Weights) Descriptor
deprecated
func (*Weights) GetWeights ¶
func (*Weights) ProtoMessage ¶
func (*Weights) ProtoMessage()
func (*Weights) ProtoReflect ¶
func (x *Weights) ProtoReflect() protoreflect.Message