emissions

package
v0.0.10 Latest Latest
Warning

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

 Go to latest Published: Apr 1, 2024 License: Apache-2.0 Imports: 31 Imported by: 1

README

Emissions Module

Dependencies

golang v1.21+ GNU make docker

Build

# get deps
go mod tidy

# rebuild the autogenerated protobuf files
make proto-gen

# build the module, making sure the source compiles
make

Then somewhere else you have a minimal-chain running:

cd ../minimal-chain
go mod tidy
make install
make init
minid start

Documentation

Overview

Package emissions is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const AlloraRequestsAccountName = "allorarequests"
View Source 
const AlloraRewardsAccountName = "allorarewards"
View Source 
const AlloraStakingAccountName = "allorastaking"
View Source 
const ModuleName = "emissions"

Variables

View Source 
var (
	ErrIntegerUnderflowDelegator                         = errors.Register(ModuleName, 1, "integer underflow for delegator")
	ErrIntegerUnderflowBonds                             = errors.Register(ModuleName, 2, "integer underflow for bonds")
	ErrIntegerUnderflowTarget                            = errors.Register(ModuleName, 3, "integer underflow for target")
	ErrIntegerUnderflowTopicStake                        = errors.Register(ModuleName, 4, "integer underflow for topic stake")
	ErrIntegerUnderflowTotalStake                        = errors.Register(ModuleName, 5, "integer underflow for total stake")
	ErrIterationLengthDoesNotMatch                       = errors.Register(ModuleName, 6, "iteration length does not match")
	ErrInvalidTopicId                                    = errors.Register(ModuleName, 7, "invalid topic ID")
	ErrReputerAlreadyRegisteredInTopic                   = errors.Register(ModuleName, 8, "reputer already registered in topic")
	ErrWorkerAlreadyRegisteredInTopic                    = errors.Register(ModuleName, 9, "worker already registered in topic")
	ErrAddressAlreadyRegisteredInATopic                  = errors.Register(ModuleName, 10, "address already registered in a topic")
	ErrAddressIsNotRegisteredInAnyTopic                  = errors.Register(ModuleName, 11, "address is not registered in any topic")
	ErrAddressIsNotRegisteredInThisTopic                 = errors.Register(ModuleName, 12, "address is not registered in this topic")
	ErrInsufficientStakeToRegister                       = errors.Register(ModuleName, 13, "insufficient stake to register")
	ErrLibP2PKeyRequired                                 = errors.Register(ModuleName, 14, "libp2p key required")
	ErrAddressNotRegistered                              = errors.Register(ModuleName, 15, "address not registered")
	ErrStakeTargetNotRegistered                          = errors.Register(ModuleName, 16, "stake target not registered")
	ErrTopicIdOfStakerAndTargetDoNotMatch                = errors.Register(ModuleName, 17, "topic ID of staker and target do not match")
	ErrInsufficientStakeToRemove                         = errors.Register(ModuleName, 18, "insufficient stake to remove")
	ErrNoStakeToRemove                                   = errors.Register(ModuleName, 19, "no stake to remove")
	ErrDoNotSetMapValueToZero                            = errors.Register(ModuleName, 20, "do not set map value to zero")
	ErrBlockHeightNegative                               = errors.Register(ModuleName, 21, "block height negative")
	ErrBlockHeightLessThanPrevious                       = errors.Register(ModuleName, 22, "block height less than previous")
	ErrModifyStakeBeforeBondLessThanAmountModified       = errors.Register(ModuleName, 23, "modify stake before bond less than amount modified")
	ErrModifyStakeBeforeSumGreaterThanSenderStake        = errors.Register(ModuleName, 24, "modify stake before sum greater than sender stake")
	ErrModifyStakeSumBeforeNotEqualToSumAfter            = errors.Register(ModuleName, 25, "modify stake sum before not equal to sum after")
	ErrConfirmRemoveStakeNoRemovalStarted                = errors.Register(ModuleName, 26, "confirm remove stake no removal started")
	ErrConfirmRemoveStakeTooEarly                        = errors.Register(ModuleName, 27, "confirm remove stake too early")
	ErrConfirmRemoveStakeTooLate                         = errors.Register(ModuleName, 28, "confirm remove stake too late")
	ErrScalarMultiplyNegative                            = errors.Register(ModuleName, 29, "scalar multiply negative")
	ErrDivideMapValuesByZero                             = errors.Register(ModuleName, 30, "divide map values by zero")
	ErrTopicIdListValueDecodeInvalidLength               = errors.Register(ModuleName, 31, "topic ID list value decode invalid length")
	ErrTopicIdListValueDecodeJsonInvalidLength           = errors.Register(ModuleName, 32, "topic ID list value decode JSON invalid length")
	ErrTopicIdListValueDecodeJsonInvalidFormat           = errors.Register(ModuleName, 33, "topic ID list value decode JSON invalid format")
	ErrTopicDoesNotExist                                 = errors.Register(ModuleName, 34, "topic does not exist")
	ErrCannotRemoveMoreStakeThanStakedInTopic            = errors.Register(ModuleName, 35, "cannot remove more stake than staked in topic")
	ErrInferenceRequestAlreadyInMempool                  = errors.Register(ModuleName, 36, "inference request already in mempool")
	ErrInferenceRequestBidAmountLessThanPrice            = errors.Register(ModuleName, 37, "inference request bid amount less than price")
	ErrInferenceRequestTimestampValidUntilInPast         = errors.Register(ModuleName, 38, "inference request timestamp valid until in past")
	ErrInferenceRequestTimestampValidUntilTooFarInFuture = errors.Register(ModuleName, 39, "inference request timestamp valid until too far in future")
	ErrInferenceRequestCadenceTooFast                    = errors.Register(ModuleName, 40, "inference request cadence too fast")
	ErrInferenceRequestCadenceTooSlow                    = errors.Register(ModuleName, 41, "inference request cadence too slow")
	ErrInferenceRequestWillNeverBeScheduled              = errors.Register(ModuleName, 42, "inference request will never be scheduled")
	ErrOwnerCannotBeEmpty                                = errors.Register(ModuleName, 43, "owner cannot be empty")
	ErrInsufficientStakeAfterRemoval                     = errors.Register(ModuleName, 44, "insufficient stake after removal")
	ErrInferenceRequestBidAmountTooLow                   = errors.Register(ModuleName, 45, "inference request bid amount too low")
	ErrIntegerUnderflowUnmetDemand                       = errors.Register(ModuleName, 46, "integer underflow for unmet demand")
	ErrInferenceCadenceBelowMinimum                      = errors.Register(ModuleName, 47, "inference cadence must be at least 60 seconds (1 minute)")
	ErrWeightCadenceBelowMinimum                         = errors.Register(ModuleName, 48, "weight cadence must be at least 10800 seconds (3 hours)")
	ErrNotWhitelistAdmin                                 = errors.Register(ModuleName, 49, "not whitelist admin")
	ErrNotInTopicCreationWhitelist                       = errors.Register(ModuleName, 50, "not in topic creation whitelist")
	ErrNotInWeightSettingWhitelist                       = errors.Register(ModuleName, 51, "not in topic weight setting whitelist")
	ErrTopicNotEnoughDemand                              = errors.Register(ModuleName, 52, "topic not enough demand")
	ErrInvalidRequestId                                  = errors.Register(ModuleName, 53, "invalid request ID")
	ErrInferenceRequestNotInMempool                      = errors.Register(ModuleName, 54, "inference request not in mempool")
)
View Source 
var (
	ParamsKey                     = collections.NewPrefix(0)
	TotalStakeKey                 = collections.NewPrefix(1)
	TopicStakeKey                 = collections.NewPrefix(2)
	LastRewardsUpdateKey          = collections.NewPrefix(3)
	RewardsKey                    = collections.NewPrefix(4)
	NextTopicIdKey                = collections.NewPrefix(5)
	TopicsKey                     = collections.NewPrefix(6)
	TopicWorkersKey               = collections.NewPrefix(7)
	TopicReputersKey              = collections.NewPrefix(8)
	DelegatorStakeKey             = collections.NewPrefix(9)
	BondsKey                      = collections.NewPrefix(10)
	TargetStakeKey                = collections.NewPrefix(11)
	WeightsKey                    = collections.NewPrefix(12)
	InferencesKey                 = collections.NewPrefix(13)
	WorkerNodesKey                = collections.NewPrefix(14)
	ReputerNodesKey               = collections.NewPrefix(15)
	LatestInferencesTsKey         = collections.NewPrefix(16)
	MempoolKey                    = collections.NewPrefix(17)
	RequestUnmetDemandKey         = collections.NewPrefix(18)
	TopicUnmetDemandKey           = collections.NewPrefix(19)
	AllInferencesKey              = collections.NewPrefix(20)
	StakeRemovalQueueKey          = collections.NewPrefix(21)
	AllTopicStakeSumKey           = collections.NewPrefix(22)
	AddressTopicsKey              = collections.NewPrefix(23)
	AccumulatedMetDemandKey       = collections.NewPrefix(24)
	NumInferencesInRewardEpochKey = collections.NewPrefix(25)
	WhitelistAdminsKey            = collections.NewPrefix(26)
	TopicCreationWhitelistKey     = collections.NewPrefix(27)
	WeightSettingWhitelistKey     = collections.NewPrefix(28)
	ChurnReadyTopicsKey           = collections.NewPrefix(30)
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTx        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTx          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTx = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthTypes        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTypes = fmt.Errorf("proto: unexpected end of group")
)

Functions

func DefaultCoreTeamAddresses added in v0.0.4 

func DefaultCoreTeamAddresses() []string

func DefaultParamsEpochLength added in v0.0.4 

func DefaultParamsEpochLength() int64

func DefaultParamsMaxInferenceRequestValidity added in v0.0.4 

func DefaultParamsMaxInferenceRequestValidity() uint64

func DefaultParamsMaxMissingInferencePercent added in v0.0.4 

func DefaultParamsMaxMissingInferencePercent() cosmosMath.LegacyDec

func DefaultParamsMaxRequestCadence added in v0.0.4 

func DefaultParamsMaxRequestCadence() uint64

func DefaultParamsMaxTopicsPerBlock added in v0.0.4 

func DefaultParamsMaxTopicsPerBlock() uint64

func DefaultParamsMinRequestCadence added in v0.0.4 

func DefaultParamsMinRequestCadence() uint64

func DefaultParamsMinRequestUnmetDemand added in v0.0.4 

func DefaultParamsMinRequestUnmetDemand() cosmosMath.Uint

func DefaultParamsMinTopicUnmetDemand added in v0.0.4 

func DefaultParamsMinTopicUnmetDemand() cosmosMath.Uint

func DefaultParamsMinWeightCadence added in v0.0.4 

func DefaultParamsMinWeightCadence() uint64

func DefaultParamsRemoveStakeDelayWindow added in v0.0.4 

func DefaultParamsRemoveStakeDelayWindow() uint64

func DefaultParamsRequiredMinimumStake added in v0.0.4 

func DefaultParamsRequiredMinimumStake() cosmosMath.Uint

func DefaultParamsVersion added in v0.0.4 

func DefaultParamsVersion() string

func IsValidRequestId added in v0.0.4 

func IsValidRequestId(requestId string) bool

func RegisterInterfaces 

func RegisterInterfaces(registry types.InterfaceRegistry)

RegisterInterfaces registers the interfaces types with the interface registry.

func RegisterMsgServer 

func RegisterMsgServer(s grpc1.Server, srv MsgServer)

func RegisterQueryHandler 

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

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

func RegisterQueryHandlerClient 

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

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

func RegisterQueryHandlerFromEndpoint 

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

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

func RegisterQueryHandlerServer 

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

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

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, 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"`
	CoreTeamAddresses []string `protobuf:"bytes,2,rep,name=core_team_addresses,json=coreTeamAddresses,proto3" json:"core_team_addresses,omitempty"`
}

GenesisState is the state that must be provided at genesis.

func NewGenesisState 

func NewGenesisState() *GenesisState

NewGenesisState creates a new genesis state with default values.

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetCoreTeamAddresses added in v0.0.4 

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

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) Validate 

func (gs *GenesisState) Validate() error

Validate performs basic genesis state validation returning an error upon any

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

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     cosmossdk_io_math.Uint `protobuf:"bytes,3,opt,name=value,proto3,customtype=cosmossdk.io/math.Uint" json:"value"`
	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"`
}

func (*Inference) Descriptor 

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

func (*Inference) Equal 

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

func (*Inference) GetExtraData 

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

func (*Inference) GetProof 

func (m *Inference) GetProof() string

func (*Inference) GetTopicId 

func (m *Inference) GetTopicId() uint64

func (*Inference) GetWorker 

func (m *Inference) GetWorker() string

func (*Inference) Marshal 

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

func (*Inference) MarshalTo 

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

func (*Inference) MarshalToSizedBuffer 

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

func (*Inference) ProtoMessage 

func (*Inference) ProtoMessage()

func (*Inference) Reset 

func (m *Inference) Reset()

func (*Inference) Size 

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

func (*Inference) String 

func (m *Inference) String() string

func (*Inference) Unmarshal 

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

func (*Inference) XXX_DiscardUnknown 

func (m *Inference) XXX_DiscardUnknown()

func (*Inference) XXX_Marshal 

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

func (*Inference) XXX_Merge 

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

func (*Inference) XXX_Size 

func (m *Inference) XXX_Size() int

func (*Inference) XXX_Unmarshal 

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

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"`
	MaxPricePerInference cosmossdk_io_math.Uint `` /* 149-byte string literal not displayed */
	BidAmount            cosmossdk_io_math.Uint `protobuf:"bytes,6,opt,name=bid_amount,json=bidAmount,proto3,customtype=cosmossdk.io/math.Uint" json:"bid_amount"`
	LastChecked          uint64                 `protobuf:"varint,7,opt,name=last_checked,json=lastChecked,proto3" json:"last_checked,omitempty"`
	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"`
}

num_inference_possible = bid_amount / max_price_per_inference, length of time this inference repeats for = num_inference_possible * cadence

func CreateNewInferenceRequestFromListItem 

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

Convenience helper function that wraps a RequestInferenceListItem into an InferenceRequest one is passed as the msg in a msg handler, while the other is stored in the state machine

func (*InferenceRequest) Descriptor 

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

func (*InferenceRequest) GetCadence 

func (m *InferenceRequest) GetCadence() uint64

func (*InferenceRequest) GetExtraData 

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

func (*InferenceRequest) GetLastChecked 

func (m *InferenceRequest) GetLastChecked() uint64

func (*InferenceRequest) GetNonce 

func (m *InferenceRequest) GetNonce() uint64

func (*InferenceRequest) GetRequestBytes 

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

func (*InferenceRequest) GetRequestId 

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

a request id is a hash of (sender, nonce, topicId)

func (*InferenceRequest) GetSender 

func (m *InferenceRequest) GetSender() string

func (*InferenceRequest) GetTimestampValidUntil 

func (m *InferenceRequest) GetTimestampValidUntil() uint64

func (*InferenceRequest) GetTopicId 

func (m *InferenceRequest) GetTopicId() uint64

func (*InferenceRequest) Marshal 

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

func (*InferenceRequest) MarshalTo 

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

func (*InferenceRequest) MarshalToSizedBuffer 

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

func (*InferenceRequest) ProtoMessage 

func (*InferenceRequest) ProtoMessage()

func (*InferenceRequest) Reset 

func (m *InferenceRequest) Reset()

func (*InferenceRequest) Size 

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

func (*InferenceRequest) String 

func (m *InferenceRequest) String() string

func (*InferenceRequest) Unmarshal 

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

func (*InferenceRequest) XXX_DiscardUnknown 

func (m *InferenceRequest) XXX_DiscardUnknown()

func (*InferenceRequest) XXX_Marshal 

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

func (*InferenceRequest) XXX_Merge 

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

func (*InferenceRequest) XXX_Size 

func (m *InferenceRequest) XXX_Size() int

func (*InferenceRequest) XXX_Unmarshal 

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

type InferenceRequestAndDemandLeft added in v0.0.4 

type InferenceRequestAndDemandLeft struct {
	InferenceRequest *InferenceRequest      `protobuf:"bytes,1,opt,name=inference_request,json=inferenceRequest,proto3" json:"inference_request,omitempty"`
	DemandLeft       cosmossdk_io_math.Uint `protobuf:"bytes,2,opt,name=demand_left,json=demandLeft,proto3,customtype=cosmossdk.io/math.Uint" json:"demand_left"`
}

func (*InferenceRequestAndDemandLeft) Descriptor added in v0.0.4 

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

func (*InferenceRequestAndDemandLeft) GetInferenceRequest added in v0.0.4 

func (m *InferenceRequestAndDemandLeft) GetInferenceRequest() *InferenceRequest

func (*InferenceRequestAndDemandLeft) Marshal added in v0.0.4 

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

func (*InferenceRequestAndDemandLeft) MarshalTo added in v0.0.4 

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

func (*InferenceRequestAndDemandLeft) MarshalToSizedBuffer added in v0.0.4 

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

func (*InferenceRequestAndDemandLeft) ProtoMessage added in v0.0.4 

func (*InferenceRequestAndDemandLeft) ProtoMessage()

func (*InferenceRequestAndDemandLeft) Reset added in v0.0.4 

func (m *InferenceRequestAndDemandLeft) Reset()

func (*InferenceRequestAndDemandLeft) Size added in v0.0.4 

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

func (*InferenceRequestAndDemandLeft) String added in v0.0.4 

func (m *InferenceRequestAndDemandLeft) String() string

func (*InferenceRequestAndDemandLeft) Unmarshal added in v0.0.4 

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

func (*InferenceRequestAndDemandLeft) XXX_DiscardUnknown added in v0.0.4 

func (m *InferenceRequestAndDemandLeft) XXX_DiscardUnknown()

func (*InferenceRequestAndDemandLeft) XXX_Marshal added in v0.0.4 

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

func (*InferenceRequestAndDemandLeft) XXX_Merge added in v0.0.4 

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

func (*InferenceRequestAndDemandLeft) XXX_Size added in v0.0.4 

func (m *InferenceRequestAndDemandLeft) XXX_Size() int

func (*InferenceRequestAndDemandLeft) XXX_Unmarshal added in v0.0.4 

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

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

func (*InferenceSetForScoring) Descriptor 

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

func (*InferenceSetForScoring) GetInferences 

func (m *InferenceSetForScoring) GetInferences() *Inferences

func (*InferenceSetForScoring) GetTimestamp 

func (m *InferenceSetForScoring) GetTimestamp() uint64

func (*InferenceSetForScoring) GetTopicId 

func (m *InferenceSetForScoring) GetTopicId() uint64

func (*InferenceSetForScoring) Marshal 

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

func (*InferenceSetForScoring) MarshalTo 

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

func (*InferenceSetForScoring) MarshalToSizedBuffer 

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

func (*InferenceSetForScoring) ProtoMessage 

func (*InferenceSetForScoring) ProtoMessage()

func (*InferenceSetForScoring) Reset 

func (m *InferenceSetForScoring) Reset()

func (*InferenceSetForScoring) Size 

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

func (*InferenceSetForScoring) String 

func (m *InferenceSetForScoring) String() string

func (*InferenceSetForScoring) Unmarshal 

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

func (*InferenceSetForScoring) XXX_DiscardUnknown 

func (m *InferenceSetForScoring) XXX_DiscardUnknown()

func (*InferenceSetForScoring) XXX_Marshal 

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

func (*InferenceSetForScoring) XXX_Merge 

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

func (*InferenceSetForScoring) XXX_Size 

func (m *InferenceSetForScoring) XXX_Size() int

func (*InferenceSetForScoring) XXX_Unmarshal 

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

type Inferences 

type Inferences struct {
	Inferences []*Inference `protobuf:"bytes,1,rep,name=inferences,proto3" json:"inferences,omitempty"`
}

func (*Inferences) Descriptor 

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

func (*Inferences) GetInferences 

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

func (*Inferences) Marshal 

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

func (*Inferences) MarshalTo 

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

func (*Inferences) MarshalToSizedBuffer 

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

func (*Inferences) ProtoMessage 

func (*Inferences) ProtoMessage()

func (*Inferences) Reset 

func (m *Inferences) Reset()

func (*Inferences) Size 

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

func (*Inferences) String 

func (m *Inferences) String() string

func (*Inferences) Unmarshal 

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

func (*Inferences) XXX_DiscardUnknown 

func (m *Inferences) XXX_DiscardUnknown()

func (*Inferences) XXX_Marshal 

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

func (*Inferences) XXX_Merge 

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

func (*Inferences) XXX_Size 

func (m *Inferences) XXX_Size() int

func (*Inferences) XXX_Unmarshal 

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

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

func (*MsgAddNewRegistration) Descriptor 

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

func (*MsgAddNewRegistration) GetCreator 

func (m *MsgAddNewRegistration) GetCreator() string

func (*MsgAddNewRegistration) GetIsReputer 

func (m *MsgAddNewRegistration) GetIsReputer() bool

func (*MsgAddNewRegistration) GetLibP2PKey 

func (m *MsgAddNewRegistration) GetLibP2PKey() string

func (*MsgAddNewRegistration) GetMultiAddress 

func (m *MsgAddNewRegistration) GetMultiAddress() string

func (*MsgAddNewRegistration) GetOwner 

func (m *MsgAddNewRegistration) GetOwner() string

func (*MsgAddNewRegistration) GetTopicId 

func (m *MsgAddNewRegistration) GetTopicId() uint64

func (*MsgAddNewRegistration) Marshal 

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

func (*MsgAddNewRegistration) MarshalTo 

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

func (*MsgAddNewRegistration) MarshalToSizedBuffer 

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

func (*MsgAddNewRegistration) ProtoMessage 

func (*MsgAddNewRegistration) ProtoMessage()

func (*MsgAddNewRegistration) Reset 

func (m *MsgAddNewRegistration) Reset()

func (*MsgAddNewRegistration) Size 

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

func (*MsgAddNewRegistration) String 

func (m *MsgAddNewRegistration) String() string

func (*MsgAddNewRegistration) Unmarshal 

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

func (*MsgAddNewRegistration) XXX_DiscardUnknown 

func (m *MsgAddNewRegistration) XXX_DiscardUnknown()

func (*MsgAddNewRegistration) XXX_Marshal 

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

func (*MsgAddNewRegistration) XXX_Merge 

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

func (*MsgAddNewRegistration) XXX_Size 

func (m *MsgAddNewRegistration) XXX_Size() int

func (*MsgAddNewRegistration) XXX_Unmarshal 

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

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

func (*MsgAddNewRegistrationResponse) Descriptor 

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

func (*MsgAddNewRegistrationResponse) GetMessage 

func (m *MsgAddNewRegistrationResponse) GetMessage() string

func (*MsgAddNewRegistrationResponse) GetSuccess 

func (m *MsgAddNewRegistrationResponse) GetSuccess() bool

func (*MsgAddNewRegistrationResponse) Marshal 

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

func (*MsgAddNewRegistrationResponse) MarshalTo 

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

func (*MsgAddNewRegistrationResponse) MarshalToSizedBuffer 

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

func (*MsgAddNewRegistrationResponse) ProtoMessage 

func (*MsgAddNewRegistrationResponse) ProtoMessage()

func (*MsgAddNewRegistrationResponse) Reset 

func (m *MsgAddNewRegistrationResponse) Reset()

func (*MsgAddNewRegistrationResponse) Size 

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

func (*MsgAddNewRegistrationResponse) String 

func (m *MsgAddNewRegistrationResponse) String() string

func (*MsgAddNewRegistrationResponse) Unmarshal 

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

func (*MsgAddNewRegistrationResponse) XXX_DiscardUnknown 

