emissions

package
v0.0.0-dev.0 Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2024 License: Apache-2.0 Imports: 29 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 ModuleName = "emissions"

Variables

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)
	AllInferencesKey      = collections.NewPrefix(18)
)
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")
)
View Source 
var ErrAddressNotRegistered = fmt.Errorf(Err_ErrAddressNotRegistered.String())
View Source 
var ErrBlockHeightLessThanPrevious = fmt.Errorf(Err_ErrBlockHeightLessThanPrevious.String())
View Source 
var ErrBlockHeightNegative = fmt.Errorf(Err_ErrBlockHeightNegative.String())
View Source 
var ErrDivideMapValuesByZero = fmt.Errorf(Err_ErrDivideMapValuesByZero.String())
View Source 
var ErrDoNotSetMapValueToZero = fmt.Errorf(Err_ErrDoNotSetMapValueToZero.String())
View Source 
var ErrInsufficientStakeToRegister = fmt.Errorf(Err_ErrInsufficientStakeToRegister.String())
View Source 
var ErrInsufficientStakeToRemove = fmt.Errorf(Err_ErrInsufficientStakeToRemove.String())
View Source 
var ErrIntegerUnderflowBonds = errors.New(Err_ErrIntegerUnderflowBonds.String())
View Source 
var ErrIntegerUnderflowDelegator = errors.New(Err_ErrIntegerUnderflowDelegator.String())
View Source 
var ErrIntegerUnderflowTarget = errors.New(Err_ErrIntegerUnderflowTarget.String())
View Source 
var ErrIntegerUnderflowTopicStake = errors.New(Err_ErrIntegerUnderflowTopicStake.String())
View Source 
var ErrIntegerUnderflowTotalStake = errors.New(Err_ErrIntegerUnderflowTotalStake.String())
View Source 
var ErrInvalidTopicId = fmt.Errorf(Err_ErrInvalidTopicId.String())
View Source 
var ErrIterationLengthDoesNotMatch = errors.New(Err_ErrIterationLengthDoesNotMatch.String())
View Source 
var ErrLibP2PKeyRequired = fmt.Errorf(Err_ErrLibP2PKeyRequired.String())
View Source 
var ErrModifyStakeBeforeBondLessThanAmountModified = fmt.Errorf(Err_ErrModifyStakeBeforeBondLessThanAmountModified.String())
View Source 
var ErrModifyStakeBeforeSumGreaterThanSenderStake = fmt.Errorf(Err_ErrModifyStakeBeforeSumGreaterThanSenderStake.String())
View Source 
var ErrModifyStakeSumBeforeNotEqualToSumAfter = fmt.Errorf(Err_ErrModifyStakeSumBeforeNotEqualToSumAfter.String())
View Source 
var ErrNoStakeToRemove = fmt.Errorf(Err_ErrNoStakeToRemove.String())
View Source 
var ErrReputerAlreadyRegistered = fmt.Errorf(Err_ErrReputerAlreadyRegistered.String())
View Source 
var ErrScalarMultiplyNegative = fmt.Errorf(Err_ErrScalarMultiplyNegative.String())
View Source 
var ErrStakeTargetNotRegistered = fmt.Errorf(Err_ErrStakeTargetNotRegistered.String())
View Source 
var ErrTopicIdOfStakerAndTargetDoNotMatch = fmt.Errorf(Err_ErrInvalidTopicId.String())
View Source 
var ErrWorkerAlreadyRegistered = fmt.Errorf(Err_ErrWorkerAlreadyRegistered.String())
View Source 
var Err_name = map[int32]string{
	0:  "ErrInvalidTopicId",
	1:  "ErrReputerAlreadyRegistered",
	2:  "ErrWorkerAlreadyRegistered",
	3:  "ErrInsufficientStakeToRegister",
	4:  "ErrLibP2PKeyRequired",
	5:  "ErrAddressNotRegistered",
	6:  "ErrStakeTargetNotRegistered",
	7:  "ErrTopicIdOfStakerAndTargetDoNotMatch",
	8:  "ErrInsufficientStakeToRemove",
	9:  "ErrIntegerUnderflowDelegator",
	10: "ErrIntegerUnderflowBonds",
	11: "ErrIntegerUnderflowTarget",
	12: "ErrIntegerUnderflowTopicStake",
	13: "ErrIntegerUnderflowTotalStake",
	14: "ErrIterationLengthDoesNotMatch",
	15: "ErrDoNotSetMapValueToZero",
	16: "ErrBlockHeightNegative",
	17: "ErrBlockHeightLessThanPrevious",
	18: "ErrNoStakeToRemove",
	19: "ErrModifyStakeBeforeBondLessThanAmountModified",
	20: "ErrModifyStakeBeforeSumGreaterThanSenderStake",
	21: "ErrModifyStakeSumBeforeNotEqualToSumAfter",
	23: "ErrScalarMultiplyNegative",
	24: "ErrDivideMapValuesByZero",
}
View Source 
var Err_value = map[string]int32{
	"ErrInvalidTopicId":                              0,
	"ErrReputerAlreadyRegistered":                    1,
	"ErrWorkerAlreadyRegistered":                     2,
	"ErrInsufficientStakeToRegister":                 3,
	"ErrLibP2PKeyRequired":                           4,
	"ErrAddressNotRegistered":                        5,
	"ErrStakeTargetNotRegistered":                    6,
	"ErrTopicIdOfStakerAndTargetDoNotMatch":          7,
	"ErrInsufficientStakeToRemove":                   8,
	"ErrIntegerUnderflowDelegator":                   9,
	"ErrIntegerUnderflowBonds":                       10,
	"ErrIntegerUnderflowTarget":                      11,
	"ErrIntegerUnderflowTopicStake":                  12,
	"ErrIntegerUnderflowTotalStake":                  13,
	"ErrIterationLengthDoesNotMatch":                 14,
	"ErrDoNotSetMapValueToZero":                      15,
	"ErrBlockHeightNegative":                         16,
	"ErrBlockHeightLessThanPrevious":                 17,
	"ErrNoStakeToRemove":                             18,
	"ErrModifyStakeBeforeBondLessThanAmountModified": 19,
	"ErrModifyStakeBeforeSumGreaterThanSenderStake":  20,
	"ErrModifyStakeSumBeforeNotEqualToSumAfter":      21,
	"ErrScalarMultiplyNegative":                      23,
	"ErrDivideMapValuesByZero":                       24,
}

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 Err 

type Err int32
const (
	Err_ErrInvalidTopicId                              Err = 0
	Err_ErrReputerAlreadyRegistered                    Err = 1
	Err_ErrWorkerAlreadyRegistered                     Err = 2
	Err_ErrInsufficientStakeToRegister                 Err = 3
	Err_ErrLibP2PKeyRequired                           Err = 4
	Err_ErrAddressNotRegistered                        Err = 5
	Err_ErrStakeTargetNotRegistered                    Err = 6
	Err_ErrTopicIdOfStakerAndTargetDoNotMatch          Err = 7
	Err_ErrInsufficientStakeToRemove                   Err = 8
	Err_ErrIntegerUnderflowDelegator                   Err = 9
	Err_ErrIntegerUnderflowBonds                       Err = 10
	Err_ErrIntegerUnderflowTarget                      Err = 11
	Err_ErrIntegerUnderflowTopicStake                  Err = 12
	Err_ErrIntegerUnderflowTotalStake                  Err = 13
	Err_ErrIterationLengthDoesNotMatch                 Err = 14
	Err_ErrDoNotSetMapValueToZero                      Err = 15
	Err_ErrBlockHeightNegative                         Err = 16
	Err_ErrBlockHeightLessThanPrevious                 Err = 17
	Err_ErrNoStakeToRemove                             Err = 18
	Err_ErrModifyStakeBeforeBondLessThanAmountModified Err = 19
	Err_ErrModifyStakeBeforeSumGreaterThanSenderStake  Err = 20
	Err_ErrModifyStakeSumBeforeNotEqualToSumAfter      Err = 21
	Err_ErrScalarMultiplyNegative                      Err = 23
	Err_ErrDivideMapValuesByZero                       Err = 24
)

func (Err) EnumDescriptor 

func (Err) EnumDescriptor() ([]byte, []int)

func (Err) String 

