statev1

package
v0.0.3 Latest Latest
Warning

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

Go to latest
Published: Feb 26, 2024 License: Apache-2.0 Imports: 19 Imported by: 0

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

View Source
const (
	Query_Params_FullMethodName                     = "/emissions.state.v1.Query/Params"
	Query_GetLastRewardsUpdate_FullMethodName       = "/emissions.state.v1.Query/GetLastRewardsUpdate"
	Query_GetAccumulatedEpochRewards_FullMethodName = "/emissions.state.v1.Query/GetAccumulatedEpochRewards"
	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_GetTopicsByCreator_FullMethodName         = "/emissions.state.v1.Query/GetTopicsByCreator"
	Query_GetWeight_FullMethodName                  = "/emissions.state.v1.Query/GetWeight"
	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_GetRegisteredTopicsIds_FullMethodName     = "/emissions.state.v1.Query/GetRegisteredTopicsIds"
)
View Source
const (
	Msg_SetInferences_FullMethodName                    = "/emissions.state.v1.Msg/SetInferences"
	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

View Source
var File_emissions_state_v1_query_proto protoreflect.FileDescriptor
View Source
var File_emissions_state_v1_tx_proto protoreflect.FileDescriptor
View Source
var File_emissions_state_v1_types_proto protoreflect.FileDescriptor
View Source
var Msg_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "emissions.state.v1.Msg",
	HandlerType: (*MsgServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SetInferences",
			Handler:    _Msg_SetInferences_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)

View Source
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: "GetAccumulatedEpochRewards",
			Handler:    _Query_GetAccumulatedEpochRewards_Handler,
		},
		{
			MethodName: "GetNextTopicId",
			Handler:    _Query_GetNextTopicId_Handler,
		},
		{
			MethodName: "GetTopic",
			Handler:    _Query_GetTopic_Handler,
		},
		{
			MethodName: "GetActiveTopics",
			Handler:    _Query_GetActiveTopics_Handler,
		},
		{
			MethodName: "GetTopicsByCreator",
			Handler:    _Query_GetTopicsByCreator_Handler,
		},
		{
			MethodName: "GetWeight",
			Handler:    _Query_GetWeight_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: "GetRegisteredTopicsIds",
			Handler:    _Query_GetRegisteredTopicsIds_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"`
	// 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) 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) Descriptor() ([]byte, []int)

Deprecated: Use Inference.ProtoReflect.Descriptor instead.

func (*Inference) GetExtraData

func (x *Inference) GetExtraData() []byte

func (*Inference) GetProof

func (x *Inference) GetProof() string

func (*Inference) GetTopicId

func (x *Inference) GetTopicId() uint64

func (*Inference) GetValue

func (x *Inference) GetValue() string

func (*Inference) GetWorker

func (x *Inference) GetWorker() string

func (*Inference) ProtoMessage

func (*Inference) ProtoMessage()

func (*Inference) ProtoReflect

func (x *Inference) ProtoReflect() protoreflect.Message

func (*Inference) Reset

func (x *Inference) Reset()

func (*Inference) String

func (x *Inference) String() string

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 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 (*MsgAddNewRegistrationResponse) Reset

func (x *MsgAddNewRegistrationResponse) Reset()

func (*MsgAddNewRegistrationResponse) 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 (*MsgAddToTopicCreationWhitelist) Reset added in v0.0.1

func (x *MsgAddToTopicCreationWhitelist) Reset()

func (*MsgAddToTopicCreationWhitelist) String added in v0.0.1

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) ProtoReflect added in v0.0.1

func (*MsgAddToTopicCreationWhitelistResponse) Reset added in v0.0.1

func (*MsgAddToTopicCreationWhitelistResponse) String added in v0.0.1

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 (*MsgAddToWeightSettingWhitelist) Reset added in v0.0.1

func (x *MsgAddToWeightSettingWhitelist) Reset()

func (*MsgAddToWeightSettingWhitelist) String added in v0.0.1

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) ProtoReflect added in v0.0.1

func (*MsgAddToWeightSettingWhitelistResponse) Reset added in v0.0.1

func (*MsgAddToWeightSettingWhitelistResponse) String added in v0.0.1

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 (*MsgAddToWhitelistAdminResponse) Reset added in v0.0.1

func (x *MsgAddToWhitelistAdminResponse) Reset()

func (*MsgAddToWhitelistAdminResponse) String added in v0.0.1

type MsgClient