func (m *MsgAddNewRegistrationResponse) XXX_DiscardUnknown()

func (*MsgAddNewRegistrationResponse) XXX_Marshal 

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

func (*MsgAddNewRegistrationResponse) XXX_Merge 

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

func (*MsgAddNewRegistrationResponse) XXX_Size 

func (m *MsgAddNewRegistrationResponse) XXX_Size() int

func (*MsgAddNewRegistrationResponse) XXX_Unmarshal 

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

type MsgAddStake 

type MsgAddStake struct {
	Sender      string                 `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Amount      cosmossdk_io_math.Uint `protobuf:"bytes,2,opt,name=amount,proto3,customtype=cosmossdk.io/math.Uint" json:"amount"`
	StakeTarget string                 `protobuf:"bytes,3,opt,name=stake_target,json=stakeTarget,proto3" json:"stake_target,omitempty"`
}

/ / Staking /

func (*MsgAddStake) Descriptor 

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

func (*MsgAddStake) GetSender 

func (m *MsgAddStake) GetSender() string

func (*MsgAddStake) GetStakeTarget 

func (m *MsgAddStake) GetStakeTarget() string

func (*MsgAddStake) Marshal 

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

func (*MsgAddStake) MarshalTo 

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

func (*MsgAddStake) MarshalToSizedBuffer 

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

func (*MsgAddStake) ProtoMessage 

func (*MsgAddStake) ProtoMessage()

func (*MsgAddStake) Reset 

func (m *MsgAddStake) Reset()

func (*MsgAddStake) Size 

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

func (*MsgAddStake) String 

func (m *MsgAddStake) String() string

func (*MsgAddStake) Unmarshal 

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

func (*MsgAddStake) XXX_DiscardUnknown 

func (m *MsgAddStake) XXX_DiscardUnknown()

func (*MsgAddStake) XXX_Marshal 

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

func (*MsgAddStake) XXX_Merge 

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

func (*MsgAddStake) XXX_Size 

func (m *MsgAddStake) XXX_Size() int

func (*MsgAddStake) XXX_Unmarshal 

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

type MsgAddStakeResponse 

type MsgAddStakeResponse struct {
}

func (*MsgAddStakeResponse) Descriptor 

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

func (*MsgAddStakeResponse) Marshal 

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

func (*MsgAddStakeResponse) MarshalTo 

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

func (*MsgAddStakeResponse) MarshalToSizedBuffer 

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

func (*MsgAddStakeResponse) ProtoMessage 

func (*MsgAddStakeResponse) ProtoMessage()

func (*MsgAddStakeResponse) Reset 

func (m *MsgAddStakeResponse) Reset()

func (*MsgAddStakeResponse) Size 

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

func (*MsgAddStakeResponse) String 

func (m *MsgAddStakeResponse) String() string

func (*MsgAddStakeResponse) Unmarshal 

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

func (*MsgAddStakeResponse) XXX_DiscardUnknown 

func (m *MsgAddStakeResponse) XXX_DiscardUnknown()

func (*MsgAddStakeResponse) XXX_Marshal 

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

func (*MsgAddStakeResponse) XXX_Merge 

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

func (*MsgAddStakeResponse) XXX_Size 

func (m *MsgAddStakeResponse) XXX_Size() int

func (*MsgAddStakeResponse) XXX_Unmarshal 

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

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

func (*MsgAddToTopicCreationWhitelist) Descriptor added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelist) GetAddress added in v0.0.1 

func (m *MsgAddToTopicCreationWhitelist) GetAddress() string

func (*MsgAddToTopicCreationWhitelist) GetSender added in v0.0.1 

func (m *MsgAddToTopicCreationWhitelist) GetSender() string

func (*MsgAddToTopicCreationWhitelist) Marshal added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelist) MarshalTo added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelist) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelist) ProtoMessage added in v0.0.1 

func (*MsgAddToTopicCreationWhitelist) ProtoMessage()

func (*MsgAddToTopicCreationWhitelist) Reset added in v0.0.1 

func (m *MsgAddToTopicCreationWhitelist) Reset()

func (*MsgAddToTopicCreationWhitelist) Size added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelist) String added in v0.0.1 

func (m *MsgAddToTopicCreationWhitelist) String() string

func (*MsgAddToTopicCreationWhitelist) Unmarshal added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelist) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgAddToTopicCreationWhitelist) XXX_DiscardUnknown()

func (*MsgAddToTopicCreationWhitelist) XXX_Marshal added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelist) XXX_Merge added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelist) XXX_Size added in v0.0.1 

func (m *MsgAddToTopicCreationWhitelist) XXX_Size() int

func (*MsgAddToTopicCreationWhitelist) XXX_Unmarshal added in v0.0.1 

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

type MsgAddToTopicCreationWhitelistResponse added in v0.0.1 

type MsgAddToTopicCreationWhitelistResponse struct {
}

func (*MsgAddToTopicCreationWhitelistResponse) Descriptor added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelistResponse) Marshal added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelistResponse) MarshalTo added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelistResponse) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelistResponse) ProtoMessage added in v0.0.1 

func (*MsgAddToTopicCreationWhitelistResponse) ProtoMessage()

func (*MsgAddToTopicCreationWhitelistResponse) Reset added in v0.0.1 

func (m *MsgAddToTopicCreationWhitelistResponse) Reset()

func (*MsgAddToTopicCreationWhitelistResponse) Size added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelistResponse) String added in v0.0.1 

func (m *MsgAddToTopicCreationWhitelistResponse) String() string

func (*MsgAddToTopicCreationWhitelistResponse) Unmarshal added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelistResponse) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgAddToTopicCreationWhitelistResponse) XXX_DiscardUnknown()

func (*MsgAddToTopicCreationWhitelistResponse) XXX_Marshal added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelistResponse) XXX_Merge added in v0.0.1 

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

func (*MsgAddToTopicCreationWhitelistResponse) XXX_Size added in v0.0.1 

func (m *MsgAddToTopicCreationWhitelistResponse) XXX_Size() int

func (*MsgAddToTopicCreationWhitelistResponse) XXX_Unmarshal added in v0.0.1 

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

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

func (*MsgAddToWeightSettingWhitelist) Descriptor added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelist) GetAddress added in v0.0.1 

func (m *MsgAddToWeightSettingWhitelist) GetAddress() string

func (*MsgAddToWeightSettingWhitelist) GetSender added in v0.0.1 

func (m *MsgAddToWeightSettingWhitelist) GetSender() string

func (*MsgAddToWeightSettingWhitelist) Marshal added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelist) MarshalTo added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelist) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelist) ProtoMessage added in v0.0.1 

func (*MsgAddToWeightSettingWhitelist) ProtoMessage()

func (*MsgAddToWeightSettingWhitelist) Reset added in v0.0.1 

func (m *MsgAddToWeightSettingWhitelist) Reset()

func (*MsgAddToWeightSettingWhitelist) Size added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelist) String added in v0.0.1 

func (m *MsgAddToWeightSettingWhitelist) String() string

func (*MsgAddToWeightSettingWhitelist) Unmarshal added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelist) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgAddToWeightSettingWhitelist) XXX_DiscardUnknown()

func (*MsgAddToWeightSettingWhitelist) XXX_Marshal added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelist) XXX_Merge added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelist) XXX_Size added in v0.0.1 

func (m *MsgAddToWeightSettingWhitelist) XXX_Size() int

func (*MsgAddToWeightSettingWhitelist) XXX_Unmarshal added in v0.0.1 

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

type MsgAddToWeightSettingWhitelistResponse added in v0.0.1 

type MsgAddToWeightSettingWhitelistResponse struct {
}

func (*MsgAddToWeightSettingWhitelistResponse) Descriptor added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelistResponse) Marshal added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelistResponse) MarshalTo added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelistResponse) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelistResponse) ProtoMessage added in v0.0.1 

func (*MsgAddToWeightSettingWhitelistResponse) ProtoMessage()

func (*MsgAddToWeightSettingWhitelistResponse) Reset added in v0.0.1 

func (m *MsgAddToWeightSettingWhitelistResponse) Reset()

func (*MsgAddToWeightSettingWhitelistResponse) Size added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelistResponse) String added in v0.0.1 

func (m *MsgAddToWeightSettingWhitelistResponse) String() string

func (*MsgAddToWeightSettingWhitelistResponse) Unmarshal added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelistResponse) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgAddToWeightSettingWhitelistResponse) XXX_DiscardUnknown()

func (*MsgAddToWeightSettingWhitelistResponse) XXX_Marshal added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelistResponse) XXX_Merge added in v0.0.1 

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

func (*MsgAddToWeightSettingWhitelistResponse) XXX_Size added in v0.0.1 

func (m *MsgAddToWeightSettingWhitelistResponse) XXX_Size() int

func (*MsgAddToWeightSettingWhitelistResponse) XXX_Unmarshal added in v0.0.1 

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

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

func (*MsgAddToWhitelistAdmin) Descriptor added in v0.0.1 

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

func (*MsgAddToWhitelistAdmin) GetAddress added in v0.0.1 

func (m *MsgAddToWhitelistAdmin) GetAddress() string

func (*MsgAddToWhitelistAdmin) GetSender added in v0.0.1 

func (m *MsgAddToWhitelistAdmin) GetSender() string

func (*MsgAddToWhitelistAdmin) Marshal added in v0.0.1 

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

func (*MsgAddToWhitelistAdmin) MarshalTo added in v0.0.1 

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

func (*MsgAddToWhitelistAdmin) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgAddToWhitelistAdmin) ProtoMessage added in v0.0.1 

func (*MsgAddToWhitelistAdmin) ProtoMessage()

func (*MsgAddToWhitelistAdmin) Reset added in v0.0.1 

func (m *MsgAddToWhitelistAdmin) Reset()

func (*MsgAddToWhitelistAdmin) Size added in v0.0.1 

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

func (*MsgAddToWhitelistAdmin) String added in v0.0.1 

func (m *MsgAddToWhitelistAdmin) String() string

func (*MsgAddToWhitelistAdmin) Unmarshal added in v0.0.1 

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

func (*MsgAddToWhitelistAdmin) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgAddToWhitelistAdmin) XXX_DiscardUnknown()

func (*MsgAddToWhitelistAdmin) XXX_Marshal added in v0.0.1 

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

func (*MsgAddToWhitelistAdmin) XXX_Merge added in v0.0.1 

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

func (*MsgAddToWhitelistAdmin) XXX_Size added in v0.0.1 

func (m *MsgAddToWhitelistAdmin) XXX_Size() int

func (*MsgAddToWhitelistAdmin) XXX_Unmarshal added in v0.0.1 

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

type MsgAddToWhitelistAdminResponse added in v0.0.1 

type MsgAddToWhitelistAdminResponse struct {
}

func (*MsgAddToWhitelistAdminResponse) Descriptor added in v0.0.1 

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

func (*MsgAddToWhitelistAdminResponse) Marshal added in v0.0.1 

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

func (*MsgAddToWhitelistAdminResponse) MarshalTo added in v0.0.1 

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

func (*MsgAddToWhitelistAdminResponse) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgAddToWhitelistAdminResponse) ProtoMessage added in v0.0.1 

func (*MsgAddToWhitelistAdminResponse) ProtoMessage()

func (*MsgAddToWhitelistAdminResponse) Reset added in v0.0.1 

func (m *MsgAddToWhitelistAdminResponse) Reset()

func (*MsgAddToWhitelistAdminResponse) Size added in v0.0.1 

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

func (*MsgAddToWhitelistAdminResponse) String added in v0.0.1 

func (m *MsgAddToWhitelistAdminResponse) String() string

func (*MsgAddToWhitelistAdminResponse) Unmarshal added in v0.0.1 

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

func (*MsgAddToWhitelistAdminResponse) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgAddToWhitelistAdminResponse) XXX_DiscardUnknown()

func (*MsgAddToWhitelistAdminResponse) XXX_Marshal added in v0.0.1 

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

func (*MsgAddToWhitelistAdminResponse) XXX_Merge added in v0.0.1 

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

func (*MsgAddToWhitelistAdminResponse) XXX_Size added in v0.0.1 

func (m *MsgAddToWhitelistAdminResponse) XXX_Size() int

func (*MsgAddToWhitelistAdminResponse) XXX_Unmarshal added in v0.0.1 

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

type MsgClient 

type MsgClient interface {
	UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
	ProcessInferences(ctx context.Context, in *MsgProcessInferences, opts ...grpc.CallOption) (*MsgProcessInferencesResponse, error)
	SetWeights(ctx context.Context, in *MsgSetWeights, opts ...grpc.CallOption) (*MsgSetWeightsResponse, error)
	CreateNewTopic(ctx context.Context, in *MsgCreateNewTopic, opts ...grpc.CallOption) (*MsgCreateNewTopicResponse, error)
	ReactivateTopic(ctx context.Context, in *MsgReactivateTopic, opts ...grpc.CallOption) (*MsgReactivateTopicResponse, error)
	Register(ctx context.Context, in *MsgRegister, opts ...grpc.CallOption) (*MsgRegisterResponse, error)
	AddNewRegistration(ctx context.Context, in *MsgAddNewRegistration, opts ...grpc.CallOption) (*MsgAddNewRegistrationResponse, error)
	RemoveRegistration(ctx context.Context, in *MsgRemoveRegistration, opts ...grpc.CallOption) (*MsgRemoveRegistrationResponse, error)
	AddStake(ctx context.Context, in *MsgAddStake, opts ...grpc.CallOption) (*MsgAddStakeResponse, error)
	ModifyStake(ctx context.Context, in *MsgModifyStake, opts ...grpc.CallOption) (*MsgModifyStakeResponse, error)
	StartRemoveStake(ctx context.Context, in *MsgStartRemoveStake, opts ...grpc.CallOption) (*MsgStartRemoveStakeResponse, error)
	ConfirmRemoveStake(ctx context.Context, in *MsgConfirmRemoveStake, opts ...grpc.CallOption) (*MsgConfirmRemoveStakeResponse, error)
	StartRemoveAllStake(ctx context.Context, in *MsgStartRemoveAllStake, opts ...grpc.CallOption) (*MsgStartRemoveAllStakeResponse, error)
	RequestInference(ctx context.Context, in *MsgRequestInference, opts ...grpc.CallOption) (*MsgRequestInferenceResponse, error)
	AddToWhitelistAdmin(ctx context.Context, in *MsgAddToWhitelistAdmin, opts ...grpc.CallOption) (*MsgAddToWhitelistAdminResponse, error)
	RemoveFromWhitelistAdmin(ctx context.Context, in *MsgRemoveFromWhitelistAdmin, opts ...grpc.CallOption) (*MsgRemoveFromWhitelistAdminResponse, error)
	AddToTopicCreationWhitelist(ctx context.Context, in *MsgAddToTopicCreationWhitelist, opts ...grpc.CallOption) (*MsgAddToTopicCreationWhitelistResponse, error)
	RemoveFromTopicCreationWhitelist(ctx context.Context, in *MsgRemoveFromTopicCreationWhitelist, opts ...grpc.CallOption) (*MsgRemoveFromTopicCreationWhitelistResponse, error)
	AddToWeightSettingWhitelist(ctx context.Context, in *MsgAddToWeightSettingWhitelist, opts ...grpc.CallOption) (*MsgAddToWeightSettingWhitelistResponse, error)
	RemoveFromWeightSettingWhitelist(ctx context.Context, in *MsgRemoveFromWeightSettingWhitelist, opts ...grpc.CallOption) (*MsgRemoveFromWeightSettingWhitelistResponse, error)
}

MsgClient is the client API for Msg service.

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

func NewMsgClient 

func NewMsgClient(cc grpc1.ClientConn) MsgClient

type MsgConfirmRemoveStake 

type MsgConfirmRemoveStake struct {
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
}

func (*MsgConfirmRemoveStake) Descriptor 

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

func (*MsgConfirmRemoveStake) GetSender 

func (m *MsgConfirmRemoveStake) GetSender() string

func (*MsgConfirmRemoveStake) Marshal 

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

func (*MsgConfirmRemoveStake) MarshalTo 

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

func (*MsgConfirmRemoveStake) MarshalToSizedBuffer 

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

func (*MsgConfirmRemoveStake) ProtoMessage 

func (*MsgConfirmRemoveStake) ProtoMessage()

func (*MsgConfirmRemoveStake) Reset 

func (m *MsgConfirmRemoveStake) Reset()

func (*MsgConfirmRemoveStake) Size 

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

func (*MsgConfirmRemoveStake) String 

func (m *MsgConfirmRemoveStake) String() string

func (*MsgConfirmRemoveStake) Unmarshal 

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

func (*MsgConfirmRemoveStake) XXX_DiscardUnknown 

func (m *MsgConfirmRemoveStake) XXX_DiscardUnknown()

func (*MsgConfirmRemoveStake) XXX_Marshal 

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

func (*MsgConfirmRemoveStake) XXX_Merge 

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

func (*MsgConfirmRemoveStake) XXX_Size 

func (m *MsgConfirmRemoveStake) XXX_Size() int

func (*MsgConfirmRemoveStake) XXX_Unmarshal 

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

type MsgConfirmRemoveStakeResponse 

type MsgConfirmRemoveStakeResponse struct {
}

func (*MsgConfirmRemoveStakeResponse) Descriptor 

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

func (*MsgConfirmRemoveStakeResponse) Marshal 

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

func (*MsgConfirmRemoveStakeResponse) MarshalTo 

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

func (*MsgConfirmRemoveStakeResponse) MarshalToSizedBuffer 

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

func (*MsgConfirmRemoveStakeResponse) ProtoMessage 

func (*MsgConfirmRemoveStakeResponse) ProtoMessage()

func (*MsgConfirmRemoveStakeResponse) Reset 

func (m *MsgConfirmRemoveStakeResponse) Reset()

func (*MsgConfirmRemoveStakeResponse) Size 

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

func (*MsgConfirmRemoveStakeResponse) String 

func (m *MsgConfirmRemoveStakeResponse) String() string

func (*MsgConfirmRemoveStakeResponse) Unmarshal 

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

func (*MsgConfirmRemoveStakeResponse) XXX_DiscardUnknown 

func (m *MsgConfirmRemoveStakeResponse) XXX_DiscardUnknown()

func (*MsgConfirmRemoveStakeResponse) XXX_Marshal 

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

func (*MsgConfirmRemoveStakeResponse) XXX_Merge 

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

func (*MsgConfirmRemoveStakeResponse) XXX_Size 

func (m *MsgConfirmRemoveStakeResponse) XXX_Size() int

func (*MsgConfirmRemoveStakeResponse) XXX_Unmarshal 

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

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

func (*MsgCreateNewTopic) Descriptor 

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

func (*MsgCreateNewTopic) GetCreator 

func (m *MsgCreateNewTopic) GetCreator() string

func (*MsgCreateNewTopic) GetDefaultArg 

func (m *MsgCreateNewTopic) GetDefaultArg() string

func (*MsgCreateNewTopic) GetInferenceCadence 

func (m *MsgCreateNewTopic) GetInferenceCadence() uint64

func (*MsgCreateNewTopic) GetInferenceLogic 

func (m *MsgCreateNewTopic) GetInferenceLogic() string

func (*MsgCreateNewTopic) GetInferenceMethod 

func (m *MsgCreateNewTopic) GetInferenceMethod() string

func (*MsgCreateNewTopic) GetMetadata 

func (m *MsgCreateNewTopic) GetMetadata() string

func (*MsgCreateNewTopic) GetWeightCadence 

func (m *MsgCreateNewTopic) GetWeightCadence() uint64

func (*MsgCreateNewTopic) GetWeightLogic 

func (m *MsgCreateNewTopic) GetWeightLogic() string

func (*MsgCreateNewTopic) GetWeightMethod 

func (m *MsgCreateNewTopic) GetWeightMethod() string

func (*MsgCreateNewTopic) Marshal 

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

func (*MsgCreateNewTopic) MarshalTo 

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

func (*MsgCreateNewTopic) MarshalToSizedBuffer 

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

func (*MsgCreateNewTopic) ProtoMessage 

func (*MsgCreateNewTopic) ProtoMessage()

func (*MsgCreateNewTopic) Reset 

func (m *MsgCreateNewTopic) Reset()

func (*MsgCreateNewTopic) Size 

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

func (*MsgCreateNewTopic) String 

func (m *MsgCreateNewTopic) String() string

func (*MsgCreateNewTopic) Unmarshal 

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

func (*MsgCreateNewTopic) XXX_DiscardUnknown 

func (m *MsgCreateNewTopic) XXX_DiscardUnknown()

func (*MsgCreateNewTopic) XXX_Marshal 

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

func (*MsgCreateNewTopic) XXX_Merge 

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

func (*MsgCreateNewTopic) XXX_Size 

func (m *MsgCreateNewTopic) XXX_Size() int

func (*MsgCreateNewTopic) XXX_Unmarshal 

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

type MsgCreateNewTopicResponse 

type MsgCreateNewTopicResponse struct {
	TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
}

func (*MsgCreateNewTopicResponse) Descriptor 

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

func (*MsgCreateNewTopicResponse) GetTopicId 

func (m *MsgCreateNewTopicResponse) GetTopicId() uint64

func (*MsgCreateNewTopicResponse) Marshal 

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

func (*MsgCreateNewTopicResponse) MarshalTo 

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

func (*MsgCreateNewTopicResponse) MarshalToSizedBuffer 

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

func (*MsgCreateNewTopicResponse) ProtoMessage 

func (*MsgCreateNewTopicResponse) ProtoMessage()

func (*MsgCreateNewTopicResponse) Reset 

func (m *MsgCreateNewTopicResponse) Reset()

func (*MsgCreateNewTopicResponse) Size 

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

func (*MsgCreateNewTopicResponse) String 

func (m *MsgCreateNewTopicResponse) String() string

func (*MsgCreateNewTopicResponse) Unmarshal 

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

func (*MsgCreateNewTopicResponse) XXX_DiscardUnknown 

func (m *MsgCreateNewTopicResponse) XXX_DiscardUnknown()

func (*MsgCreateNewTopicResponse) XXX_Marshal 

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

func (*MsgCreateNewTopicResponse) XXX_Merge 

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

func (*MsgCreateNewTopicResponse) XXX_Size 

func (m *MsgCreateNewTopicResponse) XXX_Size() int

func (*MsgCreateNewTopicResponse) XXX_Unmarshal 

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

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

func (*MsgModifyStake) Descriptor 

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

func (*MsgModifyStake) GetPlacementsAdd 

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

func (*MsgModifyStake) GetPlacementsRemove 

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

func (*MsgModifyStake) GetSender 

func (m *MsgModifyStake) GetSender() string

func (*MsgModifyStake) Marshal 

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

func (*MsgModifyStake) MarshalTo 

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

func (*MsgModifyStake) MarshalToSizedBuffer 

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

func (*MsgModifyStake) ProtoMessage 

func (*MsgModifyStake) ProtoMessage()

func (*MsgModifyStake) Reset 

func (m *MsgModifyStake) Reset()

func (*MsgModifyStake) Size 

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

func (*MsgModifyStake) String 

func (m *MsgModifyStake) String() string

func (*MsgModifyStake) Unmarshal 

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

func (*MsgModifyStake) XXX_DiscardUnknown 

func (m *MsgModifyStake) XXX_DiscardUnknown()

func (*MsgModifyStake) XXX_Marshal 

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

func (*MsgModifyStake) XXX_Merge 

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

func (*MsgModifyStake) XXX_Size 

func (m *MsgModifyStake) XXX_Size() int

func (*MsgModifyStake) XXX_Unmarshal 

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

type MsgModifyStakeResponse 

type MsgModifyStakeResponse struct {
}

func (*MsgModifyStakeResponse) Descriptor 

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

func (*MsgModifyStakeResponse) Marshal 

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

func (*MsgModifyStakeResponse) MarshalTo 

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

func (*MsgModifyStakeResponse) MarshalToSizedBuffer 

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

func (*MsgModifyStakeResponse) ProtoMessage 

func (*MsgModifyStakeResponse) ProtoMessage()

func (*MsgModifyStakeResponse) Reset 

func (m *MsgModifyStakeResponse) Reset()

func (*MsgModifyStakeResponse) Size 

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

func (*MsgModifyStakeResponse) String 

func (m *MsgModifyStakeResponse) String() string

func (*MsgModifyStakeResponse) Unmarshal 

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

func (*MsgModifyStakeResponse) XXX_DiscardUnknown 

func (m *MsgModifyStakeResponse) XXX_DiscardUnknown()

func (*MsgModifyStakeResponse) XXX_Marshal 

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

func (*MsgModifyStakeResponse) XXX_Merge 

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

func (*MsgModifyStakeResponse) XXX_Size 

func (m *MsgModifyStakeResponse) XXX_Size() int

func (*MsgModifyStakeResponse) XXX_Unmarshal 

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

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

func (*MsgProcessInferences) Descriptor 

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

func (*MsgProcessInferences) GetInferences 

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

func (*MsgProcessInferences) GetSender 

func (m *MsgProcessInferences) GetSender() string

func (*MsgProcessInferences) Marshal 

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

func (*MsgProcessInferences) MarshalTo 

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

func (*MsgProcessInferences) MarshalToSizedBuffer 

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

func (*MsgProcessInferences) ProtoMessage 

func (*MsgProcessInferences) ProtoMessage()

func (*MsgProcessInferences) Reset 

func (m *MsgProcessInferences) Reset()

func (*MsgProcessInferences) Size 

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

func (*MsgProcessInferences) String 

func (m *MsgProcessInferences) String() string

func (*MsgProcessInferences) Unmarshal 

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

func (*MsgProcessInferences) XXX_DiscardUnknown 

func (m *MsgProcessInferences) XXX_DiscardUnknown()

func (*MsgProcessInferences) XXX_Marshal 

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

func (*MsgProcessInferences) XXX_Merge 

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

func (*MsgProcessInferences) XXX_Size 

func (m *MsgProcessInferences) XXX_Size() int

func (*MsgProcessInferences) XXX_Unmarshal 

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

type MsgProcessInferencesResponse 

type MsgProcessInferencesResponse struct {
}

func (*MsgProcessInferencesResponse) Descriptor 

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

func (*MsgProcessInferencesResponse) Marshal 

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

func (*MsgProcessInferencesResponse) MarshalTo 

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

func (*MsgProcessInferencesResponse) MarshalToSizedBuffer 

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

func (*MsgProcessInferencesResponse) ProtoMessage 

func (*MsgProcessInferencesResponse) ProtoMessage()

func (*MsgProcessInferencesResponse) Reset 

func (m *MsgProcessInferencesResponse) Reset()

func (*MsgProcessInferencesResponse) Size 

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

func (*MsgProcessInferencesResponse) String 

func (m *MsgProcessInferencesResponse) String() string

func (*MsgProcessInferencesResponse) Unmarshal 

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

func (*MsgProcessInferencesResponse) XXX_DiscardUnknown 

func (m *MsgProcessInferencesResponse) XXX_DiscardUnknown()

func (*MsgProcessInferencesResponse) XXX_Marshal 

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

func (*MsgProcessInferencesResponse) XXX_Merge 

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

func (*MsgProcessInferencesResponse) XXX_Size 

func (m *MsgProcessInferencesResponse) XXX_Size() int

func (*MsgProcessInferencesResponse) XXX_Unmarshal 

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

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

func (*MsgReactivateTopic) Descriptor added in v0.0.1 

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

func (*MsgReactivateTopic) GetSender added in v0.0.1 

func (m *MsgReactivateTopic) GetSender() string

func (*MsgReactivateTopic) GetTopicId added in v0.0.1 

func (m *MsgReactivateTopic) GetTopicId() uint64

func (*MsgReactivateTopic) Marshal added in v0.0.1 

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

func (*MsgReactivateTopic) MarshalTo added in v0.0.1 

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

func (*MsgReactivateTopic) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgReactivateTopic) ProtoMessage added in v0.0.1 

func (*MsgReactivateTopic) ProtoMessage()

func (*MsgReactivateTopic) Reset added in v0.0.1 

func (m *MsgReactivateTopic) Reset()

func (*MsgReactivateTopic) Size added in v0.0.1 

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

func (*MsgReactivateTopic) String added in v0.0.1 

func (m *MsgReactivateTopic) String() string

func (*MsgReactivateTopic) Unmarshal added in v0.0.1 

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

func (*MsgReactivateTopic) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgReactivateTopic) XXX_DiscardUnknown()

func (*MsgReactivateTopic) XXX_Marshal added in v0.0.1 

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

func (*MsgReactivateTopic) XXX_Merge added in v0.0.1 

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

func (*MsgReactivateTopic) XXX_Size added in v0.0.1 

func (m *MsgReactivateTopic) XXX_Size() int

func (*MsgReactivateTopic) XXX_Unmarshal added in v0.0.1 

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

type MsgReactivateTopicResponse added in v0.0.1 

type MsgReactivateTopicResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
}

func (*MsgReactivateTopicResponse) Descriptor added in v0.0.1 

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

func (*MsgReactivateTopicResponse) GetSuccess added in v0.0.1 

func (m *MsgReactivateTopicResponse) GetSuccess() bool

func (*MsgReactivateTopicResponse) Marshal added in v0.0.1 

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

func (*MsgReactivateTopicResponse) MarshalTo added in v0.0.1 

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

func (*MsgReactivateTopicResponse) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgReactivateTopicResponse) ProtoMessage added in v0.0.1 

func (*MsgReactivateTopicResponse) ProtoMessage()

func (*MsgReactivateTopicResponse) Reset added in v0.0.1 

func (m *MsgReactivateTopicResponse) Reset()

func (*MsgReactivateTopicResponse) Size added in v0.0.1 

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

func (*MsgReactivateTopicResponse) String added in v0.0.1 

func (m *MsgReactivateTopicResponse) String() string

func (*MsgReactivateTopicResponse) Unmarshal added in v0.0.1 

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

func (*MsgReactivateTopicResponse) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgReactivateTopicResponse) XXX_DiscardUnknown()

func (*MsgReactivateTopicResponse) XXX_Marshal added in v0.0.1 

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

func (*MsgReactivateTopicResponse) XXX_Merge added in v0.0.1 

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

func (*MsgReactivateTopicResponse) XXX_Size added in v0.0.1 

func (m *MsgReactivateTopicResponse) XXX_Size() int

func (*MsgReactivateTopicResponse) XXX_Unmarshal added in v0.0.1 

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

type MsgRegister 

type MsgRegister struct {
	Creator      string                 `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
	LibP2PKey    string                 `protobuf:"bytes,2,opt,name=lib_p2p_key,json=libP2pKey,proto3" json:"lib_p2p_key,omitempty"`
	MultiAddress string                 `protobuf:"bytes,3,opt,name=multi_address,json=multiAddress,proto3" json:"multi_address,omitempty"`
	TopicIds     []uint64               `protobuf:"varint,4,rep,packed,name=topic_ids,json=topicIds,proto3" json:"topic_ids,omitempty"`
	InitialStake cosmossdk_io_math.Uint `protobuf:"bytes,5,opt,name=initial_stake,json=initialStake,proto3,customtype=cosmossdk.io/math.Uint" json:"initial_stake"`
	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"`
}