func (x Err) String() string

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

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 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)
	SetLatestInferencesTimestamp(ctx context.Context, in *MsgSetLatestInferencesTimestamp, opts ...grpc.CallOption) (*MsgSetLatestInferencesTimestampResponse, error)
	SetWeights(ctx context.Context, in *MsgSetWeights, opts ...grpc.CallOption) (*MsgSetWeightsResponse, error)
	CreateNewTopic(ctx context.Context, in *MsgCreateNewTopic, opts ...grpc.CallOption) (*MsgCreateNewTopicResponse, error)
	RegisterReputer(ctx context.Context, in *MsgRegisterReputer, opts ...grpc.CallOption) (*MsgRegisterReputerResponse, error)
	RegisterWorker(ctx context.Context, in *MsgRegisterWorker, opts ...grpc.CallOption) (*MsgRegisterWorkerResponse, error)
	AddStake(ctx context.Context, in *MsgAddStake, opts ...grpc.CallOption) (*MsgAddStakeResponse, error)
	ModifyStake(ctx context.Context, in *MsgModifyStake, opts ...grpc.CallOption) (*MsgModifyStakeResponse, error)
	RemoveStake(ctx context.Context, in *MsgRemoveStake, opts ...grpc.CallOption) (*MsgRemoveStakeResponse, error)
	RemoveAllStake(ctx context.Context, in *MsgRemoveAllStake, opts ...grpc.CallOption) (*MsgRemoveAllStakeResponse, 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 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"`
	Active           bool   `protobuf:"varint,9,opt,name=active,proto3" json:"active,omitempty"`
}

func (*MsgCreateNewTopic) Descriptor 

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

func (*MsgCreateNewTopic) GetActive 

func (m *MsgCreateNewTopic) GetActive() bool

func (*MsgCreateNewTopic) GetCreator 

func (m *MsgCreateNewTopic) GetCreator() string

func (*MsgCreateNewTopic) GetInferenceCadence 

func (m *MsgCreateNewTopic) GetInferenceCadence() uint64

func (*MsgCreateNewTopic) GetInferenceLogic 

func (m *MsgCreateNewTopic) GetInferenceLogic() string

func (*MsgCreateNewTopic) GetInferenceMethod 

func (m *MsgCreateNewTopic) GetInferenceMethod() string

func (*MsgCreateNewTopic) GetMetadata 

func (m *MsgCreateNewTopic) GetMetadata() string

func (*MsgCreateNewTopic) GetWeightCadence 

func (m *MsgCreateNewTopic) GetWeightCadence() uint64

func (*MsgCreateNewTopic) GetWeightLogic 

func (m *MsgCreateNewTopic) GetWeightLogic() string

func (*MsgCreateNewTopic) GetWeightMethod 

func (m *MsgCreateNewTopic) GetWeightMethod() string

func (*MsgCreateNewTopic) Marshal 

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

func (*MsgCreateNewTopic) MarshalTo 

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

func (*MsgCreateNewTopic) MarshalToSizedBuffer 

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

func (*MsgCreateNewTopic) ProtoMessage 

func (*MsgCreateNewTopic) ProtoMessage()

func (*MsgCreateNewTopic) Reset 

func (m *MsgCreateNewTopic) Reset()

func (*MsgCreateNewTopic) Size 

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

func (*MsgCreateNewTopic) String 

func (m *MsgCreateNewTopic) String() string

func (*MsgCreateNewTopic) Unmarshal 

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

func (*MsgCreateNewTopic) XXX_DiscardUnknown 

func (m *MsgCreateNewTopic) XXX_DiscardUnknown()

func (*MsgCreateNewTopic) XXX_Marshal 

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

func (*MsgCreateNewTopic) XXX_Merge 

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

func (*MsgCreateNewTopic) XXX_Size 

func (m *MsgCreateNewTopic) XXX_Size() int

func (*MsgCreateNewTopic) XXX_Unmarshal 

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

type MsgCreateNewTopicResponse 

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

func (*MsgCreateNewTopicResponse) Descriptor 

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

func (*MsgCreateNewTopicResponse) GetTopicId 

func (m *MsgCreateNewTopicResponse) GetTopicId() uint64

func (*MsgCreateNewTopicResponse) Marshal 

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

func (*MsgCreateNewTopicResponse) MarshalTo 

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

func (*MsgCreateNewTopicResponse) MarshalToSizedBuffer 

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

func (*MsgCreateNewTopicResponse) ProtoMessage 

func (*MsgCreateNewTopicResponse) ProtoMessage()

func (*MsgCreateNewTopicResponse) Reset 

func (m *MsgCreateNewTopicResponse) Reset()

func (*MsgCreateNewTopicResponse) Size 

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

func (*MsgCreateNewTopicResponse) String 

func (m *MsgCreateNewTopicResponse) String() string

func (*MsgCreateNewTopicResponse) Unmarshal 

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

func (*MsgCreateNewTopicResponse) XXX_DiscardUnknown 

func (m *MsgCreateNewTopicResponse) XXX_DiscardUnknown()

func (*MsgCreateNewTopicResponse) XXX_Marshal 

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

func (*MsgCreateNewTopicResponse) XXX_Merge 

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

func (*MsgCreateNewTopicResponse) XXX_Size 

func (m *MsgCreateNewTopicResponse) XXX_Size() int

func (*MsgCreateNewTopicResponse) XXX_Unmarshal 

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

type MsgModifyStake 

type MsgModifyStake struct {
	Sender           string            `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	PlacementsRemove []*StakePlacement `protobuf:"bytes,2,rep,name=placements_remove,json=placementsRemove,proto3" json:"placements_remove,omitempty"`
	PlacementsAdd    []*StakePlacement `protobuf:"bytes,3,rep,name=placements_add,json=placementsAdd,proto3" json:"placements_add,omitempty"`
}

func (*MsgModifyStake) Descriptor 

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

func (*MsgModifyStake) GetPlacementsAdd 

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

func (*MsgModifyStake) GetPlacementsRemove 

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

func (*MsgModifyStake) GetSender 

func (m *MsgModifyStake) GetSender() string

func (*MsgModifyStake) Marshal 

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

func (*MsgModifyStake) MarshalTo 

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

func (*MsgModifyStake) MarshalToSizedBuffer 

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

func (*MsgModifyStake) ProtoMessage 

func (*MsgModifyStake) ProtoMessage()

func (*MsgModifyStake) Reset 

func (m *MsgModifyStake) Reset()

func (*MsgModifyStake) Size 

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

func (*MsgModifyStake) String 

func (m *MsgModifyStake) String() string

func (*MsgModifyStake) Unmarshal 

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

func (*MsgModifyStake) XXX_DiscardUnknown 

func (m *MsgModifyStake) XXX_DiscardUnknown()

func (*MsgModifyStake) XXX_Marshal 

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

func (*MsgModifyStake) XXX_Merge 

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

func (*MsgModifyStake) XXX_Size 

func (m *MsgModifyStake) XXX_Size() int

func (*MsgModifyStake) XXX_Unmarshal 

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

type MsgModifyStakeResponse 

type MsgModifyStakeResponse struct {
}

func (*MsgModifyStakeResponse) Descriptor 

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

func (*MsgModifyStakeResponse) Marshal 

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

func (*MsgModifyStakeResponse) MarshalTo 

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

func (*MsgModifyStakeResponse) MarshalToSizedBuffer 

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

func (*MsgModifyStakeResponse) ProtoMessage 

func (*MsgModifyStakeResponse) ProtoMessage()

func (*MsgModifyStakeResponse) Reset 

func (m *MsgModifyStakeResponse) Reset()

func (*MsgModifyStakeResponse) Size 

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

func (*MsgModifyStakeResponse) String 

func (m *MsgModifyStakeResponse) String() string

func (*MsgModifyStakeResponse) Unmarshal 

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

func (*MsgModifyStakeResponse) XXX_DiscardUnknown 

func (m *MsgModifyStakeResponse) XXX_DiscardUnknown()

func (*MsgModifyStakeResponse) XXX_Marshal 

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

func (*MsgModifyStakeResponse) XXX_Merge 

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

func (*MsgModifyStakeResponse) XXX_Size 

func (m *MsgModifyStakeResponse) XXX_Size() int

func (*MsgModifyStakeResponse) XXX_Unmarshal 

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

type MsgProcessInferences 

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

func (*MsgProcessInferences) Descriptor 

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

func (*MsgProcessInferences) GetInferences 

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

func (*MsgProcessInferences) GetSender 

func (m *MsgProcessInferences) GetSender() string

func (*MsgProcessInferences) Marshal 

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

func (*MsgProcessInferences) MarshalTo 

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

func (*MsgProcessInferences) MarshalToSizedBuffer 

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

func (*MsgProcessInferences) ProtoMessage 

func (*MsgProcessInferences) ProtoMessage()

func (*MsgProcessInferences) Reset 

func (m *MsgProcessInferences) Reset()

func (*MsgProcessInferences) Size 

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

func (*MsgProcessInferences) String 

func (m *MsgProcessInferences) String() string

func (*MsgProcessInferences) Unmarshal 

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

func (*MsgProcessInferences) XXX_DiscardUnknown 

func (m *MsgProcessInferences) XXX_DiscardUnknown()

func (*MsgProcessInferences) XXX_Marshal 

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

func (*MsgProcessInferences) XXX_Merge 

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

func (*MsgProcessInferences) XXX_Size 

func (m *MsgProcessInferences) XXX_Size() int

func (*MsgProcessInferences) XXX_Unmarshal 

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

type MsgProcessInferencesResponse 

type MsgProcessInferencesResponse struct {
}

func (*MsgProcessInferencesResponse) Descriptor 

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

func (*MsgProcessInferencesResponse) Marshal 

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

func (*MsgProcessInferencesResponse) MarshalTo 

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

func (*MsgProcessInferencesResponse) MarshalToSizedBuffer 

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

func (*MsgProcessInferencesResponse) ProtoMessage 

func (*MsgProcessInferencesResponse) ProtoMessage()

func (*MsgProcessInferencesResponse) Reset 

func (m *MsgProcessInferencesResponse) Reset()

func (*MsgProcessInferencesResponse) Size 

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

func (*MsgProcessInferencesResponse) String 

func (m *MsgProcessInferencesResponse) String() string

func (*MsgProcessInferencesResponse) Unmarshal 

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

func (*MsgProcessInferencesResponse) XXX_DiscardUnknown 

func (m *MsgProcessInferencesResponse) XXX_DiscardUnknown()

func (*MsgProcessInferencesResponse) XXX_Marshal 

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

func (*MsgProcessInferencesResponse) XXX_Merge 

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

func (*MsgProcessInferencesResponse) XXX_Size 

func (m *MsgProcessInferencesResponse) XXX_Size() int

func (*MsgProcessInferencesResponse) XXX_Unmarshal 

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

type MsgRegisterReputer 

type MsgRegisterReputer 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"`
	InitialStake cosmossdk_io_math.Uint `protobuf:"bytes,5,opt,name=initial_stake,json=initialStake,proto3,customtype=cosmossdk.io/math.Uint" json:"initial_stake"`
}

