emissions

package
v0.0.2 Latest Latest
Warning

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

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

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 AlloraRequestsModuleName = "allorarequests"
View Source
const AlloraStakingModuleName = "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")
)
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)
)
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 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"`
}

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

func (*MsgAddToTopicCreationWhitelistResponse) Size added in v0.0.1

func (*MsgAddToTopicCreationWhitelistResponse) String added in v0.0.1

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

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

func (*MsgAddToWeightSettingWhitelistResponse) Size added in v0.0.1

func (*MsgAddToWeightSettingWhitelistResponse) String added in v0.0.1

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

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

MsgClient is the client API for Msg service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://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 (*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 (*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"`
	TopicsIds    []uint64               `protobuf:"varint,4,rep,packed,name=topics_ids,json=topicsIds,proto3" json:"topics_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) GetTopicsIds

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

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

func (*MsgRemoveFromTopicCreationWhitelist) String added in v0.0.1

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

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

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) MarshalTo added in v0.0.1

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) Size added in v0.0.1

func (*MsgRemoveFromTopicCreationWhitelistResponse) String added in v0.0.1

func (*MsgRemoveFromTopicCreationWhitelistResponse) Unmarshal added in v0.0.1

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

func (*MsgRemoveFromTopicCreationWhitelistResponse) XXX_Unmarshal added in v0.0.1

type MsgRemoveFromWeightSettingWhitelist added in v0.0.1

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

func (*MsgRemoveFromWeightSettingWhitelist) Descriptor added in v0.0.1

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

func (*MsgRemoveFromWeightSettingWhitelist) GetAddress added in v0.0.1

func (*MsgRemoveFromWeightSettingWhitelist) GetSender added in v0.0.1

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

func (*MsgRemoveFromWeightSettingWhitelist) String added in v0.0.1

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

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

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) MarshalTo added in v0.0.1

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) Size added in v0.0.1

func (*MsgRemoveFromWeightSettingWhitelistResponse) String added in v0.0.1

func (*MsgRemoveFromWeightSettingWhitelistResponse) Unmarshal added in v0.0.1

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

func (*MsgRemoveFromWeightSettingWhitelistResponse) XXX_Unmarshal added in v0.0.1

type MsgRemoveFromWhitelistAdmin added in v0.0.1

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

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

func (*MsgRemoveFromWhitelistAdminResponse) String added in v0.0.1

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

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 (*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 {
	SetInferences(context.Context, *MsgSetInferences) (*MsgSetInferencesResponse, error)
	ProcessInferences(context.Context, *MsgProcessInferences) (*MsgProcessInferencesResponse, error)
	SetWeights(context.Context, *MsgSetWeights) (*MsgSetWeightsResponse, error)
	CreateNewTopic(context.Context, *MsgCreateNewTopic) (*MsgCreateNewTopicResponse, error)
	ReactivateTopic(context.Context, *MsgReactivateTopic) (*MsgReactivateTopicResponse, error)
	Register(context.Context, *MsgRegister) (*MsgRegisterResponse, error)
	AddNewRegistration(context.Context, *MsgAddNewRegistration) (*MsgAddNewRegistrationResponse, error)
	RemoveRegistration(context.Context, *MsgRemoveRegistration) (*MsgRemoveRegistrationResponse, error)
	AddStake(context.Context, *MsgAddStake) (*MsgAddStakeResponse, error)
	ModifyStake(context.Context, *MsgModifyStake) (*MsgModifyStakeResponse, error)
	StartRemoveStake(context.Context, *MsgStartRemoveStake) (*MsgStartRemoveStakeResponse, error)
	ConfirmRemoveStake(context.Context, *MsgConfirmRemoveStake) (*MsgConfirmRemoveStakeResponse, error)
	StartRemoveAllStake(context.Context, *MsgStartRemoveAllStake) (*MsgStartRemoveAllStakeResponse, error)
	RequestInference(context.Context, *MsgRequestInference) (*MsgRequestInferenceResponse, error)
	AddToWhitelistAdmin(context.Context, *MsgAddToWhitelistAdmin) (*MsgAddToWhitelistAdminResponse, error)
	RemoveFromWhitelistAdmin(context.Context, *MsgRemoveFromWhitelistAdmin) (*MsgRemoveFromWhitelistAdminResponse, error)
	AddToTopicCreationWhitelist(context.Context, *MsgAddToTopicCreationWhitelist) (*MsgAddToTopicCreationWhitelistResponse, error)
	RemoveFromTopicCreationWhitelist(context.Context, *MsgRemoveFromTopicCreationWhitelist) (*MsgRemoveFromTopicCreationWhitelistResponse, error)
	AddToWeightSettingWhitelist(context.Context, *MsgAddToWeightSettingWhitelist) (*MsgAddToWeightSettingWhitelistResponse, error)
	RemoveFromWeightSettingWhitelist(context.Context, *MsgRemoveFromWeightSettingWhitelist) (*MsgRemoveFromWeightSettingWhitelistResponse, error)
}

MsgServer is the server API for Msg service.

type MsgSetInferences

type MsgSetInferences struct {
	Sender     string       `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Inferences []*Inference `protobuf:"bytes,2,rep,name=inferences,proto3" json:"inferences,omitempty"`
}