/ / Inference Node Registration /

func (*MsgRegister) Descriptor 

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

func (*MsgRegister) GetCreator 

func (m *MsgRegister) GetCreator() string

func (*MsgRegister) GetInitialStake 

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

func (*MsgRegister) GetIsReputer 

func (m *MsgRegister) GetIsReputer() bool

func (*MsgRegister) GetLibP2PKey 

func (m *MsgRegister) GetLibP2PKey() string

func (*MsgRegister) GetMultiAddress 

func (m *MsgRegister) GetMultiAddress() string

func (*MsgRegister) GetOwner 

func (m *MsgRegister) GetOwner() string

func (*MsgRegister) GetTopicIds added in v0.0.4 

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

func (*MsgRegister) Marshal 

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

func (*MsgRegister) MarshalTo 

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

func (*MsgRegister) MarshalToSizedBuffer 

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

func (*MsgRegister) ProtoMessage 

func (*MsgRegister) ProtoMessage()

func (*MsgRegister) Reset 

func (m *MsgRegister) Reset()

func (*MsgRegister) Size 

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

func (*MsgRegister) String 

func (m *MsgRegister) String() string

func (*MsgRegister) Unmarshal 

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

func (*MsgRegister) XXX_DiscardUnknown 

func (m *MsgRegister) XXX_DiscardUnknown()

func (*MsgRegister) XXX_Marshal 

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

func (*MsgRegister) XXX_Merge 

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

func (*MsgRegister) XXX_Size 

func (m *MsgRegister) XXX_Size() int

func (*MsgRegister) XXX_Unmarshal 

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

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

func (*MsgRegisterResponse) Descriptor 

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

func (*MsgRegisterResponse) GetMessage 

func (m *MsgRegisterResponse) GetMessage() string

func (*MsgRegisterResponse) GetSuccess 

func (m *MsgRegisterResponse) GetSuccess() bool

func (*MsgRegisterResponse) Marshal 

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

func (*MsgRegisterResponse) MarshalTo 

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

func (*MsgRegisterResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterResponse) ProtoMessage 

func (*MsgRegisterResponse) ProtoMessage()

func (*MsgRegisterResponse) Reset 

func (m *MsgRegisterResponse) Reset()

func (*MsgRegisterResponse) Size 

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

func (*MsgRegisterResponse) String 

func (m *MsgRegisterResponse) String() string

func (*MsgRegisterResponse) Unmarshal 

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

func (*MsgRegisterResponse) XXX_DiscardUnknown 

func (m *MsgRegisterResponse) XXX_DiscardUnknown()

func (*MsgRegisterResponse) XXX_Marshal 

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

func (*MsgRegisterResponse) XXX_Merge 

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

func (*MsgRegisterResponse) XXX_Size 

func (m *MsgRegisterResponse) XXX_Size() int

func (*MsgRegisterResponse) XXX_Unmarshal 

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

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

func (*MsgRemoveFromTopicCreationWhitelist) Descriptor added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelist) GetAddress added in v0.0.1 

func (m *MsgRemoveFromTopicCreationWhitelist) GetAddress() string

func (*MsgRemoveFromTopicCreationWhitelist) GetSender added in v0.0.1 

func (m *MsgRemoveFromTopicCreationWhitelist) GetSender() string

func (*MsgRemoveFromTopicCreationWhitelist) Marshal added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelist) MarshalTo added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelist) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelist) ProtoMessage added in v0.0.1 

func (*MsgRemoveFromTopicCreationWhitelist) ProtoMessage()

func (*MsgRemoveFromTopicCreationWhitelist) Reset added in v0.0.1 

func (m *MsgRemoveFromTopicCreationWhitelist) Reset()

func (*MsgRemoveFromTopicCreationWhitelist) Size added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelist) String added in v0.0.1 

func (m *MsgRemoveFromTopicCreationWhitelist) String() string

func (*MsgRemoveFromTopicCreationWhitelist) Unmarshal added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelist) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgRemoveFromTopicCreationWhitelist) XXX_DiscardUnknown()

func (*MsgRemoveFromTopicCreationWhitelist) XXX_Marshal added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelist) XXX_Merge added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelist) XXX_Size added in v0.0.1 

func (m *MsgRemoveFromTopicCreationWhitelist) XXX_Size() int

func (*MsgRemoveFromTopicCreationWhitelist) XXX_Unmarshal added in v0.0.1 

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

type MsgRemoveFromTopicCreationWhitelistResponse added in v0.0.1 

type MsgRemoveFromTopicCreationWhitelistResponse struct {
}

func (*MsgRemoveFromTopicCreationWhitelistResponse) Descriptor added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) Marshal added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) MarshalTo added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) ProtoMessage added in v0.0.1 

func (*MsgRemoveFromTopicCreationWhitelistResponse) ProtoMessage()

func (*MsgRemoveFromTopicCreationWhitelistResponse) Reset added in v0.0.1 

func (m *MsgRemoveFromTopicCreationWhitelistResponse) Reset()

func (*MsgRemoveFromTopicCreationWhitelistResponse) Size added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) String added in v0.0.1 

func (m *MsgRemoveFromTopicCreationWhitelistResponse) String() string

func (*MsgRemoveFromTopicCreationWhitelistResponse) Unmarshal added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgRemoveFromTopicCreationWhitelistResponse) XXX_DiscardUnknown()

func (*MsgRemoveFromTopicCreationWhitelistResponse) XXX_Marshal added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) XXX_Merge added in v0.0.1 

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) XXX_Size added in v0.0.1 

func (m *MsgRemoveFromTopicCreationWhitelistResponse) XXX_Size() int

func (*MsgRemoveFromTopicCreationWhitelistResponse) XXX_Unmarshal added in v0.0.1 

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

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

func (*MsgRemoveFromWeightSettingWhitelist) Descriptor added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelist) GetAddress added in v0.0.1 

func (m *MsgRemoveFromWeightSettingWhitelist) GetAddress() string

func (*MsgRemoveFromWeightSettingWhitelist) GetSender added in v0.0.1 

func (m *MsgRemoveFromWeightSettingWhitelist) GetSender() string

func (*MsgRemoveFromWeightSettingWhitelist) Marshal added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelist) MarshalTo added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelist) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelist) ProtoMessage added in v0.0.1 

func (*MsgRemoveFromWeightSettingWhitelist) ProtoMessage()

func (*MsgRemoveFromWeightSettingWhitelist) Reset added in v0.0.1 

func (m *MsgRemoveFromWeightSettingWhitelist) Reset()

func (*MsgRemoveFromWeightSettingWhitelist) Size added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelist) String added in v0.0.1 

func (m *MsgRemoveFromWeightSettingWhitelist) String() string

func (*MsgRemoveFromWeightSettingWhitelist) Unmarshal added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelist) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgRemoveFromWeightSettingWhitelist) XXX_DiscardUnknown()

func (*MsgRemoveFromWeightSettingWhitelist) XXX_Marshal added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelist) XXX_Merge added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelist) XXX_Size added in v0.0.1 

func (m *MsgRemoveFromWeightSettingWhitelist) XXX_Size() int

func (*MsgRemoveFromWeightSettingWhitelist) XXX_Unmarshal added in v0.0.1 

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

type MsgRemoveFromWeightSettingWhitelistResponse added in v0.0.1 

type MsgRemoveFromWeightSettingWhitelistResponse struct {
}

func (*MsgRemoveFromWeightSettingWhitelistResponse) Descriptor added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) Marshal added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) MarshalTo added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) ProtoMessage added in v0.0.1 

func (*MsgRemoveFromWeightSettingWhitelistResponse) ProtoMessage()

func (*MsgRemoveFromWeightSettingWhitelistResponse) Reset added in v0.0.1 

func (m *MsgRemoveFromWeightSettingWhitelistResponse) Reset()

func (*MsgRemoveFromWeightSettingWhitelistResponse) Size added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) String added in v0.0.1 

func (m *MsgRemoveFromWeightSettingWhitelistResponse) String() string

func (*MsgRemoveFromWeightSettingWhitelistResponse) Unmarshal added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgRemoveFromWeightSettingWhitelistResponse) XXX_DiscardUnknown()

func (*MsgRemoveFromWeightSettingWhitelistResponse) XXX_Marshal added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) XXX_Merge added in v0.0.1 

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) XXX_Size added in v0.0.1 

func (m *MsgRemoveFromWeightSettingWhitelistResponse) XXX_Size() int

func (*MsgRemoveFromWeightSettingWhitelistResponse) XXX_Unmarshal added in v0.0.1 

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

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

func (*MsgRemoveFromWhitelistAdmin) Descriptor added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdmin) GetAddress added in v0.0.1 

func (m *MsgRemoveFromWhitelistAdmin) GetAddress() string

func (*MsgRemoveFromWhitelistAdmin) GetSender added in v0.0.1 

func (m *MsgRemoveFromWhitelistAdmin) GetSender() string

func (*MsgRemoveFromWhitelistAdmin) Marshal added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdmin) MarshalTo added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdmin) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdmin) ProtoMessage added in v0.0.1 

func (*MsgRemoveFromWhitelistAdmin) ProtoMessage()

func (*MsgRemoveFromWhitelistAdmin) Reset added in v0.0.1 

func (m *MsgRemoveFromWhitelistAdmin) Reset()

func (*MsgRemoveFromWhitelistAdmin) Size added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdmin) String added in v0.0.1 

func (m *MsgRemoveFromWhitelistAdmin) String() string

func (*MsgRemoveFromWhitelistAdmin) Unmarshal added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdmin) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgRemoveFromWhitelistAdmin) XXX_DiscardUnknown()

func (*MsgRemoveFromWhitelistAdmin) XXX_Marshal added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdmin) XXX_Merge added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdmin) XXX_Size added in v0.0.1 

func (m *MsgRemoveFromWhitelistAdmin) XXX_Size() int

func (*MsgRemoveFromWhitelistAdmin) XXX_Unmarshal added in v0.0.1 

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

type MsgRemoveFromWhitelistAdminResponse added in v0.0.1 

type MsgRemoveFromWhitelistAdminResponse struct {
}

func (*MsgRemoveFromWhitelistAdminResponse) Descriptor added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdminResponse) Marshal added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdminResponse) MarshalTo added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdminResponse) MarshalToSizedBuffer added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdminResponse) ProtoMessage added in v0.0.1 

func (*MsgRemoveFromWhitelistAdminResponse) ProtoMessage()

func (*MsgRemoveFromWhitelistAdminResponse) Reset added in v0.0.1 

func (m *MsgRemoveFromWhitelistAdminResponse) Reset()

func (*MsgRemoveFromWhitelistAdminResponse) Size added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdminResponse) String added in v0.0.1 

func (m *MsgRemoveFromWhitelistAdminResponse) String() string

func (*MsgRemoveFromWhitelistAdminResponse) Unmarshal added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdminResponse) XXX_DiscardUnknown added in v0.0.1 

func (m *MsgRemoveFromWhitelistAdminResponse) XXX_DiscardUnknown()

func (*MsgRemoveFromWhitelistAdminResponse) XXX_Marshal added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdminResponse) XXX_Merge added in v0.0.1 

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

func (*MsgRemoveFromWhitelistAdminResponse) XXX_Size added in v0.0.1 

func (m *MsgRemoveFromWhitelistAdminResponse) XXX_Size() int

func (*MsgRemoveFromWhitelistAdminResponse) XXX_Unmarshal added in v0.0.1 

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

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

func (*MsgRemoveRegistration) Descriptor 

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

func (*MsgRemoveRegistration) GetCreator 

func (m *MsgRemoveRegistration) GetCreator() string

func (*MsgRemoveRegistration) GetIsReputer 

func (m *MsgRemoveRegistration) GetIsReputer() bool

func (*MsgRemoveRegistration) GetTopicId 

func (m *MsgRemoveRegistration) GetTopicId() uint64

func (*MsgRemoveRegistration) Marshal 

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

func (*MsgRemoveRegistration) MarshalTo 

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

func (*MsgRemoveRegistration) MarshalToSizedBuffer 

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

func (*MsgRemoveRegistration) ProtoMessage 

func (*MsgRemoveRegistration) ProtoMessage()

func (*MsgRemoveRegistration) Reset 

func (m *MsgRemoveRegistration) Reset()

func (*MsgRemoveRegistration) Size 

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

func (*MsgRemoveRegistration) String 

func (m *MsgRemoveRegistration) String() string

func (*MsgRemoveRegistration) Unmarshal 

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

func (*MsgRemoveRegistration) XXX_DiscardUnknown 

func (m *MsgRemoveRegistration) XXX_DiscardUnknown()

func (*MsgRemoveRegistration) XXX_Marshal 

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

func (*MsgRemoveRegistration) XXX_Merge 

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

func (*MsgRemoveRegistration) XXX_Size 

func (m *MsgRemoveRegistration) XXX_Size() int

func (*MsgRemoveRegistration) XXX_Unmarshal 

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

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

func (*MsgRemoveRegistrationResponse) Descriptor 

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

func (*MsgRemoveRegistrationResponse) GetMessage 

func (m *MsgRemoveRegistrationResponse) GetMessage() string

func (*MsgRemoveRegistrationResponse) GetSuccess 

func (m *MsgRemoveRegistrationResponse) GetSuccess() bool

func (*MsgRemoveRegistrationResponse) Marshal 

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

func (*MsgRemoveRegistrationResponse) MarshalTo 

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

func (*MsgRemoveRegistrationResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveRegistrationResponse) ProtoMessage 

func (*MsgRemoveRegistrationResponse) ProtoMessage()

func (*MsgRemoveRegistrationResponse) Reset 

func (m *MsgRemoveRegistrationResponse) Reset()

func (*MsgRemoveRegistrationResponse) Size 

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

func (*MsgRemoveRegistrationResponse) String 

func (m *MsgRemoveRegistrationResponse) String() string

func (*MsgRemoveRegistrationResponse) Unmarshal 

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

func (*MsgRemoveRegistrationResponse) XXX_DiscardUnknown 

func (m *MsgRemoveRegistrationResponse) XXX_DiscardUnknown()

func (*MsgRemoveRegistrationResponse) XXX_Marshal 

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

func (*MsgRemoveRegistrationResponse) XXX_Merge 

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

func (*MsgRemoveRegistrationResponse) XXX_Size 

func (m *MsgRemoveRegistrationResponse) XXX_Size() int

func (*MsgRemoveRegistrationResponse) XXX_Unmarshal 

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

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

func (*MsgRequestInference) Descriptor 

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

func (*MsgRequestInference) GetRequests 

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

func (*MsgRequestInference) GetSender 

func (m *MsgRequestInference) GetSender() string

func (*MsgRequestInference) Marshal 

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

func (*MsgRequestInference) MarshalTo 

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

func (*MsgRequestInference) MarshalToSizedBuffer 

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

func (*MsgRequestInference) ProtoMessage 

func (*MsgRequestInference) ProtoMessage()

func (*MsgRequestInference) Reset 

func (m *MsgRequestInference) Reset()

func (*MsgRequestInference) Size 

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

func (*MsgRequestInference) String 

func (m *MsgRequestInference) String() string

func (*MsgRequestInference) Unmarshal 

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

func (*MsgRequestInference) XXX_DiscardUnknown 

func (m *MsgRequestInference) XXX_DiscardUnknown()

func (*MsgRequestInference) XXX_Marshal 

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

func (*MsgRequestInference) XXX_Merge 

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

func (*MsgRequestInference) XXX_Size 

func (m *MsgRequestInference) XXX_Size() int

func (*MsgRequestInference) XXX_Unmarshal 

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

type MsgRequestInferenceResponse 

type MsgRequestInferenceResponse struct {
}

func (*MsgRequestInferenceResponse) Descriptor 

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

func (*MsgRequestInferenceResponse) Marshal 

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

func (*MsgRequestInferenceResponse) MarshalTo 

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

func (*MsgRequestInferenceResponse) MarshalToSizedBuffer 

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

func (*MsgRequestInferenceResponse) ProtoMessage 

func (*MsgRequestInferenceResponse) ProtoMessage()

func (*MsgRequestInferenceResponse) Reset 

func (m *MsgRequestInferenceResponse) Reset()

func (*MsgRequestInferenceResponse) Size 

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