Message for registering an Inference compute node

func (*MsgRegisterReputer) Descriptor 

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

func (*MsgRegisterReputer) GetCreator 

func (m *MsgRegisterReputer) GetCreator() string

func (*MsgRegisterReputer) GetInitialStake 

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

func (*MsgRegisterReputer) GetLibP2PKey 

func (m *MsgRegisterReputer) GetLibP2PKey() string

func (*MsgRegisterReputer) GetMultiAddress 

func (m *MsgRegisterReputer) GetMultiAddress() string

func (*MsgRegisterReputer) GetTopicId 

func (m *MsgRegisterReputer) GetTopicId() uint64

func (*MsgRegisterReputer) Marshal 

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

func (*MsgRegisterReputer) MarshalTo 

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

func (*MsgRegisterReputer) MarshalToSizedBuffer 

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

func (*MsgRegisterReputer) ProtoMessage 

func (*MsgRegisterReputer) ProtoMessage()

func (*MsgRegisterReputer) Reset 

func (m *MsgRegisterReputer) Reset()

func (*MsgRegisterReputer) Size 

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

func (*MsgRegisterReputer) String 

func (m *MsgRegisterReputer) String() string

func (*MsgRegisterReputer) Unmarshal 

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

func (*MsgRegisterReputer) XXX_DiscardUnknown 

func (m *MsgRegisterReputer) XXX_DiscardUnknown()

func (*MsgRegisterReputer) XXX_Marshal 

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

func (*MsgRegisterReputer) XXX_Merge 

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

func (*MsgRegisterReputer) XXX_Size 

func (m *MsgRegisterReputer) XXX_Size() int

func (*MsgRegisterReputer) XXX_Unmarshal 

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

type MsgRegisterReputerResponse 

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

Response for registering an Inference compute node

func (*MsgRegisterReputerResponse) Descriptor 

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

func (*MsgRegisterReputerResponse) GetMessage 

func (m *MsgRegisterReputerResponse) GetMessage() string

func (*MsgRegisterReputerResponse) GetSuccess 

func (m *MsgRegisterReputerResponse) GetSuccess() bool

func (*MsgRegisterReputerResponse) Marshal 

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

func (*MsgRegisterReputerResponse) MarshalTo 

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

func (*MsgRegisterReputerResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterReputerResponse) ProtoMessage 

func (*MsgRegisterReputerResponse) ProtoMessage()

func (*MsgRegisterReputerResponse) Reset 

func (m *MsgRegisterReputerResponse) Reset()

func (*MsgRegisterReputerResponse) Size 

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

func (*MsgRegisterReputerResponse) String 

func (m *MsgRegisterReputerResponse) String() string

func (*MsgRegisterReputerResponse) Unmarshal 

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

func (*MsgRegisterReputerResponse) XXX_DiscardUnknown 

func (m *MsgRegisterReputerResponse) XXX_DiscardUnknown()

func (*MsgRegisterReputerResponse) XXX_Marshal 

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

func (*MsgRegisterReputerResponse) XXX_Merge 

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

func (*MsgRegisterReputerResponse) XXX_Size 

func (m *MsgRegisterReputerResponse) XXX_Size() int

func (*MsgRegisterReputerResponse) XXX_Unmarshal 

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

type MsgRegisterWorker 

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

Message for registering an Inference compute node

func (*MsgRegisterWorker) Descriptor 

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

func (*MsgRegisterWorker) GetCreator 

func (m *MsgRegisterWorker) GetCreator() string

func (*MsgRegisterWorker) GetInitialStake 

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

func (*MsgRegisterWorker) GetLibP2PKey 

func (m *MsgRegisterWorker) GetLibP2PKey() string

func (*MsgRegisterWorker) GetMultiAddress 

func (m *MsgRegisterWorker) GetMultiAddress() string

func (*MsgRegisterWorker) GetOwner 

func (m *MsgRegisterWorker) GetOwner() string

func (*MsgRegisterWorker) GetTopicId 

func (m *MsgRegisterWorker) GetTopicId() uint64

func (*MsgRegisterWorker) Marshal 

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

func (*MsgRegisterWorker) MarshalTo 

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

func (*MsgRegisterWorker) MarshalToSizedBuffer 

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

func (*MsgRegisterWorker) ProtoMessage 

func (*MsgRegisterWorker) ProtoMessage()

func (*MsgRegisterWorker) Reset 

func (m *MsgRegisterWorker) Reset()

func (*MsgRegisterWorker) Size 

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

func (*MsgRegisterWorker) String 

func (m *MsgRegisterWorker) String() string

func (*MsgRegisterWorker) Unmarshal 

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

func (*MsgRegisterWorker) XXX_DiscardUnknown 

func (m *MsgRegisterWorker) XXX_DiscardUnknown()

func (*MsgRegisterWorker) XXX_Marshal 

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

func (*MsgRegisterWorker) XXX_Merge 

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

func (*MsgRegisterWorker) XXX_Size 

func (m *MsgRegisterWorker) XXX_Size() int

func (*MsgRegisterWorker) XXX_Unmarshal 

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

type MsgRegisterWorkerResponse 

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

Response for registering an Inference compute node

func (*MsgRegisterWorkerResponse) Descriptor 

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

func (*MsgRegisterWorkerResponse) GetMessage 

func (m *MsgRegisterWorkerResponse) GetMessage() string

func (*MsgRegisterWorkerResponse) GetSuccess 

func (m *MsgRegisterWorkerResponse) GetSuccess() bool

func (*MsgRegisterWorkerResponse) Marshal 

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

func (*MsgRegisterWorkerResponse) MarshalTo 

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

func (*MsgRegisterWorkerResponse) MarshalToSizedBuffer 

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

func (*MsgRegisterWorkerResponse) ProtoMessage 