type MsgClient interface {
	SetInferences(ctx context.Context, in *MsgSetInferences, opts ...grpc.CallOption) (*MsgSetInferencesResponse, 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 (*MsgConfirmRemoveStakeResponse) Reset

func (x *MsgConfirmRemoveStakeResponse) Reset()

func (*MsgConfirmRemoveStakeResponse) 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 (*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 (*MsgProcessInferencesResponse) Reset

func (x *MsgProcessInferencesResponse) Reset()

func (*MsgProcessInferencesResponse) 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 (*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"`
	TopicsIds    []uint64 `protobuf:"varint,4,rep,packed,name=topics_ids,json=topicsIds,proto3" json:"topics_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) GetTopicsIds

func (x *MsgRegister) GetTopicsIds() []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 (*MsgRemoveFromTopicCreationWhitelist) GetSender added in v0.0.1

func (*MsgRemoveFromTopicCreationWhitelist) ProtoMessage added in v0.0.1

func (*MsgRemoveFromTopicCreationWhitelist) ProtoMessage()

func (*MsgRemoveFromTopicCreationWhitelist) ProtoReflect added in v0.0.1

func (*MsgRemoveFromTopicCreationWhitelist) Reset added in v0.0.1

func (*MsgRemoveFromTopicCreationWhitelist) String added in v0.0.1

type MsgRemoveFromTopicCreationWhitelistResponse added in v0.0.1

type MsgRemoveFromTopicCreationWhitelistResponse struct {
	// contains filtered or unexported fields
}

func (*MsgRemoveFromTopicCreationWhitelistResponse) Descriptor deprecated added in v0.0.1

Deprecated: Use MsgRemoveFromTopicCreationWhitelistResponse.ProtoReflect.Descriptor instead.

func (*MsgRemoveFromTopicCreationWhitelistResponse) ProtoMessage added in v0.0.1

func (*MsgRemoveFromTopicCreationWhitelistResponse) ProtoReflect added in v0.0.1

func (*MsgRemoveFromTopicCreationWhitelistResponse) Reset added in v0.0.1

func (*MsgRemoveFromTopicCreationWhitelistResponse) String added in v0.0.1

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 (*MsgRemoveFromWeightSettingWhitelist) GetSender added in v0.0.1

func (*MsgRemoveFromWeightSettingWhitelist) ProtoMessage added in v0.0.1

func (*MsgRemoveFromWeightSettingWhitelist) ProtoMessage()

func (*MsgRemoveFromWeightSettingWhitelist) ProtoReflect added in v0.0.1

func (*MsgRemoveFromWeightSettingWhitelist) Reset added in v0.0.1

func (*MsgRemoveFromWeightSettingWhitelist) String added in v0.0.1

type MsgRemoveFromWeightSettingWhitelistResponse added in v0.0.1

type MsgRemoveFromWeightSettingWhitelistResponse struct {
	// contains filtered or unexported fields
}

func (*MsgRemoveFromWeightSettingWhitelistResponse) Descriptor deprecated added in v0.0.1

Deprecated: Use MsgRemoveFromWeightSettingWhitelistResponse.ProtoReflect.Descriptor instead.

func (*MsgRemoveFromWeightSettingWhitelistResponse) ProtoMessage added in v0.0.1

func (*MsgRemoveFromWeightSettingWhitelistResponse) ProtoReflect added in v0.0.1

func (*MsgRemoveFromWeightSettingWhitelistResponse) Reset added in v0.0.1

func (*MsgRemoveFromWeightSettingWhitelistResponse) String added in v0.0.1

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 (*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 (*MsgRemoveFromWhitelistAdminResponse) Reset added in v0.0.1

func (*MsgRemoveFromWhitelistAdminResponse) String added in v0.0.1

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 (*MsgRemoveRegistrationResponse) Reset

func (x *MsgRemoveRegistrationResponse) Reset()

func (*MsgRemoveRegistrationResponse) 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 (*MsgRequestInferenceResponse) Reset

func (x *MsgRequestInferenceResponse) Reset()

func (*MsgRequestInferenceResponse) String

func (x *MsgRequestInferenceResponse) String() string

type MsgServer

type MsgServer interface {
	SetInferences(context.Context, *MsgSetInferences) (*MsgSetInferencesResponse, 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 MsgSetInferences

type MsgSetInferences 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
}

MsgSetInferences sets the inferences for a given validator.

func (*MsgSetInferences) Descriptor deprecated

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

Deprecated: Use MsgSetInferences.ProtoReflect.Descriptor instead.

func (*MsgSetInferences) GetInferences

func (x *MsgSetInferences) GetInferences() []*Inference

func (*MsgSetInferences) GetSender

func (x *MsgSetInferences) GetSender() string

func (*MsgSetInferences) ProtoMessage

func (*MsgSetInferences) ProtoMessage()

func (*MsgSetInferences) ProtoReflect

func (x *MsgSetInferences) ProtoReflect() protoreflect.Message

func (*MsgSetInferences) Reset

func (x *MsgSetInferences) Reset()

func (*MsgSetInferences) String

func (x *MsgSetInferences) String() string

type MsgSetInferencesResponse

type MsgSetInferencesResponse struct {
	// contains filtered or unexported fields
}

func (*MsgSetInferencesResponse) Descriptor deprecated

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

Deprecated: Use MsgSetInferencesResponse.ProtoReflect.Descriptor instead.

func (*MsgSetInferencesResponse) ProtoMessage

func (*MsgSetInferencesResponse) ProtoMessage()

func (*MsgSetInferencesResponse) ProtoReflect

func (x *MsgSetInferencesResponse) ProtoReflect() protoreflect.Message

func (*MsgSetInferencesResponse) Reset

func (x *MsgSetInferencesResponse) Reset()

func (*MsgSetInferencesResponse) String

func (x *MsgSetInferencesResponse) String() string

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 (*MsgStartRemoveAllStakeResponse) Reset

func (x *MsgStartRemoveAllStakeResponse) Reset()

func (*MsgStartRemoveAllStakeResponse) 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 (*MsgStartRemoveStakeResponse) Reset

func (x *MsgStartRemoveStakeResponse) Reset()

func (*MsgStartRemoveStakeResponse) String

func (x *MsgStartRemoveStakeResponse) 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 Params

type Params struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Params defines the parameters of the module.

func (*Params) Descriptor deprecated

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

Deprecated: Use Params.ProtoReflect.Descriptor instead.

func (*Params) GetVersion

func (x *Params) GetVersion() string

func (*Params) ProtoMessage

func (*Params) ProtoMessage()

func (*Params) ProtoReflect

func (x *Params) ProtoReflect() protoreflect.Message

func (*Params) Reset

func (x *Params) Reset()

func (*Params) String

func (x *Params) String() string

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 (*QueryAccountStakeListRequest) Reset

func (x *QueryAccountStakeListRequest) Reset()

func (*QueryAccountStakeListRequest) 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 (*QueryAccountStakeListResponse) Reset

func (x *QueryAccountStakeListResponse) Reset()

func (*QueryAccountStakeListResponse) String

type QueryAccumulatedEpochRewardsRequest

type QueryAccumulatedEpochRewardsRequest struct {
	// contains filtered or unexported fields
}

Query the amount of rewards accumulated during this epoch

func (*QueryAccumulatedEpochRewardsRequest) Descriptor deprecated

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

Deprecated: Use QueryAccumulatedEpochRewardsRequest.ProtoReflect.Descriptor instead.

func (*QueryAccumulatedEpochRewardsRequest) ProtoMessage

func (*QueryAccumulatedEpochRewardsRequest) ProtoMessage()

func (*QueryAccumulatedEpochRewardsRequest) ProtoReflect

func (*QueryAccumulatedEpochRewardsRequest) Reset

func (*QueryAccumulatedEpochRewardsRequest) String

type QueryAccumulatedEpochRewardsResponse

type QueryAccumulatedEpochRewardsResponse struct {
	Amount string `protobuf:"bytes,1,opt,name=amount,proto3" json:"amount,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryAccumulatedEpochRewardsResponse) Descriptor deprecated

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

Deprecated: Use QueryAccumulatedEpochRewardsResponse.ProtoReflect.Descriptor instead.

func (*QueryAccumulatedEpochRewardsResponse) GetAmount

func (*QueryAccumulatedEpochRewardsResponse) ProtoMessage

func (*QueryAccumulatedEpochRewardsResponse) ProtoMessage()

func (*QueryAccumulatedEpochRewardsResponse) ProtoReflect

func (*QueryAccumulatedEpochRewardsResponse) Reset

func (*QueryAccumulatedEpochRewardsResponse) 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 (*QueryActiveTopicsResponse) Reset

func (x *QueryActiveTopicsResponse) Reset()

func (*QueryActiveTopicsResponse) String

func (x *QueryActiveTopicsResponse) 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)
	GetAccumulatedEpochRewards(ctx context.Context, in *QueryAccumulatedEpochRewardsRequest, opts ...grpc.CallOption) (*QueryAccumulatedEpochRewardsResponse, 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)
	GetTopicsByCreator(ctx context.Context, in *QueryGetTopicsByCreatorRequest, opts ...grpc.CallOption) (*QueryGetTopicsByCreatorResponse, error)
	GetWeight(ctx context.Context, in *QueryWeightRequest, opts ...grpc.CallOption) (*QueryWeightResponse, error)
	GetAllInferences(ctx context.Context, in *QueryInferenceRequest, opts ...grpc.CallOption) (*QueryInferenceResponse, 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)
	GetRegisteredTopicsIds(ctx context.Context, in *QueryRegisteredTopicsIdsRequest, opts ...grpc.CallOption) (*QueryRegisteredTopicsIdsResponse, 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 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 (*QueryGetTopicsByCreatorRequest) Reset

func (x *QueryGetTopicsByCreatorRequest) Reset()

func (*QueryGetTopicsByCreatorRequest) 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 (*QueryGetTopicsByCreatorResponse) Reset

func (*QueryGetTopicsByCreatorResponse) String

type QueryInferenceRequest

type QueryInferenceRequest 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 (*QueryInferenceRequest) Descriptor deprecated

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

Deprecated: Use QueryInferenceRequest.ProtoReflect.Descriptor instead.

func (*QueryInferenceRequest) GetTimestamp

func (x *QueryInferenceRequest) GetTimestamp() uint64

func (*QueryInferenceRequest) GetTopicId

func (x *QueryInferenceRequest) GetTopicId() uint64

func (*QueryInferenceRequest) ProtoMessage

func (*QueryInferenceRequest) ProtoMessage()

func (*QueryInferenceRequest) ProtoReflect

func (x *QueryInferenceRequest) ProtoReflect() protoreflect.Message

func (*QueryInferenceRequest) Reset

func (x *QueryInferenceRequest) Reset()

func (*QueryInferenceRequest) String

func (x *QueryInferenceRequest) String() string

type QueryInferenceResponse

type QueryInferenceResponse 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 (*QueryInferenceResponse) Descriptor deprecated

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

Deprecated: Use QueryInferenceResponse.ProtoReflect.Descriptor instead.

func (*QueryInferenceResponse) GetInferences

func (x *QueryInferenceResponse) GetInferences() *Inferences

func (*QueryInferenceResponse) ProtoMessage

func (*QueryInferenceResponse) ProtoMessage()

func (*QueryInferenceResponse) ProtoReflect

func (x *QueryInferenceResponse) ProtoReflect() protoreflect.Message

func (*QueryInferenceResponse) Reset

func (x *QueryInferenceResponse) Reset()

func (*QueryInferenceResponse) String

func (x *QueryInferenceResponse) 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 (*QueryInferencesToScoreRequest) Reset

func (x *QueryInferencesToScoreRequest) Reset()

func (*QueryInferencesToScoreRequest) 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 (*QueryInferencesToScoreResponse) ProtoMessage

func (*QueryInferencesToScoreResponse) ProtoMessage()

func (*QueryInferencesToScoreResponse) ProtoReflect

func (*QueryInferencesToScoreResponse) Reset

func (x *QueryInferencesToScoreResponse) Reset()

func (*QueryInferencesToScoreResponse) 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 (*QueryLastRewardsUpdateRequest) Reset

func (x *QueryLastRewardsUpdateRequest) Reset()

func (*QueryLastRewardsUpdateRequest) 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 (*QueryLastRewardsUpdateResponse) Reset

func (x *QueryLastRewardsUpdateResponse) Reset()

func (*QueryLastRewardsUpdateResponse) 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 QueryRegisteredTopicsIdsRequest

type QueryRegisteredTopicsIdsRequest 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 (*QueryRegisteredTopicsIdsRequest) Descriptor deprecated

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

Deprecated: Use QueryRegisteredTopicsIdsRequest.ProtoReflect.Descriptor instead.

func (*QueryRegisteredTopicsIdsRequest) GetAddress

func (x *QueryRegisteredTopicsIdsRequest) GetAddress() string

func (*QueryRegisteredTopicsIdsRequest) GetIsReputer

func (x *QueryRegisteredTopicsIdsRequest) GetIsReputer() bool

func (*QueryRegisteredTopicsIdsRequest) ProtoMessage

func (*QueryRegisteredTopicsIdsRequest) ProtoMessage()

func (*QueryRegisteredTopicsIdsRequest) ProtoReflect

func (*QueryRegisteredTopicsIdsRequest) Reset

func (*QueryRegisteredTopicsIdsRequest) String

type QueryRegisteredTopicsIdsResponse

type QueryRegisteredTopicsIdsResponse struct {
	TopicsIds []uint64 `protobuf:"varint,1,rep,packed,name=topics_ids,json=topicsIds,proto3" json:"topics_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRegisteredTopicsIdsResponse) Descriptor deprecated

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

Deprecated: Use QueryRegisteredTopicsIdsResponse.ProtoReflect.Descriptor instead.

func (*QueryRegisteredTopicsIdsResponse) GetTopicsIds

func (x *QueryRegisteredTopicsIdsResponse) GetTopicsIds() []uint64

func (*QueryRegisteredTopicsIdsResponse) ProtoMessage

func (*QueryRegisteredTopicsIdsResponse) ProtoMessage()

func (*QueryRegisteredTopicsIdsResponse) ProtoReflect

func (*QueryRegisteredTopicsIdsResponse) Reset

func (*QueryRegisteredTopicsIdsResponse) String

type QueryRegisteredWorkerNodesRequest

type QueryRegisteredWorkerNodesRequest struct {
	NodeId string `protobuf:"bytes,2,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 (*QueryRegisteredWorkerNodesRequest) ProtoMessage

func (*QueryRegisteredWorkerNodesRequest) ProtoMessage()

func (*QueryRegisteredWorkerNodesRequest) ProtoReflect

func (*QueryRegisteredWorkerNodesRequest) Reset

func (*QueryRegisteredWorkerNodesRequest) 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 (*QueryRegisteredWorkerNodesResponse) ProtoMessage

func (*QueryRegisteredWorkerNodesResponse) ProtoMessage()

func (*QueryRegisteredWorkerNodesResponse) ProtoReflect

func (*QueryRegisteredWorkerNodesResponse) Reset

func (*QueryRegisteredWorkerNodesResponse) String

type QueryServer

type QueryServer interface {
	// Params returns the module parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	GetLastRewardsUpdate(context.Context, *QueryLastRewardsUpdateRequest) (*QueryLastRewardsUpdateResponse, error)
	GetAccumulatedEpochRewards(context.Context, *QueryAccumulatedEpochRewardsRequest) (*QueryAccumulatedEpochRewardsResponse, error)
	GetNextTopicId(context.Context, *QueryNextTopicIdRequest) (*QueryNextTopicIdResponse, error)
	GetTopic(context.Context, *QueryTopicRequest) (*QueryTopicResponse, error)
	GetActiveTopics(context.Context, *QueryActiveTopicsRequest) (*QueryActiveTopicsResponse, error)
	GetTopicsByCreator(context.Context, *QueryGetTopicsByCreatorRequest) (*QueryGetTopicsByCreatorResponse, error)
	GetWeight(context.Context, *QueryWeightRequest) (*QueryWeightResponse, error)
	GetAllInferences(context.Context, *QueryInferenceRequest) (*QueryInferenceResponse, 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)
	GetRegisteredTopicsIds(context.Context, *QueryRegisteredTopicsIdsRequest) (*QueryRegisteredTopicsIdsResponse, 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 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 (*QueryWorkerAddressByP2PKeyRequest) Reset

func (*QueryWorkerAddressByP2PKeyRequest) 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 (*QueryWorkerAddressByP2PKeyResponse) ProtoMessage

func (*QueryWorkerAddressByP2PKeyResponse) ProtoMessage()

func (*QueryWorkerAddressByP2PKeyResponse) ProtoReflect

func (*QueryWorkerAddressByP2PKeyResponse) Reset

func (*QueryWorkerAddressByP2PKeyResponse) 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) Descriptor() ([]byte, []int)

Deprecated: Use StakeInfo.ProtoReflect.Descriptor instead.

func (*StakeInfo) GetAddress

func (x *StakeInfo) GetAddress() string

func (*StakeInfo) GetAmount

func (x *StakeInfo) GetAmount() string

func (*StakeInfo) ProtoMessage

func (*StakeInfo) ProtoMessage()

func (*StakeInfo) ProtoReflect

func (x *StakeInfo) ProtoReflect() protoreflect.Message

func (*StakeInfo) Reset

func (x *StakeInfo) Reset()

func (*StakeInfo) String

func (x *StakeInfo) String() string

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 {
	TopicsIds []uint64 `protobuf:"varint,1,rep,packed,name=topics_ids,json=topicsIds,proto3" json:"topics_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) GetTopicsIds

func (x *StakeRemovalPlacement) GetTopicsIds() []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) Descriptor() ([]byte, []int)

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetActive

func (x *Topic) GetActive() bool

func (*Topic) GetCreator

func (x *Topic) GetCreator() string

func (*Topic) GetDefaultArg

func (x *Topic) GetDefaultArg() string

func (*Topic) GetId

func (x *Topic) GetId() uint64

func (*Topic) GetInferenceCadence

func (x *Topic) GetInferenceCadence() uint64

func (*Topic) GetInferenceLastRan

func (x *Topic) GetInferenceLastRan() uint64

func (*Topic) GetInferenceLogic

func (x *Topic) GetInferenceLogic() string

func (*Topic) GetInferenceMethod

func (x *Topic) GetInferenceMethod() string

func (*Topic) GetMetadata

func (x *Topic) GetMetadata() string

func (*Topic) GetWeightCadence

func (x *Topic) GetWeightCadence() uint64

func (*Topic) GetWeightLastRan

func (x *Topic) GetWeightLastRan() uint64

func (*Topic) GetWeightLogic

func (x *Topic) GetWeightLogic() string

func (*Topic) GetWeightMethod

func (x *Topic) GetWeightMethod() string

func (*Topic) ProtoMessage

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect

func (x *Topic) ProtoReflect() protoreflect.Message

func (*Topic) Reset

func (x *Topic) Reset()

func (*Topic) String

func (x *Topic) String() string

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer must be embedded to have forward compatible implementations.

func (UnimplementedMsgServer) AddStake

func (UnimplementedMsgServer) AddToTopicCreationWhitelist added in v0.0.1

func (UnimplementedMsgServer) AddToWeightSettingWhitelist added in v0.0.1

func (UnimplementedMsgServer) AddToWhitelistAdmin added in v0.0.1

func (UnimplementedMsgServer) CreateNewTopic

func (UnimplementedMsgServer) ModifyStake

func (UnimplementedMsgServer) ReactivateTopic added in v0.0.1

func (UnimplementedMsgServer) Register

func (UnimplementedMsgServer) RemoveFromTopicCreationWhitelist added in v0.0.1

func (UnimplementedMsgServer) RemoveFromWeightSettingWhitelist added in v0.0.1

func (UnimplementedMsgServer) RemoveFromWhitelistAdmin added in v0.0.1

func (UnimplementedMsgServer) RequestInference

func (UnimplementedMsgServer) SetInferences

func (UnimplementedMsgServer) SetWeights

func (UnimplementedMsgServer) StartRemoveStake

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer must be embedded to have forward compatible implementations.

func (UnimplementedQueryServer) GetAllInferences

func (UnimplementedQueryServer) GetTopic

func (UnimplementedQueryServer) GetTotalStake

func (UnimplementedQueryServer) GetWeight

func (UnimplementedQueryServer) Params

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) Descriptor() ([]byte, []int)

Deprecated: Use Weight.ProtoReflect.Descriptor instead.

func (*Weight) GetReputer

func (x *Weight) GetReputer() string

func (*Weight) GetTopicId

func (x *Weight) GetTopicId() uint64

func (*Weight) GetWeight

func (x *Weight) GetWeight() string

func (*Weight) GetWorker

func (x *Weight) GetWorker() string

func (*Weight) ProtoMessage

func (*Weight) ProtoMessage()

func (*Weight) ProtoReflect

func (x *Weight) ProtoReflect() protoreflect.Message

func (*Weight) Reset

func (x *Weight) Reset()

func (*Weight) String

func (x *Weight) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Weights.ProtoReflect.Descriptor instead.

func (*Weights) GetWeights

func (x *Weights) GetWeights() []*Weight

func (*Weights) ProtoMessage

func (*Weights) ProtoMessage()

func (*Weights) ProtoReflect

func (x *Weights) ProtoReflect() protoreflect.Message

func (*Weights) Reset

func (x *Weights) Reset()

func (*Weights) String

func (x *Weights) String() string

Jump to

Keyboard shortcuts

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