func (*MsgRequestInferenceResponse) String 

func (m *MsgRequestInferenceResponse) String() string

func (*MsgRequestInferenceResponse) Unmarshal 

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

func (*MsgRequestInferenceResponse) XXX_DiscardUnknown 

func (m *MsgRequestInferenceResponse) XXX_DiscardUnknown()

func (*MsgRequestInferenceResponse) XXX_Marshal 

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

func (*MsgRequestInferenceResponse) XXX_Merge 

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

func (*MsgRequestInferenceResponse) XXX_Size 

func (m *MsgRequestInferenceResponse) XXX_Size() int

func (*MsgRequestInferenceResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
	ProcessInferences(context.Context, *MsgProcessInferences) (*MsgProcessInferencesResponse, error)
	SetWeights(context.Context, *MsgSetWeights) (*MsgSetWeightsResponse, error)
	CreateNewTopic(context.Context, *MsgCreateNewTopic) (*MsgCreateNewTopicResponse, error)
	ReactivateTopic(context.Context, *MsgReactivateTopic) (*MsgReactivateTopicResponse, error)
	Register(context.Context, *MsgRegister) (*MsgRegisterResponse, error)
	AddNewRegistration(context.Context, *MsgAddNewRegistration) (*MsgAddNewRegistrationResponse, error)
	RemoveRegistration(context.Context, *MsgRemoveRegistration) (*MsgRemoveRegistrationResponse, error)
	AddStake(context.Context, *MsgAddStake) (*MsgAddStakeResponse, error)
	ModifyStake(context.Context, *MsgModifyStake) (*MsgModifyStakeResponse, error)
	StartRemoveStake(context.Context, *MsgStartRemoveStake) (*MsgStartRemoveStakeResponse, error)
	ConfirmRemoveStake(context.Context, *MsgConfirmRemoveStake) (*MsgConfirmRemoveStakeResponse, error)
	StartRemoveAllStake(context.Context, *MsgStartRemoveAllStake) (*MsgStartRemoveAllStakeResponse, error)
	RequestInference(context.Context, *MsgRequestInference) (*MsgRequestInferenceResponse, error)
	AddToWhitelistAdmin(context.Context, *MsgAddToWhitelistAdmin) (*MsgAddToWhitelistAdminResponse, error)
	RemoveFromWhitelistAdmin(context.Context, *MsgRemoveFromWhitelistAdmin) (*MsgRemoveFromWhitelistAdminResponse, error)
	AddToTopicCreationWhitelist(context.Context, *MsgAddToTopicCreationWhitelist) (*MsgAddToTopicCreationWhitelistResponse, error)
	RemoveFromTopicCreationWhitelist(context.Context, *MsgRemoveFromTopicCreationWhitelist) (*MsgRemoveFromTopicCreationWhitelistResponse, error)
	AddToWeightSettingWhitelist(context.Context, *MsgAddToWeightSettingWhitelist) (*MsgAddToWeightSettingWhitelistResponse, error)
	RemoveFromWeightSettingWhitelist(context.Context, *MsgRemoveFromWeightSettingWhitelist) (*MsgRemoveFromWeightSettingWhitelistResponse, error)
}

MsgServer is the server API for Msg service.

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

MsgSetWeights sets the weights for a given validator.

func (*MsgSetWeights) Descriptor 

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

func (*MsgSetWeights) GetSender 

func (m *MsgSetWeights) GetSender() string

func (*MsgSetWeights) GetWeights 

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

func (*MsgSetWeights) Marshal 

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

func (*MsgSetWeights) MarshalTo 

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

func (*MsgSetWeights) MarshalToSizedBuffer 

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

func (*MsgSetWeights) ProtoMessage 

func (*MsgSetWeights) ProtoMessage()

func (*MsgSetWeights) Reset 

func (m *MsgSetWeights) Reset()

func (*MsgSetWeights) Size 

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

func (*MsgSetWeights) String 

func (m *MsgSetWeights) String() string

func (*MsgSetWeights) Unmarshal 

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

func (*MsgSetWeights) XXX_DiscardUnknown 

func (m *MsgSetWeights) XXX_DiscardUnknown()

func (*MsgSetWeights) XXX_Marshal 

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

func (*MsgSetWeights) XXX_Merge 

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

func (*MsgSetWeights) XXX_Size 

func (m *MsgSetWeights) XXX_Size() int

func (*MsgSetWeights) XXX_Unmarshal 

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

type MsgSetWeightsResponse 

type MsgSetWeightsResponse struct {
}

func (*MsgSetWeightsResponse) Descriptor 

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

func (*MsgSetWeightsResponse) Marshal 

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

func (*MsgSetWeightsResponse) MarshalTo 

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

func (*MsgSetWeightsResponse) MarshalToSizedBuffer 

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

func (*MsgSetWeightsResponse) ProtoMessage 

func (*MsgSetWeightsResponse) ProtoMessage()

func (*MsgSetWeightsResponse) Reset 

func (m *MsgSetWeightsResponse) Reset()

func (*MsgSetWeightsResponse) Size 

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

func (*MsgSetWeightsResponse) String 

func (m *MsgSetWeightsResponse) String() string

func (*MsgSetWeightsResponse) Unmarshal 

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

func (*MsgSetWeightsResponse) XXX_DiscardUnknown 

func (m *MsgSetWeightsResponse) XXX_DiscardUnknown()

func (*MsgSetWeightsResponse) XXX_Marshal 

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

func (*MsgSetWeightsResponse) XXX_Merge 

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

func (*MsgSetWeightsResponse) XXX_Size 

func (m *MsgSetWeightsResponse) XXX_Size() int

func (*MsgSetWeightsResponse) XXX_Unmarshal 

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

type MsgStartRemoveAllStake 

type MsgStartRemoveAllStake struct {
	Sender string `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
}

func (*MsgStartRemoveAllStake) Descriptor 

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

func (*MsgStartRemoveAllStake) GetSender 

func (m *MsgStartRemoveAllStake) GetSender() string

func (*MsgStartRemoveAllStake) Marshal 

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

func (*MsgStartRemoveAllStake) MarshalTo 

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

func (*MsgStartRemoveAllStake) MarshalToSizedBuffer 

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

func (*MsgStartRemoveAllStake) ProtoMessage 

func (*MsgStartRemoveAllStake) ProtoMessage()

func (*MsgStartRemoveAllStake) Reset 

func (m *MsgStartRemoveAllStake) Reset()

func (*MsgStartRemoveAllStake) Size 

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

func (*MsgStartRemoveAllStake) String 

func (m *MsgStartRemoveAllStake) String() string

func (*MsgStartRemoveAllStake) Unmarshal 

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

func (*MsgStartRemoveAllStake) XXX_DiscardUnknown 

func (m *MsgStartRemoveAllStake) XXX_DiscardUnknown()

func (*MsgStartRemoveAllStake) XXX_Marshal 

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

func (*MsgStartRemoveAllStake) XXX_Merge 

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

func (*MsgStartRemoveAllStake) XXX_Size 

func (m *MsgStartRemoveAllStake) XXX_Size() int

func (*MsgStartRemoveAllStake) XXX_Unmarshal 

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

type MsgStartRemoveAllStakeResponse 

type MsgStartRemoveAllStakeResponse struct {
}

func (*MsgStartRemoveAllStakeResponse) Descriptor 

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

func (*MsgStartRemoveAllStakeResponse) Marshal 

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

func (*MsgStartRemoveAllStakeResponse) MarshalTo 

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

func (*MsgStartRemoveAllStakeResponse) MarshalToSizedBuffer 

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

func (*MsgStartRemoveAllStakeResponse) ProtoMessage 

func (*MsgStartRemoveAllStakeResponse) ProtoMessage()

func (*MsgStartRemoveAllStakeResponse) Reset 

func (m *MsgStartRemoveAllStakeResponse) Reset()

func (*MsgStartRemoveAllStakeResponse) Size 

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

func (*MsgStartRemoveAllStakeResponse) String 

func (m *MsgStartRemoveAllStakeResponse) String() string

func (*MsgStartRemoveAllStakeResponse) Unmarshal 

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

func (*MsgStartRemoveAllStakeResponse) XXX_DiscardUnknown 

func (m *MsgStartRemoveAllStakeResponse) XXX_DiscardUnknown()

func (*MsgStartRemoveAllStakeResponse) XXX_Marshal 

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

func (*MsgStartRemoveAllStakeResponse) XXX_Merge 

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

func (*MsgStartRemoveAllStakeResponse) XXX_Size 

func (m *MsgStartRemoveAllStakeResponse) XXX_Size() int

func (*MsgStartRemoveAllStakeResponse) XXX_Unmarshal 

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

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

func (*MsgStartRemoveStake) Descriptor 

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

func (*MsgStartRemoveStake) GetPlacementsRemove 

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

func (*MsgStartRemoveStake) GetSender 

func (m *MsgStartRemoveStake) GetSender() string

func (*MsgStartRemoveStake) Marshal 

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

func (*MsgStartRemoveStake) MarshalTo 

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

func (*MsgStartRemoveStake) MarshalToSizedBuffer 

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

func (*MsgStartRemoveStake) ProtoMessage 

func (*MsgStartRemoveStake) ProtoMessage()

func (*MsgStartRemoveStake) Reset 

func (m *MsgStartRemoveStake) Reset()

func (*MsgStartRemoveStake) Size 

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

func (*MsgStartRemoveStake) String 

func (m *MsgStartRemoveStake) String() string

func (*MsgStartRemoveStake) Unmarshal 

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

func (*MsgStartRemoveStake) XXX_DiscardUnknown 

func (m *MsgStartRemoveStake) XXX_DiscardUnknown()

func (*MsgStartRemoveStake) XXX_Marshal 

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

func (*MsgStartRemoveStake) XXX_Merge 

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

func (*MsgStartRemoveStake) XXX_Size 

func (m *MsgStartRemoveStake) XXX_Size() int

func (*MsgStartRemoveStake) XXX_Unmarshal 

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

type MsgStartRemoveStakeResponse 

type MsgStartRemoveStakeResponse struct {
}

func (*MsgStartRemoveStakeResponse) Descriptor 

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

func (*MsgStartRemoveStakeResponse) Marshal 

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

func (*MsgStartRemoveStakeResponse) MarshalTo 

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

func (*MsgStartRemoveStakeResponse) MarshalToSizedBuffer 

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

func (*MsgStartRemoveStakeResponse) ProtoMessage 

func (*MsgStartRemoveStakeResponse) ProtoMessage()

func (*MsgStartRemoveStakeResponse) Reset 

func (m *MsgStartRemoveStakeResponse) Reset()

func (*MsgStartRemoveStakeResponse) Size 

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

func (*MsgStartRemoveStakeResponse) String 

func (m *MsgStartRemoveStakeResponse) String() string

func (*MsgStartRemoveStakeResponse) Unmarshal 

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

func (*MsgStartRemoveStakeResponse) XXX_DiscardUnknown 

func (m *MsgStartRemoveStakeResponse) XXX_DiscardUnknown()

func (*MsgStartRemoveStakeResponse) XXX_Marshal 

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

func (*MsgStartRemoveStakeResponse) XXX_Merge 

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

func (*MsgStartRemoveStakeResponse) XXX_Size 

func (m *MsgStartRemoveStakeResponse) XXX_Size() int

func (*MsgStartRemoveStakeResponse) XXX_Unmarshal 

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

type MsgUpdateParams added in v0.0.4 

type MsgUpdateParams struct {
	Sender string          `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Params *OptionalParams `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
}

func (*MsgUpdateParams) Descriptor added in v0.0.4 

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

func (*MsgUpdateParams) GetParams added in v0.0.4 

func (m *MsgUpdateParams) GetParams() *OptionalParams

func (*MsgUpdateParams) GetSender added in v0.0.4 

func (m *MsgUpdateParams) GetSender() string

func (*MsgUpdateParams) Marshal added in v0.0.4 

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

func (*MsgUpdateParams) MarshalTo added in v0.0.4 

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

func (*MsgUpdateParams) MarshalToSizedBuffer added in v0.0.4 

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

func (*MsgUpdateParams) ProtoMessage added in v0.0.4 

func (*MsgUpdateParams) ProtoMessage()

func (*MsgUpdateParams) Reset added in v0.0.4 

func (m *MsgUpdateParams) Reset()

func (*MsgUpdateParams) Size added in v0.0.4 

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

func (*MsgUpdateParams) String added in v0.0.4 

func (m *MsgUpdateParams) String() string

func (*MsgUpdateParams) Unmarshal added in v0.0.4 

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

func (*MsgUpdateParams) XXX_DiscardUnknown added in v0.0.4 

func (m *MsgUpdateParams) XXX_DiscardUnknown()

func (*MsgUpdateParams) XXX_Marshal added in v0.0.4 

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

func (*MsgUpdateParams) XXX_Merge added in v0.0.4 

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

func (*MsgUpdateParams) XXX_Size added in v0.0.4 

func (m *MsgUpdateParams) XXX_Size() int

func (*MsgUpdateParams) XXX_Unmarshal added in v0.0.4 

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

type MsgUpdateParamsResponse added in v0.0.4 

type MsgUpdateParamsResponse struct {
}

func (*MsgUpdateParamsResponse) Descriptor added in v0.0.4 

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

func (*MsgUpdateParamsResponse) Marshal added in v0.0.4 

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

func (*MsgUpdateParamsResponse) MarshalTo added in v0.0.4 

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

func (*MsgUpdateParamsResponse) MarshalToSizedBuffer added in v0.0.4 

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

func (*MsgUpdateParamsResponse) ProtoMessage added in v0.0.4 

func (*MsgUpdateParamsResponse) ProtoMessage()

func (*MsgUpdateParamsResponse) Reset added in v0.0.4 

func (m *MsgUpdateParamsResponse) Reset()

func (*MsgUpdateParamsResponse) Size added in v0.0.4 

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

func (*MsgUpdateParamsResponse) String added in v0.0.4 

func (m *MsgUpdateParamsResponse) String() string

func (*MsgUpdateParamsResponse) Unmarshal added in v0.0.4 

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

func (*MsgUpdateParamsResponse) XXX_DiscardUnknown added in v0.0.4 

func (m *MsgUpdateParamsResponse) XXX_DiscardUnknown()

func (*MsgUpdateParamsResponse) XXX_Marshal added in v0.0.4 

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

func (*MsgUpdateParamsResponse) XXX_Merge added in v0.0.4 

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

func (*MsgUpdateParamsResponse) XXX_Size added in v0.0.4 

func (m *MsgUpdateParamsResponse) XXX_Size() int

func (*MsgUpdateParamsResponse) XXX_Unmarshal added in v0.0.4 

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

type OffchainNode 

type OffchainNode struct {
	LibP2PKey    string `protobuf:"bytes,1,opt,name=lib_p2p_key,json=libP2pKey,proto3" json:"lib_p2p_key,omitempty"`
	MultiAddress string `protobuf:"bytes,2,opt,name=multi_address,json=multiAddress,proto3" json:"multi_address,omitempty"`
	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"`
}

func (*OffchainNode) Descriptor 

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

func (*OffchainNode) GetLibP2PKey 

func (m *OffchainNode) GetLibP2PKey() string

func (*OffchainNode) GetMultiAddress 

func (m *OffchainNode) GetMultiAddress() string

func (*OffchainNode) GetNodeAddress 

func (m *OffchainNode) GetNodeAddress() string

func (*OffchainNode) GetNodeId 

func (m *OffchainNode) GetNodeId() string

func (*OffchainNode) GetOwner 

func (m *OffchainNode) GetOwner() string

func (*OffchainNode) Marshal 

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

func (*OffchainNode) MarshalTo 

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

func (*OffchainNode) MarshalToSizedBuffer 

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

func (*OffchainNode) ProtoMessage 

func (*OffchainNode) ProtoMessage()

func (*OffchainNode) Reset 

func (m *OffchainNode) Reset()

func (*OffchainNode) Size 

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

func (*OffchainNode) String 

func (m *OffchainNode) String() string

func (*OffchainNode) Unmarshal 

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

func (*OffchainNode) XXX_DiscardUnknown 

func (m *OffchainNode) XXX_DiscardUnknown()

func (*OffchainNode) XXX_Marshal 

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

func (*OffchainNode) XXX_Merge 

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

func (*OffchainNode) XXX_Size 

func (m *OffchainNode) XXX_Size() int

func (*OffchainNode) XXX_Unmarshal 

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

type OffchainNodes 

type OffchainNodes struct {
	OffchainNode []*Inference `protobuf:"bytes,1,rep,name=offchain_node,json=offchainNode,proto3" json:"offchain_node,omitempty"`
}

func (*OffchainNodes) Descriptor 

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

func (*OffchainNodes) GetOffchainNode 

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

func (*OffchainNodes) Marshal 

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

func (*OffchainNodes) MarshalTo 

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

func (*OffchainNodes) MarshalToSizedBuffer 

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

func (*OffchainNodes) ProtoMessage 

func (*OffchainNodes) ProtoMessage()

func (*OffchainNodes) Reset 

func (m *OffchainNodes) Reset()

func (*OffchainNodes) Size 

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

func (*OffchainNodes) String 

func (m *OffchainNodes) String() string

func (*OffchainNodes) Unmarshal 

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

func (*OffchainNodes) XXX_DiscardUnknown 

func (m *OffchainNodes) XXX_DiscardUnknown()

func (*OffchainNodes) XXX_Marshal 

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

func (*OffchainNodes) XXX_Merge 

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

func (*OffchainNodes) XXX_Size 

func (m *OffchainNodes) XXX_Size() int

func (*OffchainNodes) XXX_Unmarshal 

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

type OptionalParams added in v0.0.4 

type OptionalParams struct {
	Version                       []string                      `protobuf:"bytes,1,rep,name=version,proto3" json:"version,omitempty"`
	EpochLength                   []int64                       `protobuf:"varint,2,rep,packed,name=epoch_length,json=epochLength,proto3" json:"epoch_length,omitempty"`
	MinTopicUnmetDemand           []cosmossdk_io_math.Uint      `` /* 146-byte string literal not displayed */
	MaxTopicsPerBlock             []uint64                      `protobuf:"varint,4,rep,packed,name=max_topics_per_block,json=maxTopicsPerBlock,proto3" json:"max_topics_per_block,omitempty"`
	MinRequestUnmetDemand         []cosmossdk_io_math.Uint      `` /* 152-byte string literal not displayed */
	MaxMissingInferencePercent    []cosmossdk_io_math.LegacyDec `` /* 172-byte string literal not displayed */
	RequiredMinimumStake          []cosmossdk_io_math.Uint      `` /* 147-byte string literal not displayed */
	RemoveStakeDelayWindow        []uint64                      `` /* 139-byte string literal not displayed */
	MinRequestCadence             []uint64                      `protobuf:"varint,9,rep,packed,name=min_request_cadence,json=minRequestCadence,proto3" json:"min_request_cadence,omitempty"`
	MinWeightCadence              []uint64                      `protobuf:"varint,10,rep,packed,name=min_weight_cadence,json=minWeightCadence,proto3" json:"min_weight_cadence,omitempty"`
	MaxInferenceRequestValidity   []uint64                      `` /* 155-byte string literal not displayed */
	MaxRequestCadence             []uint64                      `protobuf:"varint,12,rep,packed,name=max_request_cadence,json=maxRequestCadence,proto3" json:"max_request_cadence,omitempty"`
	PercentRewardsReputersWorkers []cosmossdk_io_math.LegacyDec `` /* 182-byte string literal not displayed */
}

Because gocosmos, grpc-gateway, and go-pulsar do not support optional fields and including google themselves https://cloud.google.com/apis/design/design_patterns.md#optional_primitive_fields we instead use a repeated field with a single element to represent an optional field and if the repeated field is empty, it is considered to be the same as if the field was not set

func (*OptionalParams) Descriptor added in v0.0.4 

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

func (*OptionalParams) GetEpochLength added in v0.0.4 

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

func (*OptionalParams) GetMaxInferenceRequestValidity added in v0.0.4 

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

func (*OptionalParams) GetMaxRequestCadence added in v0.0.4 

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

func (*OptionalParams) GetMaxTopicsPerBlock added in v0.0.4 

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

func (*OptionalParams) GetMinRequestCadence added in v0.0.4 

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

func (*OptionalParams) GetMinWeightCadence added in v0.0.4 

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

func (*OptionalParams) GetRemoveStakeDelayWindow added in v0.0.4 

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

func (*OptionalParams) GetVersion added in v0.0.4 

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

func (*OptionalParams) Marshal added in v0.0.4 

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

func (*OptionalParams) MarshalTo added in v0.0.4 

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

func (*OptionalParams) MarshalToSizedBuffer added in v0.0.4 

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

func (*OptionalParams) ProtoMessage added in v0.0.4 

func (*OptionalParams) ProtoMessage()

func (*OptionalParams) Reset added in v0.0.4 

func (m *OptionalParams) Reset()

func (*OptionalParams) Size added in v0.0.4 

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

func (*OptionalParams) String added in v0.0.4 

func (m *OptionalParams) String() string

func (*OptionalParams) Unmarshal added in v0.0.4 

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

func (*OptionalParams) XXX_DiscardUnknown added in v0.0.4 

func (m *OptionalParams) XXX_DiscardUnknown()

func (*OptionalParams) XXX_Marshal added in v0.0.4 

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

func (*OptionalParams) XXX_Merge added in v0.0.4 

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

func (*OptionalParams) XXX_Size added in v0.0.4 

func (m *OptionalParams) XXX_Size() int

func (*OptionalParams) XXX_Unmarshal added in v0.0.4 

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

type Params 