func (*MsgRegisterWorkerResponse) ProtoMessage()

func (*MsgRegisterWorkerResponse) Reset 

func (m *MsgRegisterWorkerResponse) Reset()

func (*MsgRegisterWorkerResponse) Size 

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

func (*MsgRegisterWorkerResponse) String 

func (m *MsgRegisterWorkerResponse) String() string

func (*MsgRegisterWorkerResponse) Unmarshal 

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

func (*MsgRegisterWorkerResponse) XXX_DiscardUnknown 

func (m *MsgRegisterWorkerResponse) XXX_DiscardUnknown()

func (*MsgRegisterWorkerResponse) XXX_Marshal 

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

func (*MsgRegisterWorkerResponse) XXX_Merge 

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

func (*MsgRegisterWorkerResponse) XXX_Size 

func (m *MsgRegisterWorkerResponse) XXX_Size() int

func (*MsgRegisterWorkerResponse) XXX_Unmarshal 

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

type MsgRemoveAllStake 

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

func (*MsgRemoveAllStake) Descriptor 

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

func (*MsgRemoveAllStake) GetSender 

func (m *MsgRemoveAllStake) GetSender() string

func (*MsgRemoveAllStake) Marshal 

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

func (*MsgRemoveAllStake) MarshalTo 

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

func (*MsgRemoveAllStake) MarshalToSizedBuffer 

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

func (*MsgRemoveAllStake) ProtoMessage 

func (*MsgRemoveAllStake) ProtoMessage()

func (*MsgRemoveAllStake) Reset 

func (m *MsgRemoveAllStake) Reset()

func (*MsgRemoveAllStake) Size 

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

func (*MsgRemoveAllStake) String 

func (m *MsgRemoveAllStake) String() string

func (*MsgRemoveAllStake) Unmarshal 

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

func (*MsgRemoveAllStake) XXX_DiscardUnknown 

func (m *MsgRemoveAllStake) XXX_DiscardUnknown()

func (*MsgRemoveAllStake) XXX_Marshal 

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

func (*MsgRemoveAllStake) XXX_Merge 

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

func (*MsgRemoveAllStake) XXX_Size 

func (m *MsgRemoveAllStake) XXX_Size() int

func (*MsgRemoveAllStake) XXX_Unmarshal 

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

type MsgRemoveAllStakeResponse 

type MsgRemoveAllStakeResponse struct {
}

func (*MsgRemoveAllStakeResponse) Descriptor 

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

func (*MsgRemoveAllStakeResponse) Marshal 

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

func (*MsgRemoveAllStakeResponse) MarshalTo 

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

func (*MsgRemoveAllStakeResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveAllStakeResponse) ProtoMessage 

func (*MsgRemoveAllStakeResponse) ProtoMessage()

func (*MsgRemoveAllStakeResponse) Reset 

func (m *MsgRemoveAllStakeResponse) Reset()

func (*MsgRemoveAllStakeResponse) Size 

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

func (*MsgRemoveAllStakeResponse) String 

func (m *MsgRemoveAllStakeResponse) String() string

func (*MsgRemoveAllStakeResponse) Unmarshal 

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

func (*MsgRemoveAllStakeResponse) XXX_DiscardUnknown 

func (m *MsgRemoveAllStakeResponse) XXX_DiscardUnknown()

func (*MsgRemoveAllStakeResponse) XXX_Marshal 

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

func (*MsgRemoveAllStakeResponse) XXX_Merge 

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

func (*MsgRemoveAllStakeResponse) XXX_Size 

func (m *MsgRemoveAllStakeResponse) XXX_Size() int

func (*MsgRemoveAllStakeResponse) XXX_Unmarshal 

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

type MsgRemoveStake 

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

func (*MsgRemoveStake) Descriptor 

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

func (*MsgRemoveStake) GetSender 

func (m *MsgRemoveStake) GetSender() string

func (*MsgRemoveStake) GetStakeTarget 

func (m *MsgRemoveStake) GetStakeTarget() string

func (*MsgRemoveStake) Marshal 

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

func (*MsgRemoveStake) MarshalTo 

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

func (*MsgRemoveStake) MarshalToSizedBuffer 

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

func (*MsgRemoveStake) ProtoMessage 

func (*MsgRemoveStake) ProtoMessage()

func (*MsgRemoveStake) Reset 

func (m *MsgRemoveStake) Reset()

func (*MsgRemoveStake) Size 

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

func (*MsgRemoveStake) String 

func (m *MsgRemoveStake) String() string

func (*MsgRemoveStake) Unmarshal 

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

func (*MsgRemoveStake) XXX_DiscardUnknown 

func (m *MsgRemoveStake) XXX_DiscardUnknown()

func (*MsgRemoveStake) XXX_Marshal 

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

func (*MsgRemoveStake) XXX_Merge 

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

func (*MsgRemoveStake) XXX_Size 

func (m *MsgRemoveStake) XXX_Size() int

func (*MsgRemoveStake) XXX_Unmarshal 

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

type MsgRemoveStakeResponse 

type MsgRemoveStakeResponse struct {
}

func (*MsgRemoveStakeResponse) Descriptor 

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

func (*MsgRemoveStakeResponse) Marshal 

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

func (*MsgRemoveStakeResponse) MarshalTo 

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

func (*MsgRemoveStakeResponse) MarshalToSizedBuffer 

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

func (*MsgRemoveStakeResponse) ProtoMessage 

func (*MsgRemoveStakeResponse) ProtoMessage()

func (*MsgRemoveStakeResponse) Reset 

func (m *MsgRemoveStakeResponse) Reset()

func (*MsgRemoveStakeResponse) Size 

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

func (*MsgRemoveStakeResponse) String 

func (m *MsgRemoveStakeResponse) String() string

func (*MsgRemoveStakeResponse) Unmarshal 

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

func (*MsgRemoveStakeResponse) XXX_DiscardUnknown 

func (m *MsgRemoveStakeResponse) XXX_DiscardUnknown()

func (*MsgRemoveStakeResponse) XXX_Marshal 

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

func (*MsgRemoveStakeResponse) XXX_Merge 

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

func (*MsgRemoveStakeResponse) XXX_Size 

func (m *MsgRemoveStakeResponse) XXX_Size() int

func (*MsgRemoveStakeResponse) XXX_Unmarshal 

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

type MsgServer 