MsgSetInferences sets the inferences for a given validator.

func (*MsgSetInferences) Descriptor

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

func (*MsgSetInferences) GetInferences

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

func (*MsgSetInferences) GetSender

func (m *MsgSetInferences) GetSender() string

func (*MsgSetInferences) Marshal

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

func (*MsgSetInferences) MarshalTo

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

func (*MsgSetInferences) MarshalToSizedBuffer

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

func (*MsgSetInferences) ProtoMessage

func (*MsgSetInferences) ProtoMessage()

func (*MsgSetInferences) Reset

func (m *MsgSetInferences) Reset()

func (*MsgSetInferences) Size

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

func (*MsgSetInferences) String

func (m *MsgSetInferences) String() string

func (*MsgSetInferences) Unmarshal

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

func (*MsgSetInferences) XXX_DiscardUnknown

func (m *MsgSetInferences) XXX_DiscardUnknown()

func (*MsgSetInferences) XXX_Marshal

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

func (*MsgSetInferences) XXX_Merge

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

func (*MsgSetInferences) XXX_Size

func (m *MsgSetInferences) XXX_Size() int

func (*MsgSetInferences) XXX_Unmarshal

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

type MsgSetInferencesResponse

type MsgSetInferencesResponse struct {
}

func (*MsgSetInferencesResponse) Descriptor

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

func (*MsgSetInferencesResponse) Marshal

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

func (*MsgSetInferencesResponse) MarshalTo

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

func (*MsgSetInferencesResponse) MarshalToSizedBuffer

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

func (*MsgSetInferencesResponse) ProtoMessage

func (*MsgSetInferencesResponse) ProtoMessage()

func (*MsgSetInferencesResponse) Reset

func (m *MsgSetInferencesResponse) Reset()

func (*MsgSetInferencesResponse) Size

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

func (*MsgSetInferencesResponse) String

func (m *MsgSetInferencesResponse) String() string

func (*MsgSetInferencesResponse) Unmarshal

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

func (*MsgSetInferencesResponse) XXX_DiscardUnknown

func (m *MsgSetInferencesResponse) XXX_DiscardUnknown()

func (*MsgSetInferencesResponse) XXX_Marshal

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

func (*MsgSetInferencesResponse) XXX_Merge

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

func (*MsgSetInferencesResponse) XXX_Size

func (m *MsgSetInferencesResponse) XXX_Size() int