type Params struct {
	Version                       string                      `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	EpochLength                   int64                       `protobuf:"varint,2,opt,name=epoch_length,json=epochLength,proto3" json:"epoch_length,omitempty"`
	MinTopicUnmetDemand           cosmossdk_io_math.Uint      `` /* 146-byte string literal not displayed */
	MaxTopicsPerBlock             uint64                      `protobuf:"varint,4,opt,name=max_topics_per_block,json=maxTopicsPerBlock,proto3" json:"max_topics_per_block,omitempty"`
	MinRequestUnmetDemand         cosmossdk_io_math.Uint      `` /* 152-byte string literal not displayed */
	MaxMissingInferencePercent    cosmossdk_io_math.LegacyDec `` /* 172-byte string literal not displayed */
	RequiredMinimumStake          cosmossdk_io_math.Uint      `` /* 147-byte string literal not displayed */
	RemoveStakeDelayWindow        uint64                      `` /* 132-byte string literal not displayed */
	MinRequestCadence             uint64                      `protobuf:"varint,9,opt,name=min_request_cadence,json=minRequestCadence,proto3" json:"min_request_cadence,omitempty"`
	MinWeightCadence              uint64                      `protobuf:"varint,10,opt,name=min_weight_cadence,json=minWeightCadence,proto3" json:"min_weight_cadence,omitempty"`
	MaxInferenceRequestValidity   uint64                      `` /* 148-byte string literal not displayed */
	MaxRequestCadence             uint64                      `protobuf:"varint,12,opt,name=max_request_cadence,json=maxRequestCadence,proto3" json:"max_request_cadence,omitempty"`
	PercentRewardsReputersWorkers cosmossdk_io_math.LegacyDec `` /* 182-byte string literal not displayed */
}

Params defines the parameters of the module.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns default module parameters.

func (*Params) Descriptor 

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

func (*Params) GetEpochLength added in v0.0.4 

func (m *Params) GetEpochLength() int64

func (*Params) GetMaxInferenceRequestValidity added in v0.0.4 

func (m *Params) GetMaxInferenceRequestValidity() uint64

func (*Params) GetMaxRequestCadence added in v0.0.4 

func (m *Params) GetMaxRequestCadence() uint64

func (*Params) GetMaxTopicsPerBlock added in v0.0.4 

func (m *Params) GetMaxTopicsPerBlock() uint64

func (*Params) GetMinRequestCadence added in v0.0.4 

func (m *Params) GetMinRequestCadence() uint64

func (*Params) GetMinWeightCadence added in v0.0.4 

func (m *Params) GetMinWeightCadence() uint64

func (*Params) GetRemoveStakeDelayWindow added in v0.0.4 

func (m *Params) GetRemoveStakeDelayWindow() uint64

func (*Params) GetVersion 

func (m *Params) GetVersion() string

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (Params) Validate 

func (p Params) Validate() error

Validate does the sanity check on the params.

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type QueryAccountStakeListRequest 

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

func (*QueryAccountStakeListRequest) Descriptor 

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

func (*QueryAccountStakeListRequest) GetAddress 

func (m *QueryAccountStakeListRequest) GetAddress() string

func (*QueryAccountStakeListRequest) Marshal 

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

func (*QueryAccountStakeListRequest) MarshalTo 

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

func (*QueryAccountStakeListRequest) MarshalToSizedBuffer 

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

func (*QueryAccountStakeListRequest) ProtoMessage 

func (*QueryAccountStakeListRequest) ProtoMessage()

func (*QueryAccountStakeListRequest) Reset 

func (m *QueryAccountStakeListRequest) Reset()

func (*QueryAccountStakeListRequest) Size 

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

func (*QueryAccountStakeListRequest) String 

func (m *QueryAccountStakeListRequest) String() string

func (*QueryAccountStakeListRequest) Unmarshal 

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

func (*QueryAccountStakeListRequest) XXX_DiscardUnknown 

func (m *QueryAccountStakeListRequest) XXX_DiscardUnknown()

func (*QueryAccountStakeListRequest) XXX_Marshal 

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

func (*QueryAccountStakeListRequest) XXX_Merge 

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

func (*QueryAccountStakeListRequest) XXX_Size 

func (m *QueryAccountStakeListRequest) XXX_Size() int

func (*QueryAccountStakeListRequest) XXX_Unmarshal 

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

type QueryAccountStakeListResponse 

type QueryAccountStakeListResponse struct {
	Stakes []*StakeInfo `protobuf:"bytes,1,rep,name=stakes,proto3" json:"stakes,omitempty"`
}

func (*QueryAccountStakeListResponse) Descriptor 

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

func (*QueryAccountStakeListResponse) GetStakes 

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

func (*QueryAccountStakeListResponse) Marshal 

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

func (*QueryAccountStakeListResponse) MarshalTo 

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

func (*QueryAccountStakeListResponse) MarshalToSizedBuffer 

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

func (*QueryAccountStakeListResponse) ProtoMessage 

func (*QueryAccountStakeListResponse) ProtoMessage()

func (*QueryAccountStakeListResponse) Reset 

func (m *QueryAccountStakeListResponse) Reset()

func (*QueryAccountStakeListResponse) Size 

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

func (*QueryAccountStakeListResponse) String 

func (m *QueryAccountStakeListResponse) String() string

func (*QueryAccountStakeListResponse) Unmarshal 

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

func (*QueryAccountStakeListResponse) XXX_DiscardUnknown 

func (m *QueryAccountStakeListResponse) XXX_DiscardUnknown()

func (*QueryAccountStakeListResponse) XXX_Marshal 

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

func (*QueryAccountStakeListResponse) XXX_Merge 

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

func (*QueryAccountStakeListResponse) XXX_Size 

func (m *QueryAccountStakeListResponse) XXX_Size() int

func (*QueryAccountStakeListResponse) XXX_Unmarshal 

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

type QueryActiveTopicsRequest 

type QueryActiveTopicsRequest struct {
}

func (*QueryActiveTopicsRequest) Descriptor 

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

func (*QueryActiveTopicsRequest) Marshal 

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

func (*QueryActiveTopicsRequest) MarshalTo 

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

func (*QueryActiveTopicsRequest) MarshalToSizedBuffer 

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

func (*QueryActiveTopicsRequest) ProtoMessage 

func (*QueryActiveTopicsRequest) ProtoMessage()

func (*QueryActiveTopicsRequest) Reset 

func (m *QueryActiveTopicsRequest) Reset()

func (*QueryActiveTopicsRequest) Size 

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

func (*QueryActiveTopicsRequest) String 

func (m *QueryActiveTopicsRequest) String() string

func (*QueryActiveTopicsRequest) Unmarshal 

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

func (*QueryActiveTopicsRequest) XXX_DiscardUnknown 

func (m *QueryActiveTopicsRequest) XXX_DiscardUnknown()

func (*QueryActiveTopicsRequest) XXX_Marshal 

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

func (*QueryActiveTopicsRequest) XXX_Merge 

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

func (*QueryActiveTopicsRequest) XXX_Size 

func (m *QueryActiveTopicsRequest) XXX_Size() int

func (*QueryActiveTopicsRequest) XXX_Unmarshal 

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

type QueryActiveTopicsResponse 

type QueryActiveTopicsResponse struct {
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
}

func (*QueryActiveTopicsResponse) Descriptor 

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

func (*QueryActiveTopicsResponse) GetTopics 

func (m *QueryActiveTopicsResponse) GetTopics() []*Topic

func (*QueryActiveTopicsResponse) Marshal 

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

func (*QueryActiveTopicsResponse) MarshalTo 

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

func (*QueryActiveTopicsResponse) MarshalToSizedBuffer 

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

func (*QueryActiveTopicsResponse) ProtoMessage 

func (*QueryActiveTopicsResponse) ProtoMessage()

func (*QueryActiveTopicsResponse) Reset 

func (m *QueryActiveTopicsResponse) Reset()

func (*QueryActiveTopicsResponse) Size 

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

func (*QueryActiveTopicsResponse) String 

func (m *QueryActiveTopicsResponse) String() string

func (*QueryActiveTopicsResponse) Unmarshal 

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

func (*QueryActiveTopicsResponse) XXX_DiscardUnknown 

func (m *QueryActiveTopicsResponse) XXX_DiscardUnknown()

func (*QueryActiveTopicsResponse) XXX_Marshal 

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

func (*QueryActiveTopicsResponse) XXX_Merge 

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

func (*QueryActiveTopicsResponse) XXX_Size 

func (m *QueryActiveTopicsResponse) XXX_Size() int

func (*QueryActiveTopicsResponse) XXX_Unmarshal 

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

type QueryAllExistingInferenceRequest added in v0.0.4 

type QueryAllExistingInferenceRequest struct {
}

func (*QueryAllExistingInferenceRequest) Descriptor added in v0.0.4 

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

func (*QueryAllExistingInferenceRequest) Marshal added in v0.0.4 

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

func (*QueryAllExistingInferenceRequest) MarshalTo added in v0.0.4 

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

func (*QueryAllExistingInferenceRequest) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryAllExistingInferenceRequest) ProtoMessage added in v0.0.4 

func (*QueryAllExistingInferenceRequest) ProtoMessage()

func (*QueryAllExistingInferenceRequest) Reset added in v0.0.4 

func (m *QueryAllExistingInferenceRequest) Reset()

func (*QueryAllExistingInferenceRequest) Size added in v0.0.4 

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

func (*QueryAllExistingInferenceRequest) String added in v0.0.4 

func (m *QueryAllExistingInferenceRequest) String() string

func (*QueryAllExistingInferenceRequest) Unmarshal added in v0.0.4 

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

func (*QueryAllExistingInferenceRequest) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryAllExistingInferenceRequest) XXX_DiscardUnknown()

func (*QueryAllExistingInferenceRequest) XXX_Marshal added in v0.0.4 

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

func (*QueryAllExistingInferenceRequest) XXX_Merge added in v0.0.4 

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

func (*QueryAllExistingInferenceRequest) XXX_Size added in v0.0.4 

func (m *QueryAllExistingInferenceRequest) XXX_Size() int

func (*QueryAllExistingInferenceRequest) XXX_Unmarshal added in v0.0.4 

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

type QueryAllExistingInferenceResponse added in v0.0.4 

type QueryAllExistingInferenceResponse struct {
	InferenceRequests []*InferenceRequestAndDemandLeft `protobuf:"bytes,1,rep,name=inference_requests,json=inferenceRequests,proto3" json:"inference_requests,omitempty"`
}

func (*QueryAllExistingInferenceResponse) Descriptor added in v0.0.4 

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

func (*QueryAllExistingInferenceResponse) GetInferenceRequests added in v0.0.4 

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

func (*QueryAllExistingInferenceResponse) Marshal added in v0.0.4 

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

func (*QueryAllExistingInferenceResponse) MarshalTo added in v0.0.4 

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

func (*QueryAllExistingInferenceResponse) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryAllExistingInferenceResponse) ProtoMessage added in v0.0.4 

func (*QueryAllExistingInferenceResponse) ProtoMessage()

func (*QueryAllExistingInferenceResponse) Reset added in v0.0.4 

func (m *QueryAllExistingInferenceResponse) Reset()

func (*QueryAllExistingInferenceResponse) Size added in v0.0.4 

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

func (*QueryAllExistingInferenceResponse) String added in v0.0.4 

func (m *QueryAllExistingInferenceResponse) String() string

func (*QueryAllExistingInferenceResponse) Unmarshal added in v0.0.4 

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

func (*QueryAllExistingInferenceResponse) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryAllExistingInferenceResponse) XXX_DiscardUnknown()

func (*QueryAllExistingInferenceResponse) XXX_Marshal added in v0.0.4 

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

func (*QueryAllExistingInferenceResponse) XXX_Merge added in v0.0.4 

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

func (*QueryAllExistingInferenceResponse) XXX_Size added in v0.0.4 

func (m *QueryAllExistingInferenceResponse) XXX_Size() int

func (*QueryAllExistingInferenceResponse) XXX_Unmarshal added in v0.0.4 

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

type QueryAllInferencesRequest added in v0.0.4 

type QueryAllInferencesRequest struct {
	TopicId   uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	Timestamp uint64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

Returns the latest inference on a topic from a worker

func (*QueryAllInferencesRequest) Descriptor added in v0.0.4 

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

func (*QueryAllInferencesRequest) GetTimestamp added in v0.0.4 

func (m *QueryAllInferencesRequest) GetTimestamp() uint64

func (*QueryAllInferencesRequest) GetTopicId added in v0.0.4 

func (m *QueryAllInferencesRequest) GetTopicId() uint64

func (*QueryAllInferencesRequest) Marshal added in v0.0.4 

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

func (*QueryAllInferencesRequest) MarshalTo added in v0.0.4 

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

func (*QueryAllInferencesRequest) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryAllInferencesRequest) ProtoMessage added in v0.0.4 

func (*QueryAllInferencesRequest) ProtoMessage()

func (*QueryAllInferencesRequest) Reset added in v0.0.4 

func (m *QueryAllInferencesRequest) Reset()

func (*QueryAllInferencesRequest) Size added in v0.0.4 

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

func (*QueryAllInferencesRequest) String added in v0.0.4 

func (m *QueryAllInferencesRequest) String() string

func (*QueryAllInferencesRequest) Unmarshal added in v0.0.4 

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

func (*QueryAllInferencesRequest) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryAllInferencesRequest) XXX_DiscardUnknown()

func (*QueryAllInferencesRequest) XXX_Marshal added in v0.0.4 

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

func (*QueryAllInferencesRequest) XXX_Merge added in v0.0.4 

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

func (*QueryAllInferencesRequest) XXX_Size added in v0.0.4 

func (m *QueryAllInferencesRequest) XXX_Size() int

func (*QueryAllInferencesRequest) XXX_Unmarshal added in v0.0.4 

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

type QueryAllInferencesResponse added in v0.0.4 

type QueryAllInferencesResponse struct {
	Inferences *Inferences `protobuf:"bytes,1,opt,name=inferences,proto3" json:"inferences,omitempty"`
}

Returns the latest inference on a topic from a worker

NOTE: The amount field is a Uint which implements the custom method signatures required by gogoproto.

func (*QueryAllInferencesResponse) Descriptor added in v0.0.4 

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

func (*QueryAllInferencesResponse) GetInferences added in v0.0.4 

func (m *QueryAllInferencesResponse) GetInferences() *Inferences

func (*QueryAllInferencesResponse) Marshal added in v0.0.4 

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

func (*QueryAllInferencesResponse) MarshalTo added in v0.0.4 

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

func (*QueryAllInferencesResponse) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryAllInferencesResponse) ProtoMessage added in v0.0.4 

func (*QueryAllInferencesResponse) ProtoMessage()

func (*QueryAllInferencesResponse) Reset added in v0.0.4 

func (m *QueryAllInferencesResponse) Reset()

func (*QueryAllInferencesResponse) Size added in v0.0.4 

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

func (*QueryAllInferencesResponse) String added in v0.0.4 

func (m *QueryAllInferencesResponse) String() string

func (*QueryAllInferencesResponse) Unmarshal added in v0.0.4 

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

func (*QueryAllInferencesResponse) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryAllInferencesResponse) XXX_DiscardUnknown()

func (*QueryAllInferencesResponse) XXX_Marshal added in v0.0.4 

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

func (*QueryAllInferencesResponse) XXX_Merge added in v0.0.4 

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

func (*QueryAllInferencesResponse) XXX_Size added in v0.0.4 

func (m *QueryAllInferencesResponse) XXX_Size() int

func (*QueryAllInferencesResponse) XXX_Unmarshal added in v0.0.4 

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

type QueryAllTopicsRequest added in v0.0.4 

type QueryAllTopicsRequest struct {
}

func (*QueryAllTopicsRequest) Descriptor added in v0.0.4 

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

func (*QueryAllTopicsRequest) Marshal added in v0.0.4 

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

func (*QueryAllTopicsRequest) MarshalTo added in v0.0.4 

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

func (*QueryAllTopicsRequest) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryAllTopicsRequest) ProtoMessage added in v0.0.4 

func (*QueryAllTopicsRequest) ProtoMessage()

func (*QueryAllTopicsRequest) Reset added in v0.0.4 

func (m *QueryAllTopicsRequest) Reset()

func (*QueryAllTopicsRequest) Size added in v0.0.4 

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

func (*QueryAllTopicsRequest) String added in v0.0.4 

func (m *QueryAllTopicsRequest) String() string

func (*QueryAllTopicsRequest) Unmarshal added in v0.0.4 

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

func (*QueryAllTopicsRequest) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryAllTopicsRequest) XXX_DiscardUnknown()

func (*QueryAllTopicsRequest) XXX_Marshal added in v0.0.4 

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

func (*QueryAllTopicsRequest) XXX_Merge added in v0.0.4 

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

func (*QueryAllTopicsRequest) XXX_Size added in v0.0.4 

func (m *QueryAllTopicsRequest) XXX_Size() int

func (*QueryAllTopicsRequest) XXX_Unmarshal added in v0.0.4 

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

type QueryAllTopicsResponse added in v0.0.4 

type QueryAllTopicsResponse struct {
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
}

func (*QueryAllTopicsResponse) Descriptor added in v0.0.4 

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

func (*QueryAllTopicsResponse) GetTopics added in v0.0.4 

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

func (*QueryAllTopicsResponse) Marshal added in v0.0.4 

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

func (*QueryAllTopicsResponse) MarshalTo added in v0.0.4 

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

func (*QueryAllTopicsResponse) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryAllTopicsResponse) ProtoMessage added in v0.0.4 

func (*QueryAllTopicsResponse) ProtoMessage()

func (*QueryAllTopicsResponse) Reset added in v0.0.4 

func (m *QueryAllTopicsResponse) Reset()

func (*QueryAllTopicsResponse) Size added in v0.0.4 

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

func (*QueryAllTopicsResponse) String added in v0.0.4 

func (m *QueryAllTopicsResponse) String() string

func (*QueryAllTopicsResponse) Unmarshal added in v0.0.4 

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

func (*QueryAllTopicsResponse) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryAllTopicsResponse) XXX_DiscardUnknown()

func (*QueryAllTopicsResponse) XXX_Marshal added in v0.0.4 

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

func (*QueryAllTopicsResponse) XXX_Merge added in v0.0.4 

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

func (*QueryAllTopicsResponse) XXX_Size added in v0.0.4 

func (m *QueryAllTopicsResponse) XXX_Size() int

func (*QueryAllTopicsResponse) XXX_Unmarshal added in v0.0.4 

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

type QueryClient 

type QueryClient interface {
	// Params returns the module parameters.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	GetLastRewardsUpdate(ctx context.Context, in *QueryLastRewardsUpdateRequest, opts ...grpc.CallOption) (*QueryLastRewardsUpdateResponse, error)
	GetNextTopicId(ctx context.Context, in *QueryNextTopicIdRequest, opts ...grpc.CallOption) (*QueryNextTopicIdResponse, error)
	GetTopic(ctx context.Context, in *QueryTopicRequest, opts ...grpc.CallOption) (*QueryTopicResponse, error)
	GetActiveTopics(ctx context.Context, in *QueryActiveTopicsRequest, opts ...grpc.CallOption) (*QueryActiveTopicsResponse, error)
	GetAllTopics(ctx context.Context, in *QueryAllTopicsRequest, opts ...grpc.CallOption) (*QueryAllTopicsResponse, error)
	GetTopicsByCreator(ctx context.Context, in *QueryGetTopicsByCreatorRequest, opts ...grpc.CallOption) (*QueryGetTopicsByCreatorResponse, error)
	GetWeight(ctx context.Context, in *QueryWeightRequest, opts ...grpc.CallOption) (*QueryWeightResponse, error)
	GetExistingInferenceRequest(ctx context.Context, in *QueryExistingInferenceRequest, opts ...grpc.CallOption) (*QueryExistingInferenceResponse, error)
	GetAllExistingInferenceRequests(ctx context.Context, in *QueryAllExistingInferenceRequest, opts ...grpc.CallOption) (*QueryAllExistingInferenceResponse, error)
	GetTopicUnmetDemand(ctx context.Context, in *QueryTopicUnmetDemandRequest, opts ...grpc.CallOption) (*QueryTopicUnmetDemandResponse, error)
	GetWorkerLatestInferenceByTopicId(ctx context.Context, in *QueryWorkerLatestInferenceRequest, opts ...grpc.CallOption) (*QueryWorkerLatestInferenceResponse, error)
	GetAllInferences(ctx context.Context, in *QueryAllInferencesRequest, opts ...grpc.CallOption) (*QueryAllInferencesResponse, error)
	GetInferencesToScore(ctx context.Context, in *QueryInferencesToScoreRequest, opts ...grpc.CallOption) (*QueryInferencesToScoreResponse, error)
	GetTotalStake(ctx context.Context, in *QueryTotalStakeRequest, opts ...grpc.CallOption) (*QueryTotalStakeResponse, error)
	GetAccountStakeList(ctx context.Context, in *QueryAccountStakeListRequest, opts ...grpc.CallOption) (*QueryAccountStakeListResponse, error)
	GetWorkerNodeRegistration(ctx context.Context, in *QueryRegisteredWorkerNodesRequest, opts ...grpc.CallOption) (*QueryRegisteredWorkerNodesResponse, error)
	GetWorkerAddressByP2PKey(ctx context.Context, in *QueryWorkerAddressByP2PKeyRequest, opts ...grpc.CallOption) (*QueryWorkerAddressByP2PKeyResponse, error)
	GetRegisteredTopicIds(ctx context.Context, in *QueryRegisteredTopicIdsRequest, opts ...grpc.CallOption) (*QueryRegisteredTopicIdsResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryExistingInferenceRequest added in v0.0.4 

type QueryExistingInferenceRequest struct {
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	TopicId   uint64 `protobuf:"varint,2,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
}

func (*QueryExistingInferenceRequest) Descriptor added in v0.0.4 

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

func (*QueryExistingInferenceRequest) GetRequestId added in v0.0.4 

func (m *QueryExistingInferenceRequest) GetRequestId() string

func (*QueryExistingInferenceRequest) GetTopicId added in v0.0.4 

func (m *QueryExistingInferenceRequest) GetTopicId() uint64

func (*QueryExistingInferenceRequest) Marshal added in v0.0.4 

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

func (*QueryExistingInferenceRequest) MarshalTo added in v0.0.4 

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

func (*QueryExistingInferenceRequest) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryExistingInferenceRequest) ProtoMessage added in v0.0.4 

func (*QueryExistingInferenceRequest) ProtoMessage()

func (*QueryExistingInferenceRequest) Reset added in v0.0.4 

func (m *QueryExistingInferenceRequest) Reset()

func (*QueryExistingInferenceRequest) Size added in v0.0.4 

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

func (*QueryExistingInferenceRequest) String added in v0.0.4 

func (m *QueryExistingInferenceRequest) String() string

func (*QueryExistingInferenceRequest) Unmarshal added in v0.0.4 

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

func (*QueryExistingInferenceRequest) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryExistingInferenceRequest) XXX_DiscardUnknown()

func (*QueryExistingInferenceRequest) XXX_Marshal added in v0.0.4 

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

func (*QueryExistingInferenceRequest) XXX_Merge added in v0.0.4 

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

func (*QueryExistingInferenceRequest) XXX_Size added in v0.0.4 

func (m *QueryExistingInferenceRequest) XXX_Size() int

func (*QueryExistingInferenceRequest) XXX_Unmarshal added in v0.0.4 

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

type QueryExistingInferenceResponse added in v0.0.4 

type QueryExistingInferenceResponse struct {
	InferenceRequest *InferenceRequest      `protobuf:"bytes,1,opt,name=inference_request,json=inferenceRequest,proto3" json:"inference_request,omitempty"`
	DemandLeft       cosmossdk_io_math.Uint `protobuf:"bytes,2,opt,name=demand_left,json=demandLeft,proto3,customtype=cosmossdk.io/math.Uint" json:"demand_left"`
}

func (*QueryExistingInferenceResponse) Descriptor added in v0.0.4 

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

func (*QueryExistingInferenceResponse) GetInferenceRequest added in v0.0.4 

func (m *QueryExistingInferenceResponse) GetInferenceRequest() *InferenceRequest

func (*QueryExistingInferenceResponse) Marshal added in v0.0.4 

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

func (*QueryExistingInferenceResponse) MarshalTo added in v0.0.4 

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

func (*QueryExistingInferenceResponse) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryExistingInferenceResponse) ProtoMessage added in v0.0.4 

func (*QueryExistingInferenceResponse) ProtoMessage()

func (*QueryExistingInferenceResponse) Reset added in v0.0.4 

func (m *QueryExistingInferenceResponse) Reset()

func (*QueryExistingInferenceResponse) Size added in v0.0.4 

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

func (*QueryExistingInferenceResponse) String added in v0.0.4 

func (m *QueryExistingInferenceResponse) String() string

func (*QueryExistingInferenceResponse) Unmarshal added in v0.0.4 

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

func (*QueryExistingInferenceResponse) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryExistingInferenceResponse) XXX_DiscardUnknown()

func (*QueryExistingInferenceResponse) XXX_Marshal added in v0.0.4 

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

func (*QueryExistingInferenceResponse) XXX_Merge added in v0.0.4 

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

func (*QueryExistingInferenceResponse) XXX_Size added in v0.0.4 

func (m *QueryExistingInferenceResponse) XXX_Size() int

func (*QueryExistingInferenceResponse) XXX_Unmarshal added in v0.0.4 

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

type QueryGetTopicsByCreatorRequest 

type QueryGetTopicsByCreatorRequest struct {
	Creator string `protobuf:"bytes,1,opt,name=creator,proto3" json:"creator,omitempty"`
}

func (*QueryGetTopicsByCreatorRequest) Descriptor 

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