type MsgServer interface {
	SetInferences(context.Context, *MsgSetInferences) (*MsgSetInferencesResponse, error)
	ProcessInferences(context.Context, *MsgProcessInferences) (*MsgProcessInferencesResponse, error)
	SetLatestInferencesTimestamp(context.Context, *MsgSetLatestInferencesTimestamp) (*MsgSetLatestInferencesTimestampResponse, error)
	SetWeights(context.Context, *MsgSetWeights) (*MsgSetWeightsResponse, error)
	CreateNewTopic(context.Context, *MsgCreateNewTopic) (*MsgCreateNewTopicResponse, error)
	RegisterReputer(context.Context, *MsgRegisterReputer) (*MsgRegisterReputerResponse, error)
	RegisterWorker(context.Context, *MsgRegisterWorker) (*MsgRegisterWorkerResponse, error)
	AddStake(context.Context, *MsgAddStake) (*MsgAddStakeResponse, error)
	ModifyStake(context.Context, *MsgModifyStake) (*MsgModifyStakeResponse, error)
	RemoveStake(context.Context, *MsgRemoveStake) (*MsgRemoveStakeResponse, error)
	RemoveAllStake(context.Context, *MsgRemoveAllStake) (*MsgRemoveAllStakeResponse, 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 MsgSetLatestInferencesTimestamp 

type MsgSetLatestInferencesTimestamp 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"`
	InferenceTimestamp uint64 `protobuf:"varint,3,opt,name=inference_timestamp,json=inferenceTimestamp,proto3" json:"inference_timestamp,omitempty"`
}

func (*MsgSetLatestInferencesTimestamp) Descriptor 

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

func (*MsgSetLatestInferencesTimestamp) GetInferenceTimestamp 

func (m *MsgSetLatestInferencesTimestamp) GetInferenceTimestamp() uint64

func (*MsgSetLatestInferencesTimestamp) GetSender 

func (m *MsgSetLatestInferencesTimestamp) GetSender() string

func (*MsgSetLatestInferencesTimestamp) GetTopicId 

func (m *MsgSetLatestInferencesTimestamp) GetTopicId() uint64

func (*MsgSetLatestInferencesTimestamp) Marshal 

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

func (*MsgSetLatestInferencesTimestamp) MarshalTo 

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

func (*MsgSetLatestInferencesTimestamp) MarshalToSizedBuffer 

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

func (*MsgSetLatestInferencesTimestamp) ProtoMessage 

func (*MsgSetLatestInferencesTimestamp) ProtoMessage()

func (*MsgSetLatestInferencesTimestamp) Reset 

func (m *MsgSetLatestInferencesTimestamp) Reset()

func (*MsgSetLatestInferencesTimestamp) Size 

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

func (*MsgSetLatestInferencesTimestamp) String 

func (m *MsgSetLatestInferencesTimestamp) String() string

func (*MsgSetLatestInferencesTimestamp) Unmarshal 

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

func (*MsgSetLatestInferencesTimestamp) XXX_DiscardUnknown 

func (m *MsgSetLatestInferencesTimestamp) XXX_DiscardUnknown()

func (*MsgSetLatestInferencesTimestamp) XXX_Marshal 

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

func (*MsgSetLatestInferencesTimestamp) XXX_Merge 

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

func (*MsgSetLatestInferencesTimestamp) XXX_Size 

func (m *MsgSetLatestInferencesTimestamp) XXX_Size() int

func (*MsgSetLatestInferencesTimestamp) XXX_Unmarshal 

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

type MsgSetLatestInferencesTimestampResponse 

type MsgSetLatestInferencesTimestampResponse struct {
}

func (*MsgSetLatestInferencesTimestampResponse) Descriptor 

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

func (*MsgSetLatestInferencesTimestampResponse) Marshal 

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

func (*MsgSetLatestInferencesTimestampResponse) MarshalTo 

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

func (*MsgSetLatestInferencesTimestampResponse) MarshalToSizedBuffer 

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

func (*MsgSetLatestInferencesTimestampResponse) ProtoMessage 

func (*MsgSetLatestInferencesTimestampResponse) ProtoMessage()

func (*MsgSetLatestInferencesTimestampResponse) Reset 

func (m *MsgSetLatestInferencesTimestampResponse) Reset()

func (*MsgSetLatestInferencesTimestampResponse) Size 

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

func (*MsgSetLatestInferencesTimestampResponse) String 

func (m *MsgSetLatestInferencesTimestampResponse) String() string

func (*MsgSetLatestInferencesTimestampResponse) Unmarshal 

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

func (*MsgSetLatestInferencesTimestampResponse) XXX_DiscardUnknown 

func (m *MsgSetLatestInferencesTimestampResponse) XXX_DiscardUnknown()

func (*MsgSetLatestInferencesTimestampResponse) XXX_Marshal 

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

func (*MsgSetLatestInferencesTimestampResponse) XXX_Merge 

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

func (*MsgSetLatestInferencesTimestampResponse) XXX_Size 

func (m *MsgSetLatestInferencesTimestampResponse) XXX_Size() int

func (*MsgSetLatestInferencesTimestampResponse) XXX_Unmarshal 

func (m *MsgSetLatestInferencesTimestampResponse) 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 OffchainNode 

type OffchainNode struct {
	TopicId      uint64 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,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"`
	Owner        string `protobuf:"bytes,4,opt,name=owner,proto3" json:"owner,omitempty"`
	NodeAddress  string `protobuf:"bytes,5,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	NodeId       string `protobuf:"bytes,6,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) GetTopicId 

func (m *OffchainNode) GetTopicId() uint64

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 (m *QueryAccountStakeListRequest) String() string

func (*QueryAccountStakeListRequest) Unmarshal 

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

func (*QueryAccountStakeListRequest) XXX_DiscardUnknown 

func (m *QueryAccountStakeListRequest) XXX_DiscardUnknown()

func (*QueryAccountStakeListRequest) XXX_Marshal 

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

func (*QueryAccountStakeListRequest) XXX_Merge 

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

func (*QueryAccountStakeListRequest) XXX_Size 

func (m *QueryAccountStakeListRequest) XXX_Size() int

func (*QueryAccountStakeListRequest) XXX_Unmarshal 

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

type QueryAccountStakeListResponse 

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

func (*QueryAccountStakeListResponse) Descriptor 

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

func (*QueryAccountStakeListResponse) GetStakes 

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

func (*QueryAccountStakeListResponse) Marshal 

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

func (*QueryAccountStakeListResponse) MarshalTo 

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

func (*QueryAccountStakeListResponse) MarshalToSizedBuffer 

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

func (*QueryAccountStakeListResponse) ProtoMessage 

func (*QueryAccountStakeListResponse) ProtoMessage()

func (*QueryAccountStakeListResponse) Reset 

func (m *QueryAccountStakeListResponse) Reset()

func (*QueryAccountStakeListResponse) Size 

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

func (*QueryAccountStakeListResponse) String 

func (m *QueryAccountStakeListResponse) String() string

func (*QueryAccountStakeListResponse) Unmarshal 

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

func (*QueryAccountStakeListResponse) XXX_DiscardUnknown 

func (m *QueryAccountStakeListResponse) XXX_DiscardUnknown()

func (*QueryAccountStakeListResponse) XXX_Marshal 

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

func (*QueryAccountStakeListResponse) XXX_Merge 

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

func (*QueryAccountStakeListResponse) XXX_Size 

func (m *QueryAccountStakeListResponse) XXX_Size() int

func (*QueryAccountStakeListResponse) XXX_Unmarshal 

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

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

func (*QueryAccumulatedEpochRewardsRequest) Size 

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

func (*QueryAccumulatedEpochRewardsRequest) String 

func (m *QueryAccumulatedEpochRewardsRequest) String() 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 (m *QueryAccumulatedEpochRewardsRequest) XXX_Merge(src proto.Message)

func (*QueryAccumulatedEpochRewardsRequest) XXX_Size 

func (m *QueryAccumulatedEpochRewardsRequest) XXX_Size() int

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

func (*QueryAccumulatedEpochRewardsResponse) Size 

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

func (*QueryAccumulatedEpochRewardsResponse) String 

func (m *QueryAccumulatedEpochRewardsResponse) String() 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 (m *QueryAccumulatedEpochRewardsResponse) XXX_Merge(src proto.Message)

func (*QueryAccumulatedEpochRewardsResponse) XXX_Size 

func (m *QueryAccumulatedEpochRewardsResponse) XXX_Size() int

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)
}

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 (m *QueryGetTopicsByCreatorRequest) String() string

func (*QueryGetTopicsByCreatorRequest) Unmarshal 

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

func (*QueryGetTopicsByCreatorRequest) XXX_DiscardUnknown 

func (m *QueryGetTopicsByCreatorRequest) XXX_DiscardUnknown()

func (*QueryGetTopicsByCreatorRequest) XXX_Marshal 

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

func (*QueryGetTopicsByCreatorRequest) XXX_Merge 

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

func (*QueryGetTopicsByCreatorRequest) XXX_Size 

func (m *QueryGetTopicsByCreatorRequest) XXX_Size() int

func (*QueryGetTopicsByCreatorRequest) XXX_Unmarshal 

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

type QueryGetTopicsByCreatorResponse 

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

func (*QueryGetTopicsByCreatorResponse) Descriptor 

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

func (*QueryGetTopicsByCreatorResponse) GetTopics 

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

func (*QueryGetTopicsByCreatorResponse) Marshal 

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

func (*QueryGetTopicsByCreatorResponse) MarshalTo 

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

func (*QueryGetTopicsByCreatorResponse) MarshalToSizedBuffer 

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

func (*QueryGetTopicsByCreatorResponse) ProtoMessage 

func (*QueryGetTopicsByCreatorResponse) ProtoMessage()

func (*QueryGetTopicsByCreatorResponse) Reset 

func (m *QueryGetTopicsByCreatorResponse) Reset()

func (*QueryGetTopicsByCreatorResponse) Size 

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

func (*QueryGetTopicsByCreatorResponse) String 

func (m *QueryGetTopicsByCreatorResponse) String() string

func (*QueryGetTopicsByCreatorResponse) Unmarshal 

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

func (*QueryGetTopicsByCreatorResponse) XXX_DiscardUnknown 

func (m *QueryGetTopicsByCreatorResponse) XXX_DiscardUnknown()

func (*QueryGetTopicsByCreatorResponse) XXX_Marshal 

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