func (*MsgSetInferencesResponse) XXX_Unmarshal

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

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 (*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 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 Params

type Params struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
}

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) 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 (*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 (*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 QueryAccumulatedEpochRewardsRequest

type QueryAccumulatedEpochRewardsRequest struct {
}

Query the amount of rewards accumulated during this epoch

func (*QueryAccumulatedEpochRewardsRequest) Descriptor

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

func (*QueryAccumulatedEpochRewardsRequest) Marshal

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

func (*QueryAccumulatedEpochRewardsRequest) MarshalTo

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

func (*QueryAccumulatedEpochRewardsRequest) MarshalToSizedBuffer

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

func (*QueryAccumulatedEpochRewardsRequest) ProtoMessage

func (*QueryAccumulatedEpochRewardsRequest) ProtoMessage()

func (*QueryAccumulatedEpochRewardsRequest) Reset

func (*QueryAccumulatedEpochRewardsRequest) Size

func (*QueryAccumulatedEpochRewardsRequest) String

func (*QueryAccumulatedEpochRewardsRequest) Unmarshal

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

func (*QueryAccumulatedEpochRewardsRequest) XXX_DiscardUnknown

func (m *QueryAccumulatedEpochRewardsRequest) XXX_DiscardUnknown()

func (*QueryAccumulatedEpochRewardsRequest) XXX_Marshal

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

func (*QueryAccumulatedEpochRewardsRequest) XXX_Merge

func (*QueryAccumulatedEpochRewardsRequest) XXX_Size

func (*QueryAccumulatedEpochRewardsRequest) XXX_Unmarshal

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

type QueryAccumulatedEpochRewardsResponse

type QueryAccumulatedEpochRewardsResponse struct {
	Amount cosmossdk_io_math.Int `protobuf:"bytes,1,opt,name=amount,proto3,customtype=cosmossdk.io/math.Int" json:"amount"`
}

func (*QueryAccumulatedEpochRewardsResponse) Descriptor

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

func (*QueryAccumulatedEpochRewardsResponse) Equal

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

func (*QueryAccumulatedEpochRewardsResponse) Marshal

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

func (*QueryAccumulatedEpochRewardsResponse) MarshalTo

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

func (*QueryAccumulatedEpochRewardsResponse) MarshalToSizedBuffer

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

func (*QueryAccumulatedEpochRewardsResponse) ProtoMessage

func (*QueryAccumulatedEpochRewardsResponse) ProtoMessage()

func (*QueryAccumulatedEpochRewardsResponse) Reset

func (*QueryAccumulatedEpochRewardsResponse) Size

func (*QueryAccumulatedEpochRewardsResponse) String

func (*QueryAccumulatedEpochRewardsResponse) Unmarshal

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

func (*QueryAccumulatedEpochRewardsResponse) XXX_DiscardUnknown

func (m *QueryAccumulatedEpochRewardsResponse) XXX_DiscardUnknown()

func (*QueryAccumulatedEpochRewardsResponse) XXX_Marshal

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

func (*QueryAccumulatedEpochRewardsResponse) XXX_Merge

func (*QueryAccumulatedEpochRewardsResponse) XXX_Size

func (*QueryAccumulatedEpochRewardsResponse) XXX_Unmarshal

func (m *QueryAccumulatedEpochRewardsResponse) 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 QueryClient

type QueryClient interface {
	// Params returns the module parameters.
	Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
	GetLastRewardsUpdate(ctx context.Context, in *QueryLastRewardsUpdateRequest, opts ...grpc.CallOption) (*QueryLastRewardsUpdateResponse, error)
	GetAccumulatedEpochRewards(ctx context.Context, in *QueryAccumulatedEpochRewardsRequest, opts ...grpc.CallOption) (*QueryAccumulatedEpochRewardsResponse, error)
	GetNextTopicId(ctx context.Context, in *QueryNextTopicIdRequest, opts ...grpc.CallOption) (*QueryNextTopicIdResponse, error)
	GetTopic(ctx context.Context, in *QueryTopicRequest, opts ...grpc.CallOption) (*QueryTopicResponse, error)
	GetActiveTopics(ctx context.Context, in *QueryActiveTopicsRequest, opts ...grpc.CallOption) (*QueryActiveTopicsResponse, error)
	GetTopicsByCreator(ctx context.Context, in *QueryGetTopicsByCreatorRequest, opts ...grpc.CallOption) (*QueryGetTopicsByCreatorResponse, error)
	GetWeight(ctx context.Context, in *QueryWeightRequest, opts ...grpc.CallOption) (*QueryWeightResponse, error)
	GetAllInferences(ctx context.Context, in *QueryInferenceRequest, opts ...grpc.CallOption) (*QueryInferenceResponse, error)
	GetInferencesToScore(ctx context.Context, in *QueryInferencesToScoreRequest, opts ...grpc.CallOption) (*QueryInferencesToScoreResponse, error)
	GetTotalStake(ctx context.Context, in *QueryTotalStakeRequest, opts ...grpc.CallOption) (*QueryTotalStakeResponse, error)
	GetAccountStakeList(ctx context.Context, in *QueryAccountStakeListRequest, opts ...grpc.CallOption) (*QueryAccountStakeListResponse, error)
	GetWorkerNodeRegistration(ctx context.Context, in *QueryRegisteredWorkerNodesRequest, opts ...grpc.CallOption) (*QueryRegisteredWorkerNodesResponse, error)
	GetWorkerAddressByP2PKey(ctx context.Context, in *QueryWorkerAddressByP2PKeyRequest, opts ...grpc.CallOption) (*QueryWorkerAddressByP2PKeyResponse, error)
	GetRegisteredTopicsIds(ctx context.Context, in *QueryRegisteredTopicsIdsRequest, opts ...grpc.CallOption) (*QueryRegisteredTopicsIdsResponse, error)
}

QueryClient is the client API for Query service.

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

func NewQueryClient

func NewQueryClient(cc grpc1.ClientConn) QueryClient

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 (*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 (*QueryGetTopicsByCreatorResponse) Size

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

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

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

Returns the latest inference on a topic from a worker

func (*QueryInferenceRequest) Descriptor

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

func (*QueryInferenceRequest) GetTimestamp

func (m *QueryInferenceRequest) GetTimestamp() uint64

func (*QueryInferenceRequest) GetTopicId

func (m *QueryInferenceRequest) GetTopicId() uint64

func (*QueryInferenceRequest) Marshal

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

func (*QueryInferenceRequest) MarshalTo

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

func (*QueryInferenceRequest) MarshalToSizedBuffer

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

func (*QueryInferenceRequest) ProtoMessage

func (*QueryInferenceRequest) ProtoMessage()

func (*QueryInferenceRequest) Reset

func (m *QueryInferenceRequest) Reset()

func (*QueryInferenceRequest) Size

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

func (*QueryInferenceRequest) String

func (m *QueryInferenceRequest) String() string

func (*QueryInferenceRequest) Unmarshal

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

func (*QueryInferenceRequest) XXX_DiscardUnknown

func (m *QueryInferenceRequest) XXX_DiscardUnknown()

func (*QueryInferenceRequest) XXX_Marshal

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

func (*QueryInferenceRequest) XXX_Merge

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

func (*QueryInferenceRequest) XXX_Size

func (m *QueryInferenceRequest) XXX_Size() int

func (*QueryInferenceRequest) XXX_Unmarshal

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

type QueryInferenceResponse

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

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

func (*QueryInferenceResponse) GetInferences

func (m *QueryInferenceResponse) GetInferences() *Inferences

func (*QueryInferenceResponse) Marshal

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

func (*QueryInferenceResponse) MarshalTo

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

func (*QueryInferenceResponse) MarshalToSizedBuffer

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

func (*QueryInferenceResponse) ProtoMessage

func (*QueryInferenceResponse) ProtoMessage()

func (*QueryInferenceResponse) Reset

func (m *QueryInferenceResponse) Reset()

func (*QueryInferenceResponse) Size

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

func (*QueryInferenceResponse) String

func (m *QueryInferenceResponse) String() string

func (*QueryInferenceResponse) Unmarshal

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

func (*QueryInferenceResponse) XXX_DiscardUnknown

func (m *QueryInferenceResponse) XXX_DiscardUnknown()

func (*QueryInferenceResponse) XXX_Marshal

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

func (*QueryInferenceResponse) XXX_Merge

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

func (*QueryInferenceResponse) XXX_Size

func (m *QueryInferenceResponse) XXX_Size() int

func (*QueryInferenceResponse) XXX_Unmarshal

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

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

func (*QueryRegisteredTopicsIdsRequest) Descriptor

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

func (*QueryRegisteredTopicsIdsRequest) GetAddress

func (m *QueryRegisteredTopicsIdsRequest) GetAddress() string

func (*QueryRegisteredTopicsIdsRequest) GetIsReputer

func (m *QueryRegisteredTopicsIdsRequest) GetIsReputer() bool

func (*QueryRegisteredTopicsIdsRequest) Marshal

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

func (*QueryRegisteredTopicsIdsRequest) MarshalTo

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

func (*QueryRegisteredTopicsIdsRequest) MarshalToSizedBuffer

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

func (*QueryRegisteredTopicsIdsRequest) ProtoMessage

func (*QueryRegisteredTopicsIdsRequest) ProtoMessage()

func (*QueryRegisteredTopicsIdsRequest) Reset

func (*QueryRegisteredTopicsIdsRequest) Size

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

func (*QueryRegisteredTopicsIdsRequest) String

func (*QueryRegisteredTopicsIdsRequest) Unmarshal

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

func (*QueryRegisteredTopicsIdsRequest) XXX_DiscardUnknown

func (m *QueryRegisteredTopicsIdsRequest) XXX_DiscardUnknown()

func (*QueryRegisteredTopicsIdsRequest) XXX_Marshal

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

func (*QueryRegisteredTopicsIdsRequest) XXX_Merge

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

func (*QueryRegisteredTopicsIdsRequest) XXX_Size

func (m *QueryRegisteredTopicsIdsRequest) XXX_Size() int

func (*QueryRegisteredTopicsIdsRequest) XXX_Unmarshal

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

type QueryRegisteredTopicsIdsResponse

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

func (*QueryRegisteredTopicsIdsResponse) Descriptor

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

func (*QueryRegisteredTopicsIdsResponse) GetTopicsIds

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

func (*QueryRegisteredTopicsIdsResponse) Marshal

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

func (*QueryRegisteredTopicsIdsResponse) MarshalTo

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

func (*QueryRegisteredTopicsIdsResponse) MarshalToSizedBuffer

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

func (*QueryRegisteredTopicsIdsResponse) ProtoMessage

func (*QueryRegisteredTopicsIdsResponse) ProtoMessage()

func (*QueryRegisteredTopicsIdsResponse) Reset

func (*QueryRegisteredTopicsIdsResponse) Size

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

func (*QueryRegisteredTopicsIdsResponse) String

func (*QueryRegisteredTopicsIdsResponse) Unmarshal

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

func (*QueryRegisteredTopicsIdsResponse) XXX_DiscardUnknown

func (m *QueryRegisteredTopicsIdsResponse) XXX_DiscardUnknown()

func (*QueryRegisteredTopicsIdsResponse) XXX_Marshal

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

func (*QueryRegisteredTopicsIdsResponse) XXX_Merge

func (*QueryRegisteredTopicsIdsResponse) XXX_Size

func (m *QueryRegisteredTopicsIdsResponse) XXX_Size() int

func (*QueryRegisteredTopicsIdsResponse) XXX_Unmarshal

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

type QueryRegisteredWorkerNodesRequest

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

func (*QueryRegisteredWorkerNodesRequest) Descriptor

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

func (*QueryRegisteredWorkerNodesRequest) GetNodeId

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 (*QueryRegisteredWorkerNodesRequest) Size

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

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

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

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)
	GetAccumulatedEpochRewards(context.Context, *QueryAccumulatedEpochRewardsRequest) (*QueryAccumulatedEpochRewardsResponse, error)
	GetNextTopicId(context.Context, *QueryNextTopicIdRequest) (*QueryNextTopicIdResponse, error)
	GetTopic(context.Context, *QueryTopicRequest) (*QueryTopicResponse, error)
	GetActiveTopics(context.Context, *QueryActiveTopicsRequest) (*QueryActiveTopicsResponse, error)
	GetTopicsByCreator(context.Context, *QueryGetTopicsByCreatorRequest) (*QueryGetTopicsByCreatorResponse, error)
	GetWeight(context.Context, *QueryWeightRequest) (*QueryWeightResponse, error)
	GetAllInferences(context.Context, *QueryInferenceRequest) (*QueryInferenceResponse, error)
	GetInferencesToScore(context.Context, *QueryInferencesToScoreRequest) (*QueryInferencesToScoreResponse, error)
	GetTotalStake(context.Context, *QueryTotalStakeRequest) (*QueryTotalStakeResponse, error)
	GetAccountStakeList(context.Context, *QueryAccountStakeListRequest) (*QueryAccountStakeListResponse, error)
	GetWorkerNodeRegistration(context.Context, *QueryRegisteredWorkerNodesRequest) (*QueryRegisteredWorkerNodesResponse, error)
	GetWorkerAddressByP2PKey(context.Context, *QueryWorkerAddressByP2PKeyRequest) (*QueryWorkerAddressByP2PKeyResponse, error)
	GetRegisteredTopicsIds(context.Context, *QueryRegisteredTopicsIdsRequest) (*QueryRegisteredTopicsIdsResponse, error)
}

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 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 (*QueryWorkerAddressByP2PKeyRequest) Size

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

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

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

func (*QueryWorkerAddressByP2PKeyResponse) XXX_Unmarshal

func (m *QueryWorkerAddressByP2PKeyResponse) 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 {
	TopicsIds []uint64               `protobuf:"varint,1,rep,packed,name=topics_ids,json=topicsIds,proto3" json:"topics_ids,omitempty"`
	Target    string                 `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Amount    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) GetTopicsIds

func (m *StakeRemovalPlacement) GetTopicsIds() []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 UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer can be embedded to have forward compatible implementations.

func (*UnimplementedMsgServer) AddNewRegistration

func (*UnimplementedMsgServer) AddStake

func (*UnimplementedMsgServer) AddToTopicCreationWhitelist added in v0.0.1

func (*UnimplementedMsgServer) AddToWeightSettingWhitelist added in v0.0.1

func (*UnimplementedMsgServer) AddToWhitelistAdmin added in v0.0.1

func (*UnimplementedMsgServer) ConfirmRemoveStake

func (*UnimplementedMsgServer) CreateNewTopic

func (*UnimplementedMsgServer) ModifyStake

func (*UnimplementedMsgServer) ProcessInferences

func (*UnimplementedMsgServer) ReactivateTopic added in v0.0.1

func (*UnimplementedMsgServer) Register

func (*UnimplementedMsgServer) RemoveFromTopicCreationWhitelist added in v0.0.1

func (*UnimplementedMsgServer) RemoveFromWeightSettingWhitelist added in v0.0.1

func (*UnimplementedMsgServer) RemoveFromWhitelistAdmin added in v0.0.1

func (*UnimplementedMsgServer) RemoveRegistration

func (*UnimplementedMsgServer) RequestInference

func (*UnimplementedMsgServer) SetInferences

func (*UnimplementedMsgServer) SetWeights

func (*UnimplementedMsgServer) StartRemoveAllStake

func (*UnimplementedMsgServer) StartRemoveStake

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetAccountStakeList

func (*UnimplementedQueryServer) GetActiveTopics

func (*UnimplementedQueryServer) GetAllInferences

func (*UnimplementedQueryServer) GetInferencesToScore

func (*UnimplementedQueryServer) GetLastRewardsUpdate

func (*UnimplementedQueryServer) GetNextTopicId

func (*UnimplementedQueryServer) GetRegisteredTopicsIds

func (*UnimplementedQueryServer) GetTopic

func (*UnimplementedQueryServer) GetTopicsByCreator

func (*UnimplementedQueryServer) GetTotalStake

func (*UnimplementedQueryServer) GetWeight

func (*UnimplementedQueryServer) Params

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

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