func (*QueryGetTopicsByCreatorRequest) GetCreator 

func (m *QueryGetTopicsByCreatorRequest) GetCreator() string

func (*QueryGetTopicsByCreatorRequest) Marshal 

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

func (*QueryGetTopicsByCreatorRequest) MarshalTo 

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

func (*QueryGetTopicsByCreatorRequest) MarshalToSizedBuffer 

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

func (*QueryGetTopicsByCreatorRequest) ProtoMessage 

func (*QueryGetTopicsByCreatorRequest) ProtoMessage()

func (*QueryGetTopicsByCreatorRequest) Reset 

func (m *QueryGetTopicsByCreatorRequest) Reset()

func (*QueryGetTopicsByCreatorRequest) Size 

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

func (*QueryGetTopicsByCreatorRequest) String 

func (m *QueryGetTopicsByCreatorRequest) String() string

func (*QueryGetTopicsByCreatorRequest) Unmarshal 

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

func (*QueryGetTopicsByCreatorRequest) XXX_DiscardUnknown 

func (m *QueryGetTopicsByCreatorRequest) XXX_DiscardUnknown()

func (*QueryGetTopicsByCreatorRequest) XXX_Marshal 

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

func (*QueryGetTopicsByCreatorRequest) XXX_Merge 

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

func (*QueryGetTopicsByCreatorRequest) XXX_Size 

func (m *QueryGetTopicsByCreatorRequest) XXX_Size() int

func (*QueryGetTopicsByCreatorRequest) XXX_Unmarshal 

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

type QueryGetTopicsByCreatorResponse 

type QueryGetTopicsByCreatorResponse struct {
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
}

func (*QueryGetTopicsByCreatorResponse) Descriptor 

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

func (*QueryGetTopicsByCreatorResponse) GetTopics 

func (m *QueryGetTopicsByCreatorResponse) GetTopics() []*Topic

func (*QueryGetTopicsByCreatorResponse) Marshal 

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

func (*QueryGetTopicsByCreatorResponse) MarshalTo 

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

func (*QueryGetTopicsByCreatorResponse) MarshalToSizedBuffer 

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

func (*QueryGetTopicsByCreatorResponse) ProtoMessage 

func (*QueryGetTopicsByCreatorResponse) ProtoMessage()

func (*QueryGetTopicsByCreatorResponse) Reset 

func (m *QueryGetTopicsByCreatorResponse) Reset()

func (*QueryGetTopicsByCreatorResponse) Size 

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

func (*QueryGetTopicsByCreatorResponse) String 

func (m *QueryGetTopicsByCreatorResponse) String() string

func (*QueryGetTopicsByCreatorResponse) Unmarshal 

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

func (*QueryGetTopicsByCreatorResponse) XXX_DiscardUnknown 

func (m *QueryGetTopicsByCreatorResponse) XXX_DiscardUnknown()

func (*QueryGetTopicsByCreatorResponse) XXX_Marshal 

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

func (*QueryGetTopicsByCreatorResponse) XXX_Merge 

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

func (*QueryGetTopicsByCreatorResponse) XXX_Size 

func (m *QueryGetTopicsByCreatorResponse) XXX_Size() int

func (*QueryGetTopicsByCreatorResponse) XXX_Unmarshal 

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

type QueryInferencesToScoreRequest 

type QueryInferencesToScoreRequest struct {
	TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
}

func (*QueryInferencesToScoreRequest) Descriptor 

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

func (*QueryInferencesToScoreRequest) GetTopicId 

func (m *QueryInferencesToScoreRequest) GetTopicId() uint64

func (*QueryInferencesToScoreRequest) Marshal 

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

func (*QueryInferencesToScoreRequest) MarshalTo 

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

func (*QueryInferencesToScoreRequest) MarshalToSizedBuffer 

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

func (*QueryInferencesToScoreRequest) ProtoMessage 

func (*QueryInferencesToScoreRequest) ProtoMessage()

func (*QueryInferencesToScoreRequest) Reset 

func (m *QueryInferencesToScoreRequest) Reset()

func (*QueryInferencesToScoreRequest) Size 

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

func (*QueryInferencesToScoreRequest) String 

func (m *QueryInferencesToScoreRequest) String() string

func (*QueryInferencesToScoreRequest) Unmarshal 

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

func (*QueryInferencesToScoreRequest) XXX_DiscardUnknown 

func (m *QueryInferencesToScoreRequest) XXX_DiscardUnknown()

func (*QueryInferencesToScoreRequest) XXX_Marshal 

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

func (*QueryInferencesToScoreRequest) XXX_Merge 

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

func (*QueryInferencesToScoreRequest) XXX_Size 

func (m *QueryInferencesToScoreRequest) XXX_Size() int

func (*QueryInferencesToScoreRequest) XXX_Unmarshal 

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

type QueryInferencesToScoreResponse 

type QueryInferencesToScoreResponse struct {
	Inferences []*InferenceSetForScoring `protobuf:"bytes,1,rep,name=inferences,proto3" json:"inferences,omitempty"`
}

func (*QueryInferencesToScoreResponse) Descriptor 

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

func (*QueryInferencesToScoreResponse) GetInferences 

func (m *QueryInferencesToScoreResponse) GetInferences() []*InferenceSetForScoring

func (*QueryInferencesToScoreResponse) Marshal 

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

func (*QueryInferencesToScoreResponse) MarshalTo 

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

func (*QueryInferencesToScoreResponse) MarshalToSizedBuffer 

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

func (*QueryInferencesToScoreResponse) ProtoMessage 

func (*QueryInferencesToScoreResponse) ProtoMessage()

func (*QueryInferencesToScoreResponse) Reset 

func (m *QueryInferencesToScoreResponse) Reset()

func (*QueryInferencesToScoreResponse) Size 

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

func (*QueryInferencesToScoreResponse) String 

func (m *QueryInferencesToScoreResponse) String() string

func (*QueryInferencesToScoreResponse) Unmarshal 

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

func (*QueryInferencesToScoreResponse) XXX_DiscardUnknown 

func (m *QueryInferencesToScoreResponse) XXX_DiscardUnknown()

func (*QueryInferencesToScoreResponse) XXX_Marshal 

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

func (*QueryInferencesToScoreResponse) XXX_Merge 

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

func (*QueryInferencesToScoreResponse) XXX_Size 

func (m *QueryInferencesToScoreResponse) XXX_Size() int

func (*QueryInferencesToScoreResponse) XXX_Unmarshal 

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

type QueryLastRewardsUpdateRequest 

type QueryLastRewardsUpdateRequest struct {
}

returns the last time the rewards inflation calculation ran

func (*QueryLastRewardsUpdateRequest) Descriptor 

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

func (*QueryLastRewardsUpdateRequest) Marshal 

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

func (*QueryLastRewardsUpdateRequest) MarshalTo 

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

func (*QueryLastRewardsUpdateRequest) MarshalToSizedBuffer 

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

func (*QueryLastRewardsUpdateRequest) ProtoMessage 

func (*QueryLastRewardsUpdateRequest) ProtoMessage()

func (*QueryLastRewardsUpdateRequest) Reset 

func (m *QueryLastRewardsUpdateRequest) Reset()

func (*QueryLastRewardsUpdateRequest) Size 

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

func (*QueryLastRewardsUpdateRequest) String 

func (m *QueryLastRewardsUpdateRequest) String() string

func (*QueryLastRewardsUpdateRequest) Unmarshal 

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

func (*QueryLastRewardsUpdateRequest) XXX_DiscardUnknown 

func (m *QueryLastRewardsUpdateRequest) XXX_DiscardUnknown()

func (*QueryLastRewardsUpdateRequest) XXX_Marshal 

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

func (*QueryLastRewardsUpdateRequest) XXX_Merge 

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

func (*QueryLastRewardsUpdateRequest) XXX_Size 

func (m *QueryLastRewardsUpdateRequest) XXX_Size() int

func (*QueryLastRewardsUpdateRequest) XXX_Unmarshal 

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

type QueryLastRewardsUpdateResponse 

type QueryLastRewardsUpdateResponse struct {
	LastRewardsUpdate int64 `protobuf:"varint,1,opt,name=last_rewards_update,json=lastRewardsUpdate,proto3" json:"last_rewards_update,omitempty"`
}

returns the last time the rewards inflation calculation ran last_rewards_update is an int64 because it is a block number

func (*QueryLastRewardsUpdateResponse) Descriptor 

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

func (*QueryLastRewardsUpdateResponse) GetLastRewardsUpdate 

func (m *QueryLastRewardsUpdateResponse) GetLastRewardsUpdate() int64

func (*QueryLastRewardsUpdateResponse) Marshal 

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

func (*QueryLastRewardsUpdateResponse) MarshalTo 

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

func (*QueryLastRewardsUpdateResponse) MarshalToSizedBuffer 

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

func (*QueryLastRewardsUpdateResponse) ProtoMessage 

func (*QueryLastRewardsUpdateResponse) ProtoMessage()

func (*QueryLastRewardsUpdateResponse) Reset 

func (m *QueryLastRewardsUpdateResponse) Reset()

func (*QueryLastRewardsUpdateResponse) Size 

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

func (*QueryLastRewardsUpdateResponse) String 

func (m *QueryLastRewardsUpdateResponse) String() string

func (*QueryLastRewardsUpdateResponse) Unmarshal 

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

func (*QueryLastRewardsUpdateResponse) XXX_DiscardUnknown 

func (m *QueryLastRewardsUpdateResponse) XXX_DiscardUnknown()

func (*QueryLastRewardsUpdateResponse) XXX_Marshal 

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

func (*QueryLastRewardsUpdateResponse) XXX_Merge 

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

func (*QueryLastRewardsUpdateResponse) XXX_Size 

func (m *QueryLastRewardsUpdateResponse) XXX_Size() int

func (*QueryLastRewardsUpdateResponse) XXX_Unmarshal 

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

type QueryNextTopicIdRequest 

type QueryNextTopicIdRequest struct {
}

func (*QueryNextTopicIdRequest) Descriptor 

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

func (*QueryNextTopicIdRequest) Marshal 

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

func (*QueryNextTopicIdRequest) MarshalTo 

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

func (*QueryNextTopicIdRequest) MarshalToSizedBuffer 

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

func (*QueryNextTopicIdRequest) ProtoMessage 

func (*QueryNextTopicIdRequest) ProtoMessage()

func (*QueryNextTopicIdRequest) Reset 

func (m *QueryNextTopicIdRequest) Reset()

func (*QueryNextTopicIdRequest) Size 

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

func (*QueryNextTopicIdRequest) String 

func (m *QueryNextTopicIdRequest) String() string

func (*QueryNextTopicIdRequest) Unmarshal 

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

func (*QueryNextTopicIdRequest) XXX_DiscardUnknown 

func (m *QueryNextTopicIdRequest) XXX_DiscardUnknown()

func (*QueryNextTopicIdRequest) XXX_Marshal 

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

func (*QueryNextTopicIdRequest) XXX_Merge 

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

func (*QueryNextTopicIdRequest) XXX_Size 

func (m *QueryNextTopicIdRequest) XXX_Size() int

func (*QueryNextTopicIdRequest) XXX_Unmarshal 

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

type QueryNextTopicIdResponse 

type QueryNextTopicIdResponse struct {
	NextTopicId uint64 `protobuf:"varint,1,opt,name=next_topic_id,json=nextTopicId,proto3" json:"next_topic_id,omitempty"`
}

func (*QueryNextTopicIdResponse) Descriptor 

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

func (*QueryNextTopicIdResponse) GetNextTopicId 

func (m *QueryNextTopicIdResponse) GetNextTopicId() uint64

func (*QueryNextTopicIdResponse) Marshal 

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

func (*QueryNextTopicIdResponse) MarshalTo 

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

func (*QueryNextTopicIdResponse) MarshalToSizedBuffer 

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

func (*QueryNextTopicIdResponse) ProtoMessage 

func (*QueryNextTopicIdResponse) ProtoMessage()

func (*QueryNextTopicIdResponse) Reset 

func (m *QueryNextTopicIdResponse) Reset()

func (*QueryNextTopicIdResponse) Size 

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

func (*QueryNextTopicIdResponse) String 

func (m *QueryNextTopicIdResponse) String() string

func (*QueryNextTopicIdResponse) Unmarshal 

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

func (*QueryNextTopicIdResponse) XXX_DiscardUnknown 

func (m *QueryNextTopicIdResponse) XXX_DiscardUnknown()

func (*QueryNextTopicIdResponse) XXX_Marshal 

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

func (*QueryNextTopicIdResponse) XXX_Merge 

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

func (*QueryNextTopicIdResponse) XXX_Size 

func (m *QueryNextTopicIdResponse) XXX_Size() int

func (*QueryNextTopicIdResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

QueryParamsRequest is the request type for the Query/Params RPC method.

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

type QueryParamsResponse struct {
	// params defines the parameters of the module.
	Params Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params"`
}

QueryParamsResponse is the response type for the Query/Params RPC method.

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type QueryRegisteredTopicIdsRequest added in v0.0.4 

type QueryRegisteredTopicIdsRequest struct {
	Address   string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	IsReputer bool   `protobuf:"varint,2,opt,name=is_reputer,json=isReputer,proto3" json:"is_reputer,omitempty"`
}

func (*QueryRegisteredTopicIdsRequest) Descriptor added in v0.0.4 

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

func (*QueryRegisteredTopicIdsRequest) GetAddress added in v0.0.4 

func (m *QueryRegisteredTopicIdsRequest) GetAddress() string

func (*QueryRegisteredTopicIdsRequest) GetIsReputer added in v0.0.4 

func (m *QueryRegisteredTopicIdsRequest) GetIsReputer() bool

func (*QueryRegisteredTopicIdsRequest) Marshal added in v0.0.4 

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

func (*QueryRegisteredTopicIdsRequest) MarshalTo added in v0.0.4 

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

func (*QueryRegisteredTopicIdsRequest) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryRegisteredTopicIdsRequest) ProtoMessage added in v0.0.4 

func (*QueryRegisteredTopicIdsRequest) ProtoMessage()

func (*QueryRegisteredTopicIdsRequest) Reset added in v0.0.4 

func (m *QueryRegisteredTopicIdsRequest) Reset()

func (*QueryRegisteredTopicIdsRequest) Size added in v0.0.4 

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

func (*QueryRegisteredTopicIdsRequest) String added in v0.0.4 

func (m *QueryRegisteredTopicIdsRequest) String() string

func (*QueryRegisteredTopicIdsRequest) Unmarshal added in v0.0.4 

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

func (*QueryRegisteredTopicIdsRequest) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryRegisteredTopicIdsRequest) XXX_DiscardUnknown()

func (*QueryRegisteredTopicIdsRequest) XXX_Marshal added in v0.0.4 

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

func (*QueryRegisteredTopicIdsRequest) XXX_Merge added in v0.0.4 

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

func (*QueryRegisteredTopicIdsRequest) XXX_Size added in v0.0.4 

func (m *QueryRegisteredTopicIdsRequest) XXX_Size() int

func (*QueryRegisteredTopicIdsRequest) XXX_Unmarshal added in v0.0.4 

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

type QueryRegisteredTopicIdsResponse added in v0.0.4 

type QueryRegisteredTopicIdsResponse struct {
	TopicIds []uint64 `protobuf:"varint,1,rep,packed,name=topic_ids,json=topicIds,proto3" json:"topic_ids,omitempty"`
}

func (*QueryRegisteredTopicIdsResponse) Descriptor added in v0.0.4 

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

func (*QueryRegisteredTopicIdsResponse) GetTopicIds added in v0.0.4 

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

func (*QueryRegisteredTopicIdsResponse) Marshal added in v0.0.4 

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

func (*QueryRegisteredTopicIdsResponse) MarshalTo added in v0.0.4 

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

func (*QueryRegisteredTopicIdsResponse) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryRegisteredTopicIdsResponse) ProtoMessage added in v0.0.4 

func (*QueryRegisteredTopicIdsResponse) ProtoMessage()

func (*QueryRegisteredTopicIdsResponse) Reset added in v0.0.4 

func (m *QueryRegisteredTopicIdsResponse) Reset()

func (*QueryRegisteredTopicIdsResponse) Size added in v0.0.4 

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

func (*QueryRegisteredTopicIdsResponse) String added in v0.0.4 

func (m *QueryRegisteredTopicIdsResponse) String() string

func (*QueryRegisteredTopicIdsResponse) Unmarshal added in v0.0.4 

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

func (*QueryRegisteredTopicIdsResponse) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryRegisteredTopicIdsResponse) XXX_DiscardUnknown()

func (*QueryRegisteredTopicIdsResponse) XXX_Marshal added in v0.0.4 

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

func (*QueryRegisteredTopicIdsResponse) XXX_Merge added in v0.0.4 

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

func (*QueryRegisteredTopicIdsResponse) XXX_Size added in v0.0.4 

func (m *QueryRegisteredTopicIdsResponse) XXX_Size() int

func (*QueryRegisteredTopicIdsResponse) XXX_Unmarshal added in v0.0.4 

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

type QueryRegisteredWorkerNodesRequest 

type QueryRegisteredWorkerNodesRequest struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
}

func (*QueryRegisteredWorkerNodesRequest) Descriptor 

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

func (*QueryRegisteredWorkerNodesRequest) GetNodeId 

func (m *QueryRegisteredWorkerNodesRequest) GetNodeId() string

func (*QueryRegisteredWorkerNodesRequest) Marshal 

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

func (*QueryRegisteredWorkerNodesRequest) MarshalTo 

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

func (*QueryRegisteredWorkerNodesRequest) MarshalToSizedBuffer 

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

func (*QueryRegisteredWorkerNodesRequest) ProtoMessage 

func (*QueryRegisteredWorkerNodesRequest) ProtoMessage()

func (*QueryRegisteredWorkerNodesRequest) Reset 

func (m *QueryRegisteredWorkerNodesRequest) Reset()

func (*QueryRegisteredWorkerNodesRequest) Size 

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

func (*QueryRegisteredWorkerNodesRequest) String 

func (m *QueryRegisteredWorkerNodesRequest) String() string

func (*QueryRegisteredWorkerNodesRequest) Unmarshal 

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

func (*QueryRegisteredWorkerNodesRequest) XXX_DiscardUnknown 

func (m *QueryRegisteredWorkerNodesRequest) XXX_DiscardUnknown()

func (*QueryRegisteredWorkerNodesRequest) XXX_Marshal 

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

func (*QueryRegisteredWorkerNodesRequest) XXX_Merge 

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

func (*QueryRegisteredWorkerNodesRequest) XXX_Size 

func (m *QueryRegisteredWorkerNodesRequest) XXX_Size() int

func (*QueryRegisteredWorkerNodesRequest) XXX_Unmarshal 

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

type QueryRegisteredWorkerNodesResponse 

type QueryRegisteredWorkerNodesResponse struct {
	Nodes []*OffchainNode `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
}

func (*QueryRegisteredWorkerNodesResponse) Descriptor 

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

func (*QueryRegisteredWorkerNodesResponse) GetNodes 

func (m *QueryRegisteredWorkerNodesResponse) GetNodes() []*OffchainNode

func (*QueryRegisteredWorkerNodesResponse) Marshal 

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

func (*QueryRegisteredWorkerNodesResponse) MarshalTo 

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

func (*QueryRegisteredWorkerNodesResponse) MarshalToSizedBuffer 

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

func (*QueryRegisteredWorkerNodesResponse) ProtoMessage 

func (*QueryRegisteredWorkerNodesResponse) ProtoMessage()

func (*QueryRegisteredWorkerNodesResponse) Reset 

func (m *QueryRegisteredWorkerNodesResponse) Reset()

func (*QueryRegisteredWorkerNodesResponse) Size 

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

func (*QueryRegisteredWorkerNodesResponse) String 

func (m *QueryRegisteredWorkerNodesResponse) String() string

func (*QueryRegisteredWorkerNodesResponse) Unmarshal 

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

func (*QueryRegisteredWorkerNodesResponse) XXX_DiscardUnknown 

func (m *QueryRegisteredWorkerNodesResponse) XXX_DiscardUnknown()

func (*QueryRegisteredWorkerNodesResponse) XXX_Marshal 

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

func (*QueryRegisteredWorkerNodesResponse) XXX_Merge 

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

func (*QueryRegisteredWorkerNodesResponse) XXX_Size 

func (m *QueryRegisteredWorkerNodesResponse) XXX_Size() int

func (*QueryRegisteredWorkerNodesResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params returns the module parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	GetLastRewardsUpdate(context.Context, *QueryLastRewardsUpdateRequest) (*QueryLastRewardsUpdateResponse, error)
	GetNextTopicId(context.Context, *QueryNextTopicIdRequest) (*QueryNextTopicIdResponse, error)
	GetTopic(context.Context, *QueryTopicRequest) (*QueryTopicResponse, error)
	GetActiveTopics(context.Context, *QueryActiveTopicsRequest) (*QueryActiveTopicsResponse, error)
	GetAllTopics(context.Context, *QueryAllTopicsRequest) (*QueryAllTopicsResponse, error)
	GetTopicsByCreator(context.Context, *QueryGetTopicsByCreatorRequest) (*QueryGetTopicsByCreatorResponse, error)
	GetWeight(context.Context, *QueryWeightRequest) (*QueryWeightResponse, error)
	GetExistingInferenceRequest(context.Context, *QueryExistingInferenceRequest) (*QueryExistingInferenceResponse, error)
	GetAllExistingInferenceRequests(context.Context, *QueryAllExistingInferenceRequest) (*QueryAllExistingInferenceResponse, error)
	GetTopicUnmetDemand(context.Context, *QueryTopicUnmetDemandRequest) (*QueryTopicUnmetDemandResponse, error)
	GetWorkerLatestInferenceByTopicId(context.Context, *QueryWorkerLatestInferenceRequest) (*QueryWorkerLatestInferenceResponse, error)
	GetAllInferences(context.Context, *QueryAllInferencesRequest) (*QueryAllInferencesResponse, error)
	GetInferencesToScore(context.Context, *QueryInferencesToScoreRequest) (*QueryInferencesToScoreResponse, error)
	GetTotalStake(context.Context, *QueryTotalStakeRequest) (*QueryTotalStakeResponse, error)
	GetAccountStakeList(context.Context, *QueryAccountStakeListRequest) (*QueryAccountStakeListResponse, error)
	GetWorkerNodeRegistration(context.Context, *QueryRegisteredWorkerNodesRequest) (*QueryRegisteredWorkerNodesResponse, error)
	GetWorkerAddressByP2PKey(context.Context, *QueryWorkerAddressByP2PKeyRequest) (*QueryWorkerAddressByP2PKeyResponse, error)
	GetRegisteredTopicIds(context.Context, *QueryRegisteredTopicIdsRequest) (*QueryRegisteredTopicIdsResponse, error)
}

QueryServer is the server API for Query service.

type QueryTopicRequest 

type QueryTopicRequest struct {
	TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
}

func (*QueryTopicRequest) Descriptor 

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

func (*QueryTopicRequest) GetTopicId 

func (m *QueryTopicRequest) GetTopicId() uint64

func (*QueryTopicRequest) Marshal 

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

func (*QueryTopicRequest) MarshalTo 

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

func (*QueryTopicRequest) MarshalToSizedBuffer 

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

func (*QueryTopicRequest) ProtoMessage 

func (*QueryTopicRequest) ProtoMessage()

func (*QueryTopicRequest) Reset 

func (m *QueryTopicRequest) Reset()

func (*QueryTopicRequest) Size 

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

func (*QueryTopicRequest) String 

func (m *QueryTopicRequest) String() string

func (*QueryTopicRequest) Unmarshal 

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

func (*QueryTopicRequest) XXX_DiscardUnknown 

func (m *QueryTopicRequest) XXX_DiscardUnknown()

func (*QueryTopicRequest) XXX_Marshal 

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

func (*QueryTopicRequest) XXX_Merge 

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

func (*QueryTopicRequest) XXX_Size 

func (m *QueryTopicRequest) XXX_Size() int

func (*QueryTopicRequest) XXX_Unmarshal 

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

type QueryTopicResponse 

type QueryTopicResponse struct {
	Topic *Topic `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
}