func (*QueryGetTopicsByCreatorResponse) XXX_Merge 

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

func (*QueryGetTopicsByCreatorResponse) XXX_Size 

func (m *QueryGetTopicsByCreatorResponse) XXX_Size() int

func (*QueryGetTopicsByCreatorResponse) XXX_Unmarshal 

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

type 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 (m *QueryInferencesToScoreRequest) String() string

func (*QueryInferencesToScoreRequest) Unmarshal 

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

func (*QueryInferencesToScoreRequest) XXX_DiscardUnknown 

func (m *QueryInferencesToScoreRequest) XXX_DiscardUnknown()

func (*QueryInferencesToScoreRequest) XXX_Marshal 

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

func (*QueryInferencesToScoreRequest) XXX_Merge 

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

func (*QueryInferencesToScoreRequest) XXX_Size 

func (m *QueryInferencesToScoreRequest) XXX_Size() int

func (*QueryInferencesToScoreRequest) XXX_Unmarshal 

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

type QueryInferencesToScoreResponse 

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

func (*QueryInferencesToScoreResponse) Descriptor 

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

func (*QueryInferencesToScoreResponse) GetInferences 

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

func (*QueryInferencesToScoreResponse) Marshal 

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

func (*QueryInferencesToScoreResponse) MarshalTo 

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

func (*QueryInferencesToScoreResponse) MarshalToSizedBuffer 

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

func (*QueryInferencesToScoreResponse) ProtoMessage 

func (*QueryInferencesToScoreResponse) ProtoMessage()

func (*QueryInferencesToScoreResponse) Reset 

func (m *QueryInferencesToScoreResponse) Reset()

func (*QueryInferencesToScoreResponse) Size 

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

func (*QueryInferencesToScoreResponse) String 

func (m *QueryInferencesToScoreResponse) String() string

func (*QueryInferencesToScoreResponse) Unmarshal 

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

func (*QueryInferencesToScoreResponse) XXX_DiscardUnknown 

func (m *QueryInferencesToScoreResponse) XXX_DiscardUnknown()

func (*QueryInferencesToScoreResponse) XXX_Marshal 

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

func (*QueryInferencesToScoreResponse) XXX_Merge 

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

func (*QueryInferencesToScoreResponse) XXX_Size 

func (m *QueryInferencesToScoreResponse) XXX_Size() int

func (*QueryInferencesToScoreResponse) XXX_Unmarshal 

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

type QueryLastRewardsUpdateRequest 

type QueryLastRewardsUpdateRequest struct {
}

returns the last time the rewards inflation calculation ran

func (*QueryLastRewardsUpdateRequest) Descriptor 

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

func (*QueryLastRewardsUpdateRequest) Marshal 

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

func (*QueryLastRewardsUpdateRequest) MarshalTo 

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

func (*QueryLastRewardsUpdateRequest) MarshalToSizedBuffer 

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

func (*QueryLastRewardsUpdateRequest) ProtoMessage 

func (*QueryLastRewardsUpdateRequest) ProtoMessage()

func (*QueryLastRewardsUpdateRequest) Reset 

func (m *QueryLastRewardsUpdateRequest) Reset()

func (*QueryLastRewardsUpdateRequest) Size 

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

func (*QueryLastRewardsUpdateRequest) String 

func (m *QueryLastRewardsUpdateRequest) String() string

func (*QueryLastRewardsUpdateRequest) Unmarshal 

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

func (*QueryLastRewardsUpdateRequest) XXX_DiscardUnknown 

func (m *QueryLastRewardsUpdateRequest) XXX_DiscardUnknown()

func (*QueryLastRewardsUpdateRequest) XXX_Marshal 

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

func (*QueryLastRewardsUpdateRequest) XXX_Merge 

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

func (*QueryLastRewardsUpdateRequest) XXX_Size 

func (m *QueryLastRewardsUpdateRequest) XXX_Size() int

func (*QueryLastRewardsUpdateRequest) XXX_Unmarshal 

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

type QueryLastRewardsUpdateResponse 

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

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

func (*QueryLastRewardsUpdateResponse) Descriptor 

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

func (*QueryLastRewardsUpdateResponse) GetLastRewardsUpdate 

func (m *QueryLastRewardsUpdateResponse) GetLastRewardsUpdate() int64

func (*QueryLastRewardsUpdateResponse) Marshal 

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

func (*QueryLastRewardsUpdateResponse) MarshalTo 

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

func (*QueryLastRewardsUpdateResponse) MarshalToSizedBuffer 

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

func (*QueryLastRewardsUpdateResponse) ProtoMessage 

func (*QueryLastRewardsUpdateResponse) ProtoMessage()

func (*QueryLastRewardsUpdateResponse) Reset 

func (m *QueryLastRewardsUpdateResponse) Reset()

func (*QueryLastRewardsUpdateResponse) Size 

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

func (*QueryLastRewardsUpdateResponse) String 

func (m *QueryLastRewardsUpdateResponse) String() string

func (*QueryLastRewardsUpdateResponse) Unmarshal 

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

func (*QueryLastRewardsUpdateResponse) XXX_DiscardUnknown 

func (m *QueryLastRewardsUpdateResponse) XXX_DiscardUnknown()

func (*QueryLastRewardsUpdateResponse) XXX_Marshal 

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

func (*QueryLastRewardsUpdateResponse) XXX_Merge 

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

func (*QueryLastRewardsUpdateResponse) XXX_Size 

func (m *QueryLastRewardsUpdateResponse) XXX_Size() int

func (*QueryLastRewardsUpdateResponse) XXX_Unmarshal 

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

type QueryNextTopicIdRequest 

type QueryNextTopicIdRequest struct {
}

func (*QueryNextTopicIdRequest) Descriptor 

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

func (*QueryNextTopicIdRequest) Marshal 

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

func (*QueryNextTopicIdRequest) MarshalTo 

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

func (*QueryNextTopicIdRequest) MarshalToSizedBuffer 

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

func (*QueryNextTopicIdRequest) ProtoMessage 

func (*QueryNextTopicIdRequest) ProtoMessage()

func (*QueryNextTopicIdRequest) Reset 

func (m *QueryNextTopicIdRequest) Reset()

func (*QueryNextTopicIdRequest) Size 

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

func (*QueryNextTopicIdRequest) String 

func (m *QueryNextTopicIdRequest) String() string

func (*QueryNextTopicIdRequest) Unmarshal 

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

func (*QueryNextTopicIdRequest) XXX_DiscardUnknown 

func (m *QueryNextTopicIdRequest) XXX_DiscardUnknown()

func (*QueryNextTopicIdRequest) XXX_Marshal 

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

func (*QueryNextTopicIdRequest) XXX_Merge 

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

func (*QueryNextTopicIdRequest) XXX_Size 

func (m *QueryNextTopicIdRequest) XXX_Size() int

func (*QueryNextTopicIdRequest) XXX_Unmarshal 

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

type QueryNextTopicIdResponse 

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

func (*QueryNextTopicIdResponse) Descriptor 

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

func (*QueryNextTopicIdResponse) GetNextTopicId 

func (m *QueryNextTopicIdResponse) GetNextTopicId() uint64

func (*QueryNextTopicIdResponse) Marshal 

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

func (*QueryNextTopicIdResponse) MarshalTo 

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

func (*QueryNextTopicIdResponse) MarshalToSizedBuffer 

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

func (*QueryNextTopicIdResponse) ProtoMessage 

func (*QueryNextTopicIdResponse) ProtoMessage()

func (*QueryNextTopicIdResponse) Reset 

func (m *QueryNextTopicIdResponse) Reset()

func (*QueryNextTopicIdResponse) Size 

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

func (*QueryNextTopicIdResponse) String 

func (m *QueryNextTopicIdResponse) String() string

func (*QueryNextTopicIdResponse) Unmarshal 

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

func (*QueryNextTopicIdResponse) XXX_DiscardUnknown 

func (m *QueryNextTopicIdResponse) XXX_DiscardUnknown()

func (*QueryNextTopicIdResponse) XXX_Marshal 

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

func (*QueryNextTopicIdResponse) XXX_Merge 

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

func (*QueryNextTopicIdResponse) XXX_Size 

func (m *QueryNextTopicIdResponse) XXX_Size() int

func (*QueryNextTopicIdResponse) XXX_Unmarshal 

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

type QueryParamsRequest 