func (*QueryTopicResponse) Descriptor 

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

func (*QueryTopicResponse) GetTopic 

func (m *QueryTopicResponse) GetTopic() *Topic

func (*QueryTopicResponse) Marshal 

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

func (*QueryTopicResponse) MarshalTo 

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

func (*QueryTopicResponse) MarshalToSizedBuffer 

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

func (*QueryTopicResponse) ProtoMessage 

func (*QueryTopicResponse) ProtoMessage()

func (*QueryTopicResponse) Reset 

func (m *QueryTopicResponse) Reset()

func (*QueryTopicResponse) Size 

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

func (*QueryTopicResponse) String 

func (m *QueryTopicResponse) String() string

func (*QueryTopicResponse) Unmarshal 

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

func (*QueryTopicResponse) XXX_DiscardUnknown 

func (m *QueryTopicResponse) XXX_DiscardUnknown()

func (*QueryTopicResponse) XXX_Marshal 

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

func (*QueryTopicResponse) XXX_Merge 

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

func (*QueryTopicResponse) XXX_Size 

func (m *QueryTopicResponse) XXX_Size() int

func (*QueryTopicResponse) XXX_Unmarshal 

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

type QueryTopicUnmetDemandRequest added in v0.0.4 

type QueryTopicUnmetDemandRequest struct {
	TopicId uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
}

func (*QueryTopicUnmetDemandRequest) Descriptor added in v0.0.4 

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

func (*QueryTopicUnmetDemandRequest) GetTopicId added in v0.0.4 

func (m *QueryTopicUnmetDemandRequest) GetTopicId() uint64

func (*QueryTopicUnmetDemandRequest) Marshal added in v0.0.4 

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

func (*QueryTopicUnmetDemandRequest) MarshalTo added in v0.0.4 

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

func (*QueryTopicUnmetDemandRequest) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryTopicUnmetDemandRequest) ProtoMessage added in v0.0.4 

func (*QueryTopicUnmetDemandRequest) ProtoMessage()

func (*QueryTopicUnmetDemandRequest) Reset added in v0.0.4 

func (m *QueryTopicUnmetDemandRequest) Reset()

func (*QueryTopicUnmetDemandRequest) Size added in v0.0.4 

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

func (*QueryTopicUnmetDemandRequest) String added in v0.0.4 

func (m *QueryTopicUnmetDemandRequest) String() string

func (*QueryTopicUnmetDemandRequest) Unmarshal added in v0.0.4 

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

func (*QueryTopicUnmetDemandRequest) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryTopicUnmetDemandRequest) XXX_DiscardUnknown()

func (*QueryTopicUnmetDemandRequest) XXX_Marshal added in v0.0.4 

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

func (*QueryTopicUnmetDemandRequest) XXX_Merge added in v0.0.4 

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

func (*QueryTopicUnmetDemandRequest) XXX_Size added in v0.0.4 

func (m *QueryTopicUnmetDemandRequest) XXX_Size() int

func (*QueryTopicUnmetDemandRequest) XXX_Unmarshal added in v0.0.4 

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

type QueryTopicUnmetDemandResponse added in v0.0.4 

type QueryTopicUnmetDemandResponse struct {
	DemandLeft cosmossdk_io_math.Uint `protobuf:"bytes,1,opt,name=demand_left,json=demandLeft,proto3,customtype=cosmossdk.io/math.Uint" json:"demand_left"`
}

func (*QueryTopicUnmetDemandResponse) Descriptor added in v0.0.4 

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

func (*QueryTopicUnmetDemandResponse) Marshal added in v0.0.4 

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

func (*QueryTopicUnmetDemandResponse) MarshalTo added in v0.0.4 

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

func (*QueryTopicUnmetDemandResponse) MarshalToSizedBuffer added in v0.0.4 

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

func (*QueryTopicUnmetDemandResponse) ProtoMessage added in v0.0.4 

func (*QueryTopicUnmetDemandResponse) ProtoMessage()

func (*QueryTopicUnmetDemandResponse) Reset added in v0.0.4 

func (m *QueryTopicUnmetDemandResponse) Reset()

func (*QueryTopicUnmetDemandResponse) Size added in v0.0.4 

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

func (*QueryTopicUnmetDemandResponse) String added in v0.0.4 

func (m *QueryTopicUnmetDemandResponse) String() string

func (*QueryTopicUnmetDemandResponse) Unmarshal added in v0.0.4 

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

func (*QueryTopicUnmetDemandResponse) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryTopicUnmetDemandResponse) XXX_DiscardUnknown()

func (*QueryTopicUnmetDemandResponse) XXX_Marshal added in v0.0.4 

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

func (*QueryTopicUnmetDemandResponse) XXX_Merge added in v0.0.4 

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

func (*QueryTopicUnmetDemandResponse) XXX_Size added in v0.0.4 

func (m *QueryTopicUnmetDemandResponse) XXX_Size() int

func (*QueryTopicUnmetDemandResponse) XXX_Unmarshal added in v0.0.4 

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

type QueryTotalStakeRequest 

type QueryTotalStakeRequest struct {
}

Total Stake returns the total amount of stake in the system

func (*QueryTotalStakeRequest) Descriptor 

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

func (*QueryTotalStakeRequest) Marshal 

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

func (*QueryTotalStakeRequest) MarshalTo 

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

func (*QueryTotalStakeRequest) MarshalToSizedBuffer 

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

func (*QueryTotalStakeRequest) ProtoMessage 

func (*QueryTotalStakeRequest) ProtoMessage()

func (*QueryTotalStakeRequest) Reset 

func (m *QueryTotalStakeRequest) Reset()

func (*QueryTotalStakeRequest) Size 

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

func (*QueryTotalStakeRequest) String 

func (m *QueryTotalStakeRequest) String() string

func (*QueryTotalStakeRequest) Unmarshal 

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

func (*QueryTotalStakeRequest) XXX_DiscardUnknown 

func (m *QueryTotalStakeRequest) XXX_DiscardUnknown()

func (*QueryTotalStakeRequest) XXX_Marshal 

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

func (*QueryTotalStakeRequest) XXX_Merge 

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

func (*QueryTotalStakeRequest) XXX_Size 

func (m *QueryTotalStakeRequest) XXX_Size() int

func (*QueryTotalStakeRequest) XXX_Unmarshal 

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

type QueryTotalStakeResponse 

type QueryTotalStakeResponse struct {
	Amount cosmossdk_io_math.Uint `protobuf:"bytes,1,opt,name=amount,proto3,customtype=cosmossdk.io/math.Uint" json:"amount"`
}

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 

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

func (*QueryTotalStakeResponse) Equal 

func (this *QueryTotalStakeResponse) Equal(that interface{}) bool

func (*QueryTotalStakeResponse) Marshal 

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

func (*QueryTotalStakeResponse) MarshalTo 

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

func (*QueryTotalStakeResponse) MarshalToSizedBuffer 

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

func (*QueryTotalStakeResponse) ProtoMessage 

func (*QueryTotalStakeResponse) ProtoMessage()

func (*QueryTotalStakeResponse) Reset 

func (m *QueryTotalStakeResponse) Reset()

func (*QueryTotalStakeResponse) Size 

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

func (*QueryTotalStakeResponse) String 

func (m *QueryTotalStakeResponse) String() string

func (*QueryTotalStakeResponse) Unmarshal 

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

func (*QueryTotalStakeResponse) XXX_DiscardUnknown 

func (m *QueryTotalStakeResponse) XXX_DiscardUnknown()

func (*QueryTotalStakeResponse) XXX_Marshal 

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

func (*QueryTotalStakeResponse) XXX_Merge 

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

func (*QueryTotalStakeResponse) XXX_Size 

func (m *QueryTotalStakeResponse) XXX_Size() int

func (*QueryTotalStakeResponse) XXX_Unmarshal 

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

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

Returns the weight assigned by a reputer onto a worker for a given topic

func (*QueryWeightRequest) Descriptor 

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

func (*QueryWeightRequest) GetReputer 

func (m *QueryWeightRequest) GetReputer() string

func (*QueryWeightRequest) GetTopicId 

func (m *QueryWeightRequest) GetTopicId() uint64

func (*QueryWeightRequest) GetWorker 

func (m *QueryWeightRequest) GetWorker() string

func (*QueryWeightRequest) Marshal 

func (m *QueryWeightRequest) Marshal() (dAtA []byte, err error)

func (*QueryWeightRequest) MarshalTo 

func (m *QueryWeightRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryWeightRequest) MarshalToSizedBuffer 

func (m *QueryWeightRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryWeightRequest) ProtoMessage 

func (*QueryWeightRequest) ProtoMessage()

func (*QueryWeightRequest) Reset 

func (m *QueryWeightRequest) Reset()

func (*QueryWeightRequest) Size 

func (m *QueryWeightRequest) Size() (n int)

func (*QueryWeightRequest) String 

func (m *QueryWeightRequest) String() string

func (*QueryWeightRequest) Unmarshal 

func (m *QueryWeightRequest) Unmarshal(dAtA []byte) error

func (*QueryWeightRequest) XXX_DiscardUnknown 

func (m *QueryWeightRequest) XXX_DiscardUnknown()

func (*QueryWeightRequest) XXX_Marshal 

func (m *QueryWeightRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWeightRequest) XXX_Merge 

func (m *QueryWeightRequest) XXX_Merge(src proto.Message)

func (*QueryWeightRequest) XXX_Size 

func (m *QueryWeightRequest) XXX_Size() int

func (*QueryWeightRequest) XXX_Unmarshal 

func (m *QueryWeightRequest) XXX_Unmarshal(b []byte) error

type QueryWeightResponse 

type QueryWeightResponse struct {
	Amount cosmossdk_io_math.Uint `protobuf:"bytes,1,opt,name=amount,proto3,customtype=cosmossdk.io/math.Uint" json:"amount"`
}

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 

func (*QueryWeightResponse) Descriptor() ([]byte, []int)

func (*QueryWeightResponse) Equal 

func (this *QueryWeightResponse) Equal(that interface{}) bool

func (*QueryWeightResponse) Marshal 

func (m *QueryWeightResponse) Marshal() (dAtA []byte, err error)

func (*QueryWeightResponse) MarshalTo 

func (m *QueryWeightResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryWeightResponse) MarshalToSizedBuffer 

func (m *QueryWeightResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryWeightResponse) ProtoMessage 

func (*QueryWeightResponse) ProtoMessage()

func (*QueryWeightResponse) Reset 

func (m *QueryWeightResponse) Reset()

func (*QueryWeightResponse) Size 

func (m *QueryWeightResponse) Size() (n int)

func (*QueryWeightResponse) String 

func (m *QueryWeightResponse) String() string

func (*QueryWeightResponse) Unmarshal 

func (m *QueryWeightResponse) Unmarshal(dAtA []byte) error

func (*QueryWeightResponse) XXX_DiscardUnknown 

func (m *QueryWeightResponse) XXX_DiscardUnknown()

func (*QueryWeightResponse) XXX_Marshal 

func (m *QueryWeightResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWeightResponse) XXX_Merge 

func (m *QueryWeightResponse) XXX_Merge(src proto.Message)

func (*QueryWeightResponse) XXX_Size 

func (m *QueryWeightResponse) XXX_Size() int

func (*QueryWeightResponse) XXX_Unmarshal 

func (m *QueryWeightResponse) XXX_Unmarshal(b []byte) error

type QueryWorkerAddressByP2PKeyRequest 

type QueryWorkerAddressByP2PKeyRequest struct {
	Libp2PKey string `protobuf:"bytes,1,opt,name=libp2p_key,json=libp2pKey,proto3" json:"libp2p_key,omitempty"`
}

func (*QueryWorkerAddressByP2PKeyRequest) Descriptor 

func (*QueryWorkerAddressByP2PKeyRequest) Descriptor() ([]byte, []int)

func (*QueryWorkerAddressByP2PKeyRequest) GetLibp2PKey 

func (m *QueryWorkerAddressByP2PKeyRequest) GetLibp2PKey() string

func (*QueryWorkerAddressByP2PKeyRequest) Marshal 

func (m *QueryWorkerAddressByP2PKeyRequest) Marshal() (dAtA []byte, err error)

func (*QueryWorkerAddressByP2PKeyRequest) MarshalTo 

func (m *QueryWorkerAddressByP2PKeyRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryWorkerAddressByP2PKeyRequest) MarshalToSizedBuffer 

func (m *QueryWorkerAddressByP2PKeyRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryWorkerAddressByP2PKeyRequest) ProtoMessage 

func (*QueryWorkerAddressByP2PKeyRequest) ProtoMessage()

func (*QueryWorkerAddressByP2PKeyRequest) Reset 

func (m *QueryWorkerAddressByP2PKeyRequest) Reset()

func (*QueryWorkerAddressByP2PKeyRequest) Size 

func (m *QueryWorkerAddressByP2PKeyRequest) Size() (n int)

func (*QueryWorkerAddressByP2PKeyRequest) String 

func (m *QueryWorkerAddressByP2PKeyRequest) String() string

func (*QueryWorkerAddressByP2PKeyRequest) Unmarshal 

func (m *QueryWorkerAddressByP2PKeyRequest) Unmarshal(dAtA []byte) error

func (*QueryWorkerAddressByP2PKeyRequest) XXX_DiscardUnknown 

func (m *QueryWorkerAddressByP2PKeyRequest) XXX_DiscardUnknown()

func (*QueryWorkerAddressByP2PKeyRequest) XXX_Marshal 

func (m *QueryWorkerAddressByP2PKeyRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWorkerAddressByP2PKeyRequest) XXX_Merge 

func (m *QueryWorkerAddressByP2PKeyRequest) XXX_Merge(src proto.Message)

func (*QueryWorkerAddressByP2PKeyRequest) XXX_Size 

func (m *QueryWorkerAddressByP2PKeyRequest) XXX_Size() int

func (*QueryWorkerAddressByP2PKeyRequest) XXX_Unmarshal 

func (m *QueryWorkerAddressByP2PKeyRequest) XXX_Unmarshal(b []byte) error

type QueryWorkerAddressByP2PKeyResponse 

type QueryWorkerAddressByP2PKeyResponse struct {
	Address string `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
}

func (*QueryWorkerAddressByP2PKeyResponse) Descriptor 

func (*QueryWorkerAddressByP2PKeyResponse) Descriptor() ([]byte, []int)

func (*QueryWorkerAddressByP2PKeyResponse) GetAddress 

func (m *QueryWorkerAddressByP2PKeyResponse) GetAddress() string

func (*QueryWorkerAddressByP2PKeyResponse) Marshal 

func (m *QueryWorkerAddressByP2PKeyResponse) Marshal() (dAtA []byte, err error)

func (*QueryWorkerAddressByP2PKeyResponse) MarshalTo 

func (m *QueryWorkerAddressByP2PKeyResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryWorkerAddressByP2PKeyResponse) MarshalToSizedBuffer 

func (m *QueryWorkerAddressByP2PKeyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryWorkerAddressByP2PKeyResponse) ProtoMessage 

func (*QueryWorkerAddressByP2PKeyResponse) ProtoMessage()

func (*QueryWorkerAddressByP2PKeyResponse) Reset 

func (m *QueryWorkerAddressByP2PKeyResponse) Reset()

func (*QueryWorkerAddressByP2PKeyResponse) Size 

func (m *QueryWorkerAddressByP2PKeyResponse) Size() (n int)

func (*QueryWorkerAddressByP2PKeyResponse) String 

func (m *QueryWorkerAddressByP2PKeyResponse) String() string

func (*QueryWorkerAddressByP2PKeyResponse) Unmarshal 

func (m *QueryWorkerAddressByP2PKeyResponse) Unmarshal(dAtA []byte) error

func (*QueryWorkerAddressByP2PKeyResponse) XXX_DiscardUnknown 

func (m *QueryWorkerAddressByP2PKeyResponse) XXX_DiscardUnknown()

func (*QueryWorkerAddressByP2PKeyResponse) XXX_Marshal 

func (m *QueryWorkerAddressByP2PKeyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWorkerAddressByP2PKeyResponse) XXX_Merge 

func (m *QueryWorkerAddressByP2PKeyResponse) XXX_Merge(src proto.Message)

func (*QueryWorkerAddressByP2PKeyResponse) XXX_Size 

func (m *QueryWorkerAddressByP2PKeyResponse) XXX_Size() int

func (*QueryWorkerAddressByP2PKeyResponse) XXX_Unmarshal 

func (m *QueryWorkerAddressByP2PKeyResponse) XXX_Unmarshal(b []byte) error

type QueryWorkerLatestInferenceRequest added in v0.0.4 

type QueryWorkerLatestInferenceRequest struct {
	TopicId       uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	WorkerAddress string `protobuf:"bytes,2,opt,name=worker_address,json=workerAddress,proto3" json:"worker_address,omitempty"`
}

func (*QueryWorkerLatestInferenceRequest) Descriptor added in v0.0.4 

func (*QueryWorkerLatestInferenceRequest) Descriptor() ([]byte, []int)

func (*QueryWorkerLatestInferenceRequest) GetTopicId added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) GetTopicId() uint64

func (*QueryWorkerLatestInferenceRequest) GetWorkerAddress added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) GetWorkerAddress() string

func (*QueryWorkerLatestInferenceRequest) Marshal added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) Marshal() (dAtA []byte, err error)

func (*QueryWorkerLatestInferenceRequest) MarshalTo added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) MarshalTo(dAtA []byte) (int, error)

func (*QueryWorkerLatestInferenceRequest) MarshalToSizedBuffer added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryWorkerLatestInferenceRequest) ProtoMessage added in v0.0.4 

func (*QueryWorkerLatestInferenceRequest) ProtoMessage()

func (*QueryWorkerLatestInferenceRequest) Reset added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) Reset()

func (*QueryWorkerLatestInferenceRequest) Size added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) Size() (n int)

func (*QueryWorkerLatestInferenceRequest) String added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) String() string

func (*QueryWorkerLatestInferenceRequest) Unmarshal added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) Unmarshal(dAtA []byte) error

func (*QueryWorkerLatestInferenceRequest) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) XXX_DiscardUnknown()

func (*QueryWorkerLatestInferenceRequest) XXX_Marshal added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWorkerLatestInferenceRequest) XXX_Merge added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) XXX_Merge(src proto.Message)

func (*QueryWorkerLatestInferenceRequest) XXX_Size added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) XXX_Size() int

func (*QueryWorkerLatestInferenceRequest) XXX_Unmarshal added in v0.0.4 

func (m *QueryWorkerLatestInferenceRequest) XXX_Unmarshal(b []byte) error

type QueryWorkerLatestInferenceResponse added in v0.0.4 

type QueryWorkerLatestInferenceResponse struct {
	LatestInference *Inference `protobuf:"bytes,1,opt,name=latest_inference,json=latestInference,proto3" json:"latest_inference,omitempty"`
}

func (*QueryWorkerLatestInferenceResponse) Descriptor added in v0.0.4 

func (*QueryWorkerLatestInferenceResponse) Descriptor() ([]byte, []int)

func (*QueryWorkerLatestInferenceResponse) GetLatestInference added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) GetLatestInference() *Inference

func (*QueryWorkerLatestInferenceResponse) Marshal added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) Marshal() (dAtA []byte, err error)

func (*QueryWorkerLatestInferenceResponse) MarshalTo added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) MarshalTo(dAtA []byte) (int, error)

func (*QueryWorkerLatestInferenceResponse) MarshalToSizedBuffer added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*QueryWorkerLatestInferenceResponse) ProtoMessage added in v0.0.4 

func (*QueryWorkerLatestInferenceResponse) ProtoMessage()

func (*QueryWorkerLatestInferenceResponse) Reset added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) Reset()

func (*QueryWorkerLatestInferenceResponse) Size added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) Size() (n int)

func (*QueryWorkerLatestInferenceResponse) String added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) String() string

func (*QueryWorkerLatestInferenceResponse) Unmarshal added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) Unmarshal(dAtA []byte) error

func (*QueryWorkerLatestInferenceResponse) XXX_DiscardUnknown added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) XXX_DiscardUnknown()

func (*QueryWorkerLatestInferenceResponse) XXX_Marshal added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryWorkerLatestInferenceResponse) XXX_Merge added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) XXX_Merge(src proto.Message)

func (*QueryWorkerLatestInferenceResponse) XXX_Size added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) XXX_Size() int

func (*QueryWorkerLatestInferenceResponse) XXX_Unmarshal added in v0.0.4 

func (m *QueryWorkerLatestInferenceResponse) XXX_Unmarshal(b []byte) error

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"`
	MaxPricePerInference cosmossdk_io_math.Uint `` /* 149-byte string literal not displayed */
	BidAmount            cosmossdk_io_math.Uint `protobuf:"bytes,5,opt,name=bid_amount,json=bidAmount,proto3,customtype=cosmossdk.io/math.Uint" json:"bid_amount"`
	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"`
}

func (*RequestInferenceListItem) Descriptor 

func (*RequestInferenceListItem) Descriptor() ([]byte, []int)

func (*RequestInferenceListItem) GetCadence 

func (m *RequestInferenceListItem) GetCadence() uint64

func (*RequestInferenceListItem) GetExtraData 

func (m *RequestInferenceListItem) GetExtraData() []byte

func (*RequestInferenceListItem) GetNonce 

func (m *RequestInferenceListItem) GetNonce() uint64

func (*RequestInferenceListItem) GetTimestampValidUntil 

func (m *RequestInferenceListItem) GetTimestampValidUntil() uint64

func (*RequestInferenceListItem) GetTopicId 

func (m *RequestInferenceListItem) GetTopicId() uint64

func (*RequestInferenceListItem) Marshal 

func (m *RequestInferenceListItem) Marshal() (dAtA []byte, err error)

func (*RequestInferenceListItem) MarshalTo 

func (m *RequestInferenceListItem) MarshalTo(dAtA []byte) (int, error)

func (*RequestInferenceListItem) MarshalToSizedBuffer 

func (m *RequestInferenceListItem) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RequestInferenceListItem) ProtoMessage 

func (*RequestInferenceListItem) ProtoMessage()

func (*RequestInferenceListItem) Reset 

func (m *RequestInferenceListItem) Reset()

func (*RequestInferenceListItem) Size 

func (m *RequestInferenceListItem) Size() (n int)

func (*RequestInferenceListItem) String 

func (m *RequestInferenceListItem) String() string

func (*RequestInferenceListItem) Unmarshal 

func (m *RequestInferenceListItem) Unmarshal(dAtA []byte) error

func (*RequestInferenceListItem) XXX_DiscardUnknown 

func (m *RequestInferenceListItem) XXX_DiscardUnknown()

func (*RequestInferenceListItem) XXX_Marshal 

func (m *RequestInferenceListItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestInferenceListItem) XXX_Merge 

func (m *RequestInferenceListItem) XXX_Merge(src proto.Message)

func (*RequestInferenceListItem) XXX_Size 

func (m *RequestInferenceListItem) XXX_Size() int

func (*RequestInferenceListItem) XXX_Unmarshal 

func (m *RequestInferenceListItem) XXX_Unmarshal(b []byte) error

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"`
}

func (*StakeInfo) Descriptor 