type QueryParamsRequest struct {
}

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

func (*QueryParamsRequest) Descriptor 

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

func (*QueryParamsRequest) Marshal 

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

func (*QueryParamsRequest) MarshalTo 

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

func (*QueryParamsRequest) MarshalToSizedBuffer 

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

func (*QueryParamsRequest) ProtoMessage 

func (*QueryParamsRequest) ProtoMessage()

func (*QueryParamsRequest) Reset 

func (m *QueryParamsRequest) Reset()

func (*QueryParamsRequest) Size 

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

func (*QueryParamsRequest) String 

func (m *QueryParamsRequest) String() string

func (*QueryParamsRequest) Unmarshal 

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

func (*QueryParamsRequest) XXX_DiscardUnknown 

func (m *QueryParamsRequest) XXX_DiscardUnknown()

func (*QueryParamsRequest) XXX_Marshal 

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

func (*QueryParamsRequest) XXX_Merge 

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

func (*QueryParamsRequest) XXX_Size 

func (m *QueryParamsRequest) XXX_Size() int

func (*QueryParamsRequest) XXX_Unmarshal 

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

type QueryParamsResponse 

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

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

func (*QueryParamsResponse) Descriptor 

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

func (*QueryParamsResponse) GetParams 

func (m *QueryParamsResponse) GetParams() Params

func (*QueryParamsResponse) Marshal 

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

func (*QueryParamsResponse) MarshalTo 

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

func (*QueryParamsResponse) MarshalToSizedBuffer 

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

func (*QueryParamsResponse) ProtoMessage 

func (*QueryParamsResponse) ProtoMessage()

func (*QueryParamsResponse) Reset 

func (m *QueryParamsResponse) Reset()

func (*QueryParamsResponse) Size 

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

func (*QueryParamsResponse) String 

func (m *QueryParamsResponse) String() string

func (*QueryParamsResponse) Unmarshal 

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

func (*QueryParamsResponse) XXX_DiscardUnknown 

func (m *QueryParamsResponse) XXX_DiscardUnknown()

func (*QueryParamsResponse) XXX_Marshal 

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

func (*QueryParamsResponse) XXX_Merge 

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

func (*QueryParamsResponse) XXX_Size 

func (m *QueryParamsResponse) XXX_Size() int

func (*QueryParamsResponse) XXX_Unmarshal 

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

type 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 (m *QueryRegisteredWorkerNodesRequest) GetNodeId() string

func (*QueryRegisteredWorkerNodesRequest) Marshal 

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

func (*QueryRegisteredWorkerNodesRequest) MarshalTo 

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

func (*QueryRegisteredWorkerNodesRequest) MarshalToSizedBuffer 

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

func (*QueryRegisteredWorkerNodesRequest) ProtoMessage 

func (*QueryRegisteredWorkerNodesRequest) ProtoMessage()

func (*QueryRegisteredWorkerNodesRequest) Reset 

func (m *QueryRegisteredWorkerNodesRequest) Reset()

func (*QueryRegisteredWorkerNodesRequest) Size 

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

func (*QueryRegisteredWorkerNodesRequest) String 

func (m *QueryRegisteredWorkerNodesRequest) String() string

func (*QueryRegisteredWorkerNodesRequest) Unmarshal 

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

func (*QueryRegisteredWorkerNodesRequest) XXX_DiscardUnknown 

func (m *QueryRegisteredWorkerNodesRequest) XXX_DiscardUnknown()

func (*QueryRegisteredWorkerNodesRequest) XXX_Marshal 

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

func (*QueryRegisteredWorkerNodesRequest) XXX_Merge 

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

func (*QueryRegisteredWorkerNodesRequest) XXX_Size 

func (m *QueryRegisteredWorkerNodesRequest) XXX_Size() int

func (*QueryRegisteredWorkerNodesRequest) XXX_Unmarshal 

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

type QueryRegisteredWorkerNodesResponse 

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

func (*QueryRegisteredWorkerNodesResponse) Descriptor 

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

func (*QueryRegisteredWorkerNodesResponse) GetNodes 

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

func (*QueryRegisteredWorkerNodesResponse) Marshal 

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

func (*QueryRegisteredWorkerNodesResponse) MarshalTo 

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

func (*QueryRegisteredWorkerNodesResponse) MarshalToSizedBuffer 

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

func (*QueryRegisteredWorkerNodesResponse) ProtoMessage 

func (*QueryRegisteredWorkerNodesResponse) ProtoMessage()

func (*QueryRegisteredWorkerNodesResponse) Reset 

func (m *QueryRegisteredWorkerNodesResponse) Reset()

func (*QueryRegisteredWorkerNodesResponse) Size 

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

func (*QueryRegisteredWorkerNodesResponse) String 

func (m *QueryRegisteredWorkerNodesResponse) String() string

func (*QueryRegisteredWorkerNodesResponse) Unmarshal 

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

func (*QueryRegisteredWorkerNodesResponse) XXX_DiscardUnknown 

func (m *QueryRegisteredWorkerNodesResponse) XXX_DiscardUnknown()

func (*QueryRegisteredWorkerNodesResponse) XXX_Marshal 

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

func (*QueryRegisteredWorkerNodesResponse) XXX_Merge 

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

func (*QueryRegisteredWorkerNodesResponse) XXX_Size 

func (m *QueryRegisteredWorkerNodesResponse) XXX_Size() int

func (*QueryRegisteredWorkerNodesResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Params returns the module parameters.
	Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
	GetLastRewardsUpdate(context.Context, *QueryLastRewardsUpdateRequest) (*QueryLastRewardsUpdateResponse, error)
	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)
}

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

func (*QueryWorkerAddressByP2PKeyRequest) Size 

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

func (*QueryWorkerAddressByP2PKeyRequest) String 

func (m *QueryWorkerAddressByP2PKeyRequest) String() string

func (*QueryWorkerAddressByP2PKeyRequest) Unmarshal 

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

func (*QueryWorkerAddressByP2PKeyRequest) XXX_DiscardUnknown 

func (m *QueryWorkerAddressByP2PKeyRequest) XXX_DiscardUnknown()

func (*QueryWorkerAddressByP2PKeyRequest) XXX_Marshal 

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

func (*QueryWorkerAddressByP2PKeyRequest) XXX_Merge 

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

func (*QueryWorkerAddressByP2PKeyRequest) XXX_Size 

func (m *QueryWorkerAddressByP2PKeyRequest) XXX_Size() int

func (*QueryWorkerAddressByP2PKeyRequest) XXX_Unmarshal 

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

type QueryWorkerAddressByP2PKeyResponse 

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

func (*QueryWorkerAddressByP2PKeyResponse) Descriptor 

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

func (*QueryWorkerAddressByP2PKeyResponse) GetAddress 

func (m *QueryWorkerAddressByP2PKeyResponse) GetAddress() string

func (*QueryWorkerAddressByP2PKeyResponse) Marshal 

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

func (*QueryWorkerAddressByP2PKeyResponse) MarshalTo 

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

func (*QueryWorkerAddressByP2PKeyResponse) MarshalToSizedBuffer 

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

func (*QueryWorkerAddressByP2PKeyResponse) ProtoMessage 

func (*QueryWorkerAddressByP2PKeyResponse) ProtoMessage()

func (*QueryWorkerAddressByP2PKeyResponse) Reset 

func (m *QueryWorkerAddressByP2PKeyResponse) Reset()

func (*QueryWorkerAddressByP2PKeyResponse) Size 

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

func (*QueryWorkerAddressByP2PKeyResponse) String 

func (m *QueryWorkerAddressByP2PKeyResponse) String() string

func (*QueryWorkerAddressByP2PKeyResponse) Unmarshal 

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

func (*QueryWorkerAddressByP2PKeyResponse) XXX_DiscardUnknown 

func (m *QueryWorkerAddressByP2PKeyResponse) XXX_DiscardUnknown()

func (*QueryWorkerAddressByP2PKeyResponse) XXX_Marshal 

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

func (*QueryWorkerAddressByP2PKeyResponse) XXX_Merge 

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

func (*QueryWorkerAddressByP2PKeyResponse) XXX_Size 

func (m *QueryWorkerAddressByP2PKeyResponse) XXX_Size() int

func (*QueryWorkerAddressByP2PKeyResponse) XXX_Unmarshal 

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

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

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) 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) AddStake 