func (*StakeInfo) Descriptor() ([]byte, []int)

func (*StakeInfo) GetAddress 

func (m *StakeInfo) GetAddress() string

func (*StakeInfo) GetAmount 

func (m *StakeInfo) GetAmount() string

func (*StakeInfo) Marshal 

func (m *StakeInfo) Marshal() (dAtA []byte, err error)

func (*StakeInfo) MarshalTo 

func (m *StakeInfo) MarshalTo(dAtA []byte) (int, error)

func (*StakeInfo) MarshalToSizedBuffer 

func (m *StakeInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StakeInfo) ProtoMessage 

func (*StakeInfo) ProtoMessage()

func (*StakeInfo) Reset 

func (m *StakeInfo) Reset()

func (*StakeInfo) Size 

func (m *StakeInfo) Size() (n int)

func (*StakeInfo) String 

func (m *StakeInfo) String() string

func (*StakeInfo) Unmarshal 

func (m *StakeInfo) Unmarshal(dAtA []byte) error

func (*StakeInfo) XXX_DiscardUnknown 

func (m *StakeInfo) XXX_DiscardUnknown()

func (*StakeInfo) XXX_Marshal 

func (m *StakeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StakeInfo) XXX_Merge 

func (m *StakeInfo) XXX_Merge(src proto.Message)

func (*StakeInfo) XXX_Size 

func (m *StakeInfo) XXX_Size() int

func (*StakeInfo) XXX_Unmarshal 

func (m *StakeInfo) XXX_Unmarshal(b []byte) error

type StakePlacement 

type StakePlacement struct {
	Target string                 `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Amount cosmossdk_io_math.Uint `protobuf:"bytes,2,opt,name=amount,proto3,customtype=cosmossdk.io/math.Uint" json:"amount"`
}

func (*StakePlacement) Descriptor 

func (*StakePlacement) Descriptor() ([]byte, []int)

func (*StakePlacement) GetTarget 

func (m *StakePlacement) GetTarget() string

func (*StakePlacement) Marshal 

func (m *StakePlacement) Marshal() (dAtA []byte, err error)

func (*StakePlacement) MarshalTo 

func (m *StakePlacement) MarshalTo(dAtA []byte) (int, error)

func (*StakePlacement) MarshalToSizedBuffer 

func (m *StakePlacement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StakePlacement) ProtoMessage 

func (*StakePlacement) ProtoMessage()

func (*StakePlacement) Reset 

func (m *StakePlacement) Reset()

func (*StakePlacement) Size 

func (m *StakePlacement) Size() (n int)

func (*StakePlacement) String 

func (m *StakePlacement) String() string

func (*StakePlacement) Unmarshal 

func (m *StakePlacement) Unmarshal(dAtA []byte) error

func (*StakePlacement) XXX_DiscardUnknown 

func (m *StakePlacement) XXX_DiscardUnknown()

func (*StakePlacement) XXX_Marshal 

func (m *StakePlacement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StakePlacement) XXX_Merge 

func (m *StakePlacement) XXX_Merge(src proto.Message)

func (*StakePlacement) XXX_Size 

func (m *StakePlacement) XXX_Size() int

func (*StakePlacement) XXX_Unmarshal 

func (m *StakePlacement) XXX_Unmarshal(b []byte) error

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"`
}

func (*StakeRemoval) Descriptor 

func (*StakeRemoval) Descriptor() ([]byte, []int)

func (*StakeRemoval) GetPlacements 

func (m *StakeRemoval) GetPlacements() []*StakeRemovalPlacement

func (*StakeRemoval) GetTimestampRemovalStarted 

func (m *StakeRemoval) GetTimestampRemovalStarted() uint64

func (*StakeRemoval) Marshal 

func (m *StakeRemoval) Marshal() (dAtA []byte, err error)

func (*StakeRemoval) MarshalTo 

func (m *StakeRemoval) MarshalTo(dAtA []byte) (int, error)

func (*StakeRemoval) MarshalToSizedBuffer 

func (m *StakeRemoval) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StakeRemoval) ProtoMessage 

func (*StakeRemoval) ProtoMessage()

func (*StakeRemoval) Reset 

func (m *StakeRemoval) Reset()

func (*StakeRemoval) Size 

func (m *StakeRemoval) Size() (n int)

func (*StakeRemoval) String 

func (m *StakeRemoval) String() string

func (*StakeRemoval) Unmarshal 

func (m *StakeRemoval) Unmarshal(dAtA []byte) error

func (*StakeRemoval) XXX_DiscardUnknown 

func (m *StakeRemoval) XXX_DiscardUnknown()

func (*StakeRemoval) XXX_Marshal 

func (m *StakeRemoval) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StakeRemoval) XXX_Merge 

func (m *StakeRemoval) XXX_Merge(src proto.Message)

func (*StakeRemoval) XXX_Size 

func (m *StakeRemoval) XXX_Size() int

func (*StakeRemoval) XXX_Unmarshal 

func (m *StakeRemoval) XXX_Unmarshal(b []byte) error

type StakeRemovalPlacement 

type StakeRemovalPlacement struct {
	TopicIds []uint64               `protobuf:"varint,1,rep,packed,name=topic_ids,json=topicIds,proto3" json:"topic_ids,omitempty"`
	Target   string                 `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Amount   cosmossdk_io_math.Uint `protobuf:"bytes,3,opt,name=amount,proto3,customtype=cosmossdk.io/math.Uint" json:"amount"`
}

func (*StakeRemovalPlacement) Descriptor 

func (*StakeRemovalPlacement) Descriptor() ([]byte, []int)

func (*StakeRemovalPlacement) GetTarget 

func (m *StakeRemovalPlacement) GetTarget() string

func (*StakeRemovalPlacement) GetTopicIds added in v0.0.4 

func (m *StakeRemovalPlacement) GetTopicIds() []uint64

func (*StakeRemovalPlacement) Marshal 

func (m *StakeRemovalPlacement) Marshal() (dAtA []byte, err error)

func (*StakeRemovalPlacement) MarshalTo 

func (m *StakeRemovalPlacement) MarshalTo(dAtA []byte) (int, error)

func (*StakeRemovalPlacement) MarshalToSizedBuffer 

func (m *StakeRemovalPlacement) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StakeRemovalPlacement) ProtoMessage 

func (*StakeRemovalPlacement) ProtoMessage()

func (*StakeRemovalPlacement) Reset 

func (m *StakeRemovalPlacement) Reset()

func (*StakeRemovalPlacement) Size 

func (m *StakeRemovalPlacement) Size() (n int)

func (*StakeRemovalPlacement) String 

func (m *StakeRemovalPlacement) String() string

func (*StakeRemovalPlacement) Unmarshal 

func (m *StakeRemovalPlacement) Unmarshal(dAtA []byte) error

func (*StakeRemovalPlacement) XXX_DiscardUnknown 

func (m *StakeRemovalPlacement) XXX_DiscardUnknown()

func (*StakeRemovalPlacement) XXX_Marshal 

func (m *StakeRemovalPlacement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StakeRemovalPlacement) XXX_Merge 

func (m *StakeRemovalPlacement) XXX_Merge(src proto.Message)

func (*StakeRemovalPlacement) XXX_Size 

func (m *StakeRemovalPlacement) XXX_Size() int

func (*StakeRemovalPlacement) XXX_Unmarshal 

func (m *StakeRemovalPlacement) XXX_Unmarshal(b []byte) error

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"`
}

func (*Topic) Descriptor 

func (*Topic) Descriptor() ([]byte, []int)

func (*Topic) GetActive 

func (m *Topic) GetActive() bool

func (*Topic) GetCreator 

func (m *Topic) GetCreator() string

func (*Topic) GetDefaultArg 

func (m *Topic) GetDefaultArg() string

func (*Topic) GetId 

func (m *Topic) GetId() uint64

func (*Topic) GetInferenceCadence 

func (m *Topic) GetInferenceCadence() uint64

func (*Topic) GetInferenceLastRan 

func (m *Topic) GetInferenceLastRan() uint64

func (*Topic) GetInferenceLogic 

func (m *Topic) GetInferenceLogic() string

func (*Topic) GetInferenceMethod 

func (m *Topic) GetInferenceMethod() string

func (*Topic) GetMetadata 

func (m *Topic) GetMetadata() string

func (*Topic) GetWeightCadence 

func (m *Topic) GetWeightCadence() uint64

func (*Topic) GetWeightLastRan 

func (m *Topic) GetWeightLastRan() uint64

func (*Topic) GetWeightLogic 

func (m *Topic) GetWeightLogic() string

func (*Topic) GetWeightMethod 

func (m *Topic) GetWeightMethod() string

func (*Topic) Marshal 

func (m *Topic) Marshal() (dAtA []byte, err error)

func (*Topic) MarshalTo 

func (m *Topic) MarshalTo(dAtA []byte) (int, error)

func (*Topic) MarshalToSizedBuffer 

func (m *Topic) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) Reset 

func (m *Topic) Reset()

func (*Topic) Size 

func (m *Topic) Size() (n int)

func (*Topic) String 

func (m *Topic) String() string

func (*Topic) Unmarshal 

func (m *Topic) Unmarshal(dAtA []byte) error

func (*Topic) XXX_DiscardUnknown 

func (m *Topic) XXX_DiscardUnknown()

func (*Topic) XXX_Marshal 

func (m *Topic) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Topic) XXX_Merge 

func (m *Topic) XXX_Merge(src proto.Message)

func (*Topic) XXX_Size 

func (m *Topic) XXX_Size() int

func (*Topic) XXX_Unmarshal 

func (m *Topic) XXX_Unmarshal(b []byte) error

type TopicList added in v0.0.4 

type TopicList struct {
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
}

func (*TopicList) Descriptor added in v0.0.4 

func (*TopicList) Descriptor() ([]byte, []int)

func (*TopicList) GetTopics added in v0.0.4 

func (m *TopicList) GetTopics() []*Topic

func (*TopicList) Marshal added in v0.0.4 

func (m *TopicList) Marshal() (dAtA []byte, err error)

func (*TopicList) MarshalTo added in v0.0.4 

func (m *TopicList) MarshalTo(dAtA []byte) (int, error)

func (*TopicList) MarshalToSizedBuffer added in v0.0.4 

func (m *TopicList) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TopicList) ProtoMessage added in v0.0.4 

func (*TopicList) ProtoMessage()

func (*TopicList) Reset added in v0.0.4 

func (m *TopicList) Reset()

func (*TopicList) Size added in v0.0.4 

func (m *TopicList) Size() (n int)

func (*TopicList) String added in v0.0.4 

func (m *TopicList) String() string

func (*TopicList) Unmarshal added in v0.0.4 

func (m *TopicList) Unmarshal(dAtA []byte) error

func (*TopicList) XXX_DiscardUnknown added in v0.0.4 

func (m *TopicList) XXX_DiscardUnknown()

func (*TopicList) XXX_Marshal added in v0.0.4 

func (m *TopicList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TopicList) XXX_Merge added in v0.0.4 

func (m *TopicList) XXX_Merge(src proto.Message)

func (*TopicList) XXX_Size added in v0.0.4 

func (m *TopicList) XXX_Size() int

func (*TopicList) XXX_Unmarshal added in v0.0.4 

func (m *TopicList) XXX_Unmarshal(b []byte) error

type UnimplementedMsgServer 

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AddNewRegistration 

func (*UnimplementedMsgServer) AddNewRegistration(ctx context.Context, req *MsgAddNewRegistration) (*MsgAddNewRegistrationResponse, error)

func (*UnimplementedMsgServer) AddStake 

func (*UnimplementedMsgServer) AddStake(ctx context.Context, req *MsgAddStake) (*MsgAddStakeResponse, error)

func (*UnimplementedMsgServer) AddToTopicCreationWhitelist added in v0.0.1 

func (*UnimplementedMsgServer) AddToTopicCreationWhitelist(ctx context.Context, req *MsgAddToTopicCreationWhitelist) (*MsgAddToTopicCreationWhitelistResponse, error)

func (*UnimplementedMsgServer) AddToWeightSettingWhitelist added in v0.0.1 

func (*UnimplementedMsgServer) AddToWeightSettingWhitelist(ctx context.Context, req *MsgAddToWeightSettingWhitelist) (*MsgAddToWeightSettingWhitelistResponse, error)

func (*UnimplementedMsgServer) AddToWhitelistAdmin added in v0.0.1 

func (*UnimplementedMsgServer) AddToWhitelistAdmin(ctx context.Context, req *MsgAddToWhitelistAdmin) (*MsgAddToWhitelistAdminResponse, error)

func (*UnimplementedMsgServer) ConfirmRemoveStake 

func (*UnimplementedMsgServer) ConfirmRemoveStake(ctx context.Context, req *MsgConfirmRemoveStake) (*MsgConfirmRemoveStakeResponse, error)

func (*UnimplementedMsgServer) CreateNewTopic 

func (*UnimplementedMsgServer) CreateNewTopic(ctx context.Context, req *MsgCreateNewTopic) (*MsgCreateNewTopicResponse, error)

func (*UnimplementedMsgServer) ModifyStake 

func (*UnimplementedMsgServer) ModifyStake(ctx context.Context, req *MsgModifyStake) (*MsgModifyStakeResponse, error)

func (*UnimplementedMsgServer) ProcessInferences 

func (*UnimplementedMsgServer) ProcessInferences(ctx context.Context, req *MsgProcessInferences) (*MsgProcessInferencesResponse, error)

func (*UnimplementedMsgServer) ReactivateTopic added in v0.0.1 

func (*UnimplementedMsgServer) ReactivateTopic(ctx context.Context, req *MsgReactivateTopic) (*MsgReactivateTopicResponse, error)

func (*UnimplementedMsgServer) Register 

func (*UnimplementedMsgServer) Register(ctx context.Context, req *MsgRegister) (*MsgRegisterResponse, error)

func (*UnimplementedMsgServer) RemoveFromTopicCreationWhitelist added in v0.0.1 

func (*UnimplementedMsgServer) RemoveFromTopicCreationWhitelist(ctx context.Context, req *MsgRemoveFromTopicCreationWhitelist) (*MsgRemoveFromTopicCreationWhitelistResponse, error)

func (*UnimplementedMsgServer) RemoveFromWeightSettingWhitelist added in v0.0.1 

func (*UnimplementedMsgServer) RemoveFromWeightSettingWhitelist(ctx context.Context, req *MsgRemoveFromWeightSettingWhitelist) (*MsgRemoveFromWeightSettingWhitelistResponse, error)

func (*UnimplementedMsgServer) RemoveFromWhitelistAdmin added in v0.0.1 

func (*UnimplementedMsgServer) RemoveFromWhitelistAdmin(ctx context.Context, req *MsgRemoveFromWhitelistAdmin) (*MsgRemoveFromWhitelistAdminResponse, error)

func (*UnimplementedMsgServer) RemoveRegistration 

func (*UnimplementedMsgServer) RemoveRegistration(ctx context.Context, req *MsgRemoveRegistration) (*MsgRemoveRegistrationResponse, error)

func (*UnimplementedMsgServer) RequestInference 

func (*UnimplementedMsgServer) RequestInference(ctx context.Context, req *MsgRequestInference) (*MsgRequestInferenceResponse, error)

func (*UnimplementedMsgServer) SetWeights 

func (*UnimplementedMsgServer) SetWeights(ctx context.Context, req *MsgSetWeights) (*MsgSetWeightsResponse, error)

func (*UnimplementedMsgServer) StartRemoveAllStake 

func (*UnimplementedMsgServer) StartRemoveAllStake(ctx context.Context, req *MsgStartRemoveAllStake) (*MsgStartRemoveAllStakeResponse, error)

func (*UnimplementedMsgServer) StartRemoveStake 

func (*UnimplementedMsgServer) StartRemoveStake(ctx context.Context, req *MsgStartRemoveStake) (*MsgStartRemoveStakeResponse, error)

func (*UnimplementedMsgServer) UpdateParams added in v0.0.4 

func (*UnimplementedMsgServer) UpdateParams(ctx context.Context, req *MsgUpdateParams) (*MsgUpdateParamsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetAccountStakeList 

func (*UnimplementedQueryServer) GetAccountStakeList(ctx context.Context, req *QueryAccountStakeListRequest) (*QueryAccountStakeListResponse, error)

func (*UnimplementedQueryServer) GetActiveTopics 

func (*UnimplementedQueryServer) GetActiveTopics(ctx context.Context, req *QueryActiveTopicsRequest) (*QueryActiveTopicsResponse, error)

func (*UnimplementedQueryServer) GetAllExistingInferenceRequests added in v0.0.4 

func (*UnimplementedQueryServer) GetAllExistingInferenceRequests(ctx context.Context, req *QueryAllExistingInferenceRequest) (*QueryAllExistingInferenceResponse, error)

func (*UnimplementedQueryServer) GetAllInferences 

func (*UnimplementedQueryServer) GetAllInferences(ctx context.Context, req *QueryAllInferencesRequest) (*QueryAllInferencesResponse, error)

func (*UnimplementedQueryServer) GetAllTopics added in v0.0.4 

func (*UnimplementedQueryServer) GetAllTopics(ctx context.Context, req *QueryAllTopicsRequest) (*QueryAllTopicsResponse, error)

func (*UnimplementedQueryServer) GetExistingInferenceRequest added in v0.0.4 

func (*UnimplementedQueryServer) GetExistingInferenceRequest(ctx context.Context, req *QueryExistingInferenceRequest) (*QueryExistingInferenceResponse, error)

func (*UnimplementedQueryServer) GetInferencesToScore 

func (*UnimplementedQueryServer) GetInferencesToScore(ctx context.Context, req *QueryInferencesToScoreRequest) (*QueryInferencesToScoreResponse, error)

func (*UnimplementedQueryServer) GetLastRewardsUpdate 

func (*UnimplementedQueryServer) GetLastRewardsUpdate(ctx context.Context, req *QueryLastRewardsUpdateRequest) (*QueryLastRewardsUpdateResponse, error)

func (*UnimplementedQueryServer) GetNextTopicId 

func (*UnimplementedQueryServer) GetNextTopicId(ctx context.Context, req *QueryNextTopicIdRequest) (*QueryNextTopicIdResponse, error)

func (*UnimplementedQueryServer) GetRegisteredTopicIds added in v0.0.4 

func (*UnimplementedQueryServer) GetRegisteredTopicIds(ctx context.Context, req *QueryRegisteredTopicIdsRequest) (*QueryRegisteredTopicIdsResponse, error)

func (*UnimplementedQueryServer) GetTopic 

func (*UnimplementedQueryServer) GetTopic(ctx context.Context, req *QueryTopicRequest) (*QueryTopicResponse, error)

func (*UnimplementedQueryServer) GetTopicUnmetDemand added in v0.0.4 

func (*UnimplementedQueryServer) GetTopicUnmetDemand(ctx context.Context, req *QueryTopicUnmetDemandRequest) (*QueryTopicUnmetDemandResponse, error)

func (*UnimplementedQueryServer) GetTopicsByCreator 

func (*UnimplementedQueryServer) GetTopicsByCreator(ctx context.Context, req *QueryGetTopicsByCreatorRequest) (*QueryGetTopicsByCreatorResponse, error)

func (*UnimplementedQueryServer) GetTotalStake 

func (*UnimplementedQueryServer) GetTotalStake(ctx context.Context, req *QueryTotalStakeRequest) (*QueryTotalStakeResponse, error)

func (*UnimplementedQueryServer) GetWeight 

func (*UnimplementedQueryServer) GetWeight(ctx context.Context, req *QueryWeightRequest) (*QueryWeightResponse, error)

func (*UnimplementedQueryServer) GetWorkerAddressByP2PKey 

func (*UnimplementedQueryServer) GetWorkerAddressByP2PKey(ctx context.Context, req *QueryWorkerAddressByP2PKeyRequest) (*QueryWorkerAddressByP2PKeyResponse, error)

func (*UnimplementedQueryServer) GetWorkerLatestInferenceByTopicId added in v0.0.4 

func (*UnimplementedQueryServer) GetWorkerLatestInferenceByTopicId(ctx context.Context, req *QueryWorkerLatestInferenceRequest) (*QueryWorkerLatestInferenceResponse, error)

func (*UnimplementedQueryServer) GetWorkerNodeRegistration 

func (*UnimplementedQueryServer) GetWorkerNodeRegistration(ctx context.Context, req *QueryRegisteredWorkerNodesRequest) (*QueryRegisteredWorkerNodesResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

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  cosmossdk_io_math.Uint `protobuf:"bytes,4,opt,name=weight,proto3,customtype=cosmossdk.io/math.Uint" json:"weight"`
}

func (*Weight) Descriptor 

func (*Weight) Descriptor() ([]byte, []int)

func (*Weight) Equal 

func (this *Weight) Equal(that interface{}) bool

func (*Weight) GetReputer 

func (m *Weight) GetReputer() string

func (*Weight) GetTopicId 

func (m *Weight) GetTopicId() uint64

func (*Weight) GetWorker 

func (m *Weight) GetWorker() string

func (*Weight) Marshal 

func (m *Weight) Marshal() (dAtA []byte, err error)

func (*Weight) MarshalTo 

func (m *Weight) MarshalTo(dAtA []byte) (int, error)

func (*Weight) MarshalToSizedBuffer 

func (m *Weight) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Weight) ProtoMessage 

func (*Weight) ProtoMessage()

func (*Weight) Reset 

func (m *Weight) Reset()

func (*Weight) Size 

func (m *Weight) Size() (n int)

func (*Weight) String 

func (m *Weight) String() string

func (*Weight) Unmarshal 

func (m *Weight) Unmarshal(dAtA []byte) error

func (*Weight) XXX_DiscardUnknown 

func (m *Weight) XXX_DiscardUnknown()

func (*Weight) XXX_Marshal 

func (m *Weight) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Weight) XXX_Merge 

func (m *Weight) XXX_Merge(src proto.Message)

func (*Weight) XXX_Size 

func (m *Weight) XXX_Size() int

func (*Weight) XXX_Unmarshal 

func (m *Weight) XXX_Unmarshal(b []byte) error

type Weights 

type Weights struct {
	Weights []*Weight `protobuf:"bytes,1,rep,name=weights,proto3" json:"weights,omitempty"`
}

func (*Weights) Descriptor 

func (*Weights) Descriptor() ([]byte, []int)

func (*Weights) GetWeights 

func (m *Weights) GetWeights() []*Weight

func (*Weights) Marshal 

func (m *Weights) Marshal() (dAtA []byte, err error)

func (*Weights) MarshalTo 

func (m *Weights) MarshalTo(dAtA []byte) (int, error)

func (*Weights) MarshalToSizedBuffer 

func (m *Weights) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Weights) ProtoMessage 

func (*Weights) ProtoMessage()

func (*Weights) Reset 

func (m *Weights) Reset()

func (*Weights) Size 

func (m *Weights) Size() (n int)

func (*Weights) String 

func (m *Weights) String() string

func (*Weights) Unmarshal 

func (m *Weights) Unmarshal(dAtA []byte) error

func (*Weights) XXX_DiscardUnknown 

func (m *Weights) XXX_DiscardUnknown()

func (*Weights) XXX_Marshal 

func (m *Weights) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Weights) XXX_Merge 

func (m *Weights) XXX_Merge(src proto.Message)

func (*Weights) XXX_Size 

func (m *Weights) XXX_Size() int

func (*Weights) XXX_Unmarshal 

func (m *Weights) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Directories

Path Synopsis
api
module/v1
Code generated by protoc-gen-go-pulsar.
 Code generated by protoc-gen-go-pulsar.
v1
Code generated by protoc-gen-go-pulsar.
 Code generated by protoc-gen-go-pulsar.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.