func (*UnimplementedMsgServer) AddStake(ctx context.Context, req *MsgAddStake) (*MsgAddStakeResponse, error)

func (*UnimplementedMsgServer) CreateNewTopic 

func (*UnimplementedMsgServer) CreateNewTopic(ctx context.Context, req *MsgCreateNewTopic) (*MsgCreateNewTopicResponse, error)

func (*UnimplementedMsgServer) ModifyStake 

func (*UnimplementedMsgServer) ModifyStake(ctx context.Context, req *MsgModifyStake) (*MsgModifyStakeResponse, error)

func (*UnimplementedMsgServer) ProcessInferences 

func (*UnimplementedMsgServer) ProcessInferences(ctx context.Context, req *MsgProcessInferences) (*MsgProcessInferencesResponse, error)

func (*UnimplementedMsgServer) RegisterReputer 

func (*UnimplementedMsgServer) RegisterReputer(ctx context.Context, req *MsgRegisterReputer) (*MsgRegisterReputerResponse, error)

func (*UnimplementedMsgServer) RegisterWorker 

func (*UnimplementedMsgServer) RegisterWorker(ctx context.Context, req *MsgRegisterWorker) (*MsgRegisterWorkerResponse, error)

func (*UnimplementedMsgServer) RemoveAllStake 

func (*UnimplementedMsgServer) RemoveAllStake(ctx context.Context, req *MsgRemoveAllStake) (*MsgRemoveAllStakeResponse, error)

func (*UnimplementedMsgServer) RemoveStake 

func (*UnimplementedMsgServer) RemoveStake(ctx context.Context, req *MsgRemoveStake) (*MsgRemoveStakeResponse, error)

func (*UnimplementedMsgServer) SetInferences 

func (*UnimplementedMsgServer) SetInferences(ctx context.Context, req *MsgSetInferences) (*MsgSetInferencesResponse, error)

func (*UnimplementedMsgServer) SetLatestInferencesTimestamp 

func (*UnimplementedMsgServer) SetLatestInferencesTimestamp(ctx context.Context, req *MsgSetLatestInferencesTimestamp) (*MsgSetLatestInferencesTimestampResponse, error)

func (*UnimplementedMsgServer) SetWeights 

func (*UnimplementedMsgServer) SetWeights(ctx context.Context, req *MsgSetWeights) (*MsgSetWeightsResponse, error)

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) GetAccountStakeList 

func (*UnimplementedQueryServer) GetAccountStakeList(ctx context.Context, req *QueryAccountStakeListRequest) (*QueryAccountStakeListResponse, error)

func (*UnimplementedQueryServer) GetAccumulatedEpochRewards 

func (*UnimplementedQueryServer) GetAccumulatedEpochRewards(ctx context.Context, req *QueryAccumulatedEpochRewardsRequest) (*QueryAccumulatedEpochRewardsResponse, error)

func (*UnimplementedQueryServer) GetActiveTopics 

func (*UnimplementedQueryServer) GetActiveTopics(ctx context.Context, req *QueryActiveTopicsRequest) (*QueryActiveTopicsResponse, error)

func (*UnimplementedQueryServer) GetAllInferences 

func (*UnimplementedQueryServer) GetAllInferences(ctx context.Context, req *QueryInferenceRequest) (*QueryInferenceResponse, error)

func (*UnimplementedQueryServer) GetInferencesToScore 

func (*UnimplementedQueryServer) GetInferencesToScore(ctx context.Context, req *QueryInferencesToScoreRequest) (*QueryInferencesToScoreResponse, error)

func (*UnimplementedQueryServer) GetLastRewardsUpdate 

func (*UnimplementedQueryServer) GetLastRewardsUpdate(ctx context.Context, req *QueryLastRewardsUpdateRequest) (*QueryLastRewardsUpdateResponse, error)

func (*UnimplementedQueryServer) GetNextTopicId 

func (*UnimplementedQueryServer) GetNextTopicId(ctx context.Context, req *QueryNextTopicIdRequest) (*QueryNextTopicIdResponse, error)

func (*UnimplementedQueryServer) GetTopic 

func (*UnimplementedQueryServer) GetTopic(ctx context.Context, req *QueryTopicRequest) (*QueryTopicResponse, error)

func (*UnimplementedQueryServer) GetTopicsByCreator 

func (*UnimplementedQueryServer) GetTopicsByCreator(ctx context.Context, req *QueryGetTopicsByCreatorRequest) (*QueryGetTopicsByCreatorResponse, error)

func (*UnimplementedQueryServer) GetTotalStake 

func (*UnimplementedQueryServer) GetTotalStake(ctx context.Context, req *QueryTotalStakeRequest) (*QueryTotalStakeResponse, error)

func (*UnimplementedQueryServer) GetWeight 

func (*UnimplementedQueryServer) GetWeight(ctx context.Context, req *QueryWeightRequest) (*QueryWeightResponse, error)

func (*UnimplementedQueryServer) GetWorkerAddressByP2PKey 

func (*UnimplementedQueryServer) GetWorkerAddressByP2PKey(ctx context.Context, req *QueryWorkerAddressByP2PKeyRequest) (*QueryWorkerAddressByP2PKeyResponse, error)

func (*UnimplementedQueryServer) GetWorkerNodeRegistration 

func (*UnimplementedQueryServer) GetWorkerNodeRegistration(ctx context.Context, req *QueryRegisteredWorkerNodesRequest) (*QueryRegisteredWorkerNodesResponse, error)

func (*UnimplementedQueryServer) Params 

func (*UnimplementedQueryServer) Params(ctx context.Context, req *QueryParamsRequest) (*QueryParamsResponse, error)

type Weight 

type Weight struct {
	TopicId uint64                 `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	Reputer string                 `protobuf:"bytes,2,opt,name=reputer,proto3" json:"reputer,omitempty"`
	Worker  string                 `protobuf:"bytes,3,opt,name=worker,proto3" json:"worker,omitempty"`
	Weight  cosmossdk_io_math.Uint `protobuf:"bytes,4,opt,name=weight,proto3,customtype=cosmossdk.io/math.Uint" json:"weight"`
}

func (*Weight) Descriptor 

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

func (*Weight) Equal 

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

func (*Weight) GetReputer 

func (m *Weight) GetReputer() string

func (*Weight) GetTopicId 

func (m *Weight) GetTopicId() uint64

func (*Weight) GetWorker 

func (m *Weight) GetWorker() string

func (*Weight) Marshal 

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

func (*Weight) MarshalTo 

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

func (*Weight) MarshalToSizedBuffer 

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

func (*Weight) ProtoMessage 

func (*Weight) ProtoMessage()

func (*Weight) Reset 

func (m *Weight) Reset()

func (*Weight) Size 

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

func (*Weight) String 

func (m *Weight) String() string

func (*Weight) Unmarshal 

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

func (*Weight) XXX_DiscardUnknown 

func (m *Weight) XXX_DiscardUnknown()

func (*Weight) XXX_Marshal 

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

func (*Weight) XXX_Merge 

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

func (*Weight) XXX_Size 

func (m *Weight) XXX_Size() int

func (*Weight) XXX_Unmarshal 

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

type Weights 

type Weights struct {
	Weights []*Weight `protobuf:"bytes,1,rep,name=weights,proto3" json:"weights,omitempty"`
}

func (*Weights) Descriptor 

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

func (*Weights) GetWeights 

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

func (*Weights) Marshal 

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

func (*Weights) MarshalTo 

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

func (*Weights) MarshalToSizedBuffer 

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

func (*Weights) ProtoMessage 

func (*Weights) ProtoMessage()

func (*Weights) Reset 

func (m *Weights) Reset()

func (*Weights) Size 

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

func (*Weights) String 

func (m *Weights) String() string

func (*Weights) Unmarshal 

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

func (*Weights) XXX_DiscardUnknown 

func (m *Weights) XXX_DiscardUnknown()

func (*Weights) XXX_Marshal 

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

func (*Weights) XXX_Merge 

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

func (*Weights) XXX_Size 

func (m *Weights) XXX_Size() int

func (*Weights) XXX_Unmarshal 

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

Source Files

View all Source files

Directories

Path Synopsis
api
module/v1
Code generated by protoc-gen-go-pulsar.
 Code generated by protoc-gen-go-pulsar.
v1
Code generated by protoc-gen-go-pulsar.
 Code generated by protoc-gen-go-pulsar.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.