emissionsv1

package
v0.7.1-rc-1 Latest Latest
Warning

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

 Go to latest Published: Dec 12, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Code generated by protoc-gen-go-pulsar. DO NOT EDIT.

Index

Constants

This section is empty.

Variables

View Source 
var File_emissions_v1_node_proto protoreflect.FileDescriptor
View Source 
var File_emissions_v1_nonce_proto protoreflect.FileDescriptor
View Source 
var File_emissions_v1_reputer_proto protoreflect.FileDescriptor
View Source 
var File_emissions_v1_topic_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Nonce 

type Nonce struct {
	BlockHeight int64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"` // block height of the request
	// contains filtered or unexported fields
}

func (*Nonce) Descriptor deprecated 

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

Deprecated: Use Nonce.ProtoReflect.Descriptor instead.

func (*Nonce) GetBlockHeight 

func (x *Nonce) GetBlockHeight() int64

func (*Nonce) ProtoMessage 

func (*Nonce) ProtoMessage()

func (*Nonce) ProtoReflect 

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

func (*Nonce) Reset 

func (x *Nonce) Reset()

func (*Nonce) String 

func (x *Nonce) String() string

type Nonces 

type Nonces struct {
	Nonces []*Nonce `protobuf:"bytes,1,rep,name=nonces,proto3" json:"nonces,omitempty"`
	// contains filtered or unexported fields
}

func (*Nonces) Descriptor deprecated 

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

Deprecated: Use Nonces.ProtoReflect.Descriptor instead.

func (*Nonces) GetNonces 

func (x *Nonces) GetNonces() []*Nonce

func (*Nonces) ProtoMessage 

func (*Nonces) ProtoMessage()

func (*Nonces) ProtoReflect 

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

func (*Nonces) Reset 

func (x *Nonces) Reset()

func (*Nonces) String 

func (x *Nonces) String() string

type OffchainNode 

type OffchainNode struct {
	LibP2PKey    string `protobuf:"bytes,1,opt,name=lib_p2p_key,json=libP2pKey,proto3" json:"lib_p2p_key,omitempty"`
	MultiAddress string `protobuf:"bytes,2,opt,name=multi_address,json=multiAddress,proto3" json:"multi_address,omitempty"`
	Owner        string `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"`
	NodeAddress  string `protobuf:"bytes,4,opt,name=node_address,json=nodeAddress,proto3" json:"node_address,omitempty"`
	NodeId       string `protobuf:"bytes,5,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	// contains filtered or unexported fields
}

func (*OffchainNode) Descriptor deprecated 

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

Deprecated: Use OffchainNode.ProtoReflect.Descriptor instead.

func (*OffchainNode) GetLibP2PKey 

func (x *OffchainNode) GetLibP2PKey() string

func (*OffchainNode) GetMultiAddress 

func (x *OffchainNode) GetMultiAddress() string

func (*OffchainNode) GetNodeAddress 

func (x *OffchainNode) GetNodeAddress() string

func (*OffchainNode) GetNodeId 

func (x *OffchainNode) GetNodeId() string

func (*OffchainNode) GetOwner 

func (x *OffchainNode) GetOwner() string

func (*OffchainNode) ProtoMessage 

func (*OffchainNode) ProtoMessage()

func (*OffchainNode) ProtoReflect 

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

func (*OffchainNode) Reset 

func (x *OffchainNode) Reset()

func (*OffchainNode) String 

func (x *OffchainNode) String() string

type ReputerRequestNonce 

type ReputerRequestNonce struct {

	// the reputers should respond to the reputer request with losses for work
	// found at this worker nonce
	ReputerNonce *Nonce `protobuf:"bytes,1,opt,name=reputer_nonce,json=reputerNonce,proto3" json:"reputer_nonce,omitempty"`
	// contains filtered or unexported fields
}

func (*ReputerRequestNonce) Descriptor deprecated 

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

Deprecated: Use ReputerRequestNonce.ProtoReflect.Descriptor instead.

func (*ReputerRequestNonce) GetReputerNonce 

func (x *ReputerRequestNonce) GetReputerNonce() *Nonce

func (*ReputerRequestNonce) ProtoMessage 

func (*ReputerRequestNonce) ProtoMessage()

func (*ReputerRequestNonce) ProtoReflect 

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

func (*ReputerRequestNonce) Reset 

func (x *ReputerRequestNonce) Reset()

func (*ReputerRequestNonce) String 

func (x *ReputerRequestNonce) String() string

type ReputerRequestNonces 

type ReputerRequestNonces struct {
	Nonces []*ReputerRequestNonce `protobuf:"bytes,1,rep,name=nonces,proto3" json:"nonces,omitempty"`
	// contains filtered or unexported fields
}

func (*ReputerRequestNonces) Descriptor deprecated 

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

Deprecated: Use ReputerRequestNonces.ProtoReflect.Descriptor instead.

func (*ReputerRequestNonces) GetNonces 

func (x *ReputerRequestNonces) GetNonces() []*ReputerRequestNonce

func (*ReputerRequestNonces) ProtoMessage 

func (*ReputerRequestNonces) ProtoMessage()

func (*ReputerRequestNonces) ProtoReflect 

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

func (*ReputerRequestNonces) Reset 

func (x *ReputerRequestNonces) Reset()

func (*ReputerRequestNonces) String 

func (x *ReputerRequestNonces) String() string

type ReputerValueBundle 

type ReputerValueBundle struct {
	ValueBundle *ValueBundle `protobuf:"bytes,1,opt,name=value_bundle,json=valueBundle,proto3" json:"value_bundle,omitempty"`
	Signature   []byte       `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	Pubkey      string       `protobuf:"bytes,3,opt,name=pubkey,proto3" json:"pubkey,omitempty"`
	// contains filtered or unexported fields
}

For when the bundle is computed on a per-reputer basis (ie.. if there is an index `m` in the above)

func (*ReputerValueBundle) Descriptor deprecated 

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

Deprecated: Use ReputerValueBundle.ProtoReflect.Descriptor instead.

func (*ReputerValueBundle) GetPubkey 

func (x *ReputerValueBundle) GetPubkey() string

func (*ReputerValueBundle) GetSignature 

func (x *ReputerValueBundle) GetSignature() []byte

func (*ReputerValueBundle) GetValueBundle 

func (x *ReputerValueBundle) GetValueBundle() *ValueBundle

func (*ReputerValueBundle) ProtoMessage 

func (*ReputerValueBundle) ProtoMessage()

func (*ReputerValueBundle) ProtoReflect 

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

func (*ReputerValueBundle) Reset 

func (x *ReputerValueBundle) Reset()

func (*ReputerValueBundle) String 

func (x *ReputerValueBundle) String() string

type ReputerValueBundles 

type ReputerValueBundles struct {
	ReputerValueBundles []*ReputerValueBundle `protobuf:"bytes,1,rep,name=reputer_value_bundles,json=reputerValueBundles,proto3" json:"reputer_value_bundles,omitempty"`
	// contains filtered or unexported fields
}

func (*ReputerValueBundles) Descriptor deprecated 

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

Deprecated: Use ReputerValueBundles.ProtoReflect.Descriptor instead.

func (*ReputerValueBundles) GetReputerValueBundles 

func (x *ReputerValueBundles) GetReputerValueBundles() []*ReputerValueBundle

func (*ReputerValueBundles) ProtoMessage 

func (*ReputerValueBundles) ProtoMessage()

func (*ReputerValueBundles) ProtoReflect 

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

func (*ReputerValueBundles) Reset 

func (x *ReputerValueBundles) Reset()

func (*ReputerValueBundles) String 

func (x *ReputerValueBundles) String() string

type TimestampedActorNonce 

type TimestampedActorNonce struct {
	BlockHeight int64  `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"` // height at which value calculated or received
	Actor       string `protobuf:"bytes,2,opt,name=actor,proto3" json:"actor,omitempty"`
	Nonce       *Nonce `protobuf:"bytes,3,opt,name=nonce,proto3" json:"nonce,omitempty"`
	// contains filtered or unexported fields
}

func (*TimestampedActorNonce) Descriptor deprecated 

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

Deprecated: Use TimestampedActorNonce.ProtoReflect.Descriptor instead.

func (*TimestampedActorNonce) GetActor 

func (x *TimestampedActorNonce) GetActor() string

func (*TimestampedActorNonce) GetBlockHeight 

func (x *TimestampedActorNonce) GetBlockHeight() int64

func (*TimestampedActorNonce) GetNonce 

func (x *TimestampedActorNonce) GetNonce() *Nonce

func (*TimestampedActorNonce) ProtoMessage 

func (*TimestampedActorNonce) ProtoMessage()

func (*TimestampedActorNonce) ProtoReflect 

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

func (*TimestampedActorNonce) Reset 

func (x *TimestampedActorNonce) Reset()

func (*TimestampedActorNonce) String 

func (x *TimestampedActorNonce) String() string

type Topic 

type Topic struct {
	Id              uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Creator         string `protobuf:"bytes,2,opt,name=creator,proto3" json:"creator,omitempty"`
	Metadata        string `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	LossLogic       string `protobuf:"bytes,4,opt,name=loss_logic,json=lossLogic,proto3" json:"loss_logic,omitempty"`
	LossMethod      string `protobuf:"bytes,5,opt,name=loss_method,json=lossMethod,proto3" json:"loss_method,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"`
	EpochLastEnded  int64  `protobuf:"varint,8,opt,name=epoch_last_ended,json=epochLastEnded,proto3" json:"epoch_last_ended,omitempty"`
	EpochLength     int64  `protobuf:"varint,9,opt,name=epoch_length,json=epochLength,proto3" json:"epoch_length,omitempty"`
	GroundTruthLag  int64  `protobuf:"varint,10,opt,name=ground_truth_lag,json=groundTruthLag,proto3" json:"ground_truth_lag,omitempty"`
	DefaultArg      string `protobuf:"bytes,11,opt,name=default_arg,json=defaultArg,proto3" json:"default_arg,omitempty"`
	PNorm           string `protobuf:"bytes,12,opt,name=p_norm,json=pNorm,proto3" json:"p_norm,omitempty"`
	AlphaRegret     string `protobuf:"bytes,13,opt,name=alpha_regret,json=alphaRegret,proto3" json:"alpha_regret,omitempty"`
	AllowNegative   bool   `protobuf:"varint,14,opt,name=allow_negative,json=allowNegative,proto3" json:"allow_negative,omitempty"`
	// contains filtered or unexported fields
}

func (*Topic) Descriptor deprecated 

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

Deprecated: Use Topic.ProtoReflect.Descriptor instead.

func (*Topic) GetAllowNegative 

func (x *Topic) GetAllowNegative() bool

func (*Topic) GetAlphaRegret 

func (x *Topic) GetAlphaRegret() string

func (*Topic) GetCreator 

func (x *Topic) GetCreator() string

func (*Topic) GetDefaultArg 

func (x *Topic) GetDefaultArg() string

func (*Topic) GetEpochLastEnded 

func (x *Topic) GetEpochLastEnded() int64

func (*Topic) GetEpochLength 

func (x *Topic) GetEpochLength() int64

func (*Topic) GetGroundTruthLag 

func (x *Topic) GetGroundTruthLag() int64

func (*Topic) GetId 

func (x *Topic) GetId() uint64

func (*Topic) GetInferenceLogic 

func (x *Topic) GetInferenceLogic() string

func (*Topic) GetInferenceMethod 

func (x *Topic) GetInferenceMethod() string

func (*Topic) GetLossLogic 

func (x *Topic) GetLossLogic() string

func (*Topic) GetLossMethod 

func (x *Topic) GetLossMethod() string

func (*Topic) GetMetadata 

func (x *Topic) GetMetadata() string

func (*Topic) GetPNorm 

func (x *Topic) GetPNorm() string

func (*Topic) ProtoMessage 

func (*Topic) ProtoMessage()

func (*Topic) ProtoReflect 

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

func (*Topic) Reset 

func (x *Topic) Reset()

func (*Topic) String 

func (x *Topic) String() string

type TopicList 

type TopicList struct {
	Topics []*Topic `protobuf:"bytes,1,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

func (*TopicList) Descriptor deprecated 

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

Deprecated: Use TopicList.ProtoReflect.Descriptor instead.

func (*TopicList) GetTopics 

func (x *TopicList) GetTopics() []*Topic

func (*TopicList) ProtoMessage 

func (*TopicList) ProtoMessage()

func (*TopicList) ProtoReflect 

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

func (*TopicList) Reset 

func (x *TopicList) Reset()

func (*TopicList) String 

func (x *TopicList) String() string

type ValueBundle 

type ValueBundle struct {
	TopicId             uint64               `protobuf:"varint,1,opt,name=topic_id,json=topicId,proto3" json:"topic_id,omitempty"`
	ReputerRequestNonce *ReputerRequestNonce `protobuf:"bytes,2,opt,name=reputer_request_nonce,json=reputerRequestNonce,proto3" json:"reputer_request_nonce,omitempty"`
	Reputer             string               `protobuf:"bytes,3,opt,name=reputer,proto3" json:"reputer,omitempty"`
	ExtraData           []byte               `protobuf:"bytes,4,opt,name=extra_data,json=extraData,proto3" json:"extra_data,omitempty"`
	// R_im || log10 L_im || I_i
	CombinedValue string `protobuf:"bytes,5,opt,name=combined_value,json=combinedValue,proto3" json:"combined_value,omitempty"`
	// R_ijm || log10 L_ijm || I_ij
	InfererValues []*WorkerAttributedValue `protobuf:"bytes,6,rep,name=inferer_values,json=infererValues,proto3" json:"inferer_values,omitempty"`
	// R_ikm || log10 L_ikm || I_ik
	ForecasterValues []*WorkerAttributedValue `protobuf:"bytes,7,rep,name=forecaster_values,json=forecasterValues,proto3" json:"forecaster_values,omitempty"`
	// R^-_im  || log10 L^-_im || I^-_i
	NaiveValue string `protobuf:"bytes,8,opt,name=naive_value,json=naiveValue,proto3" json:"naive_value,omitempty"`
	// R^-_ilm || log10 L^-_ilm || I^-_il where l = any j
	// Note: forecast-implied inferences are recomputed for each left-out
	// inference
	OneOutInfererValues []*WithheldWorkerAttributedValue `protobuf:"bytes,9,rep,name=one_out_inferer_values,json=oneOutInfererValues,proto3" json:"one_out_inferer_values,omitempty"`
	// R^-_ilm || log10 L^-_ilm || I^-_il where l = any k
	OneOutForecasterValues []*WithheldWorkerAttributedValue `` /* 132-byte string literal not displayed */
	// R^+_ikm || log10 L^+_ikm || I^+_ik
	// aka one_in_forecaster_values because equivalent to using only one
	// forecast-implied inference
	OneInForecasterValues []*WorkerAttributedValue `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

These losses and inferences are calculated per reputer or by the network The `m`s in the comments below exist for when they're made by reputers, but they may be absent implying that they were made by the network

func (*ValueBundle) Descriptor deprecated 

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

Deprecated: Use ValueBundle.ProtoReflect.Descriptor instead.

func (*ValueBundle) GetCombinedValue 

func (x *ValueBundle) GetCombinedValue() string

func (*ValueBundle) GetExtraData 

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

func (*ValueBundle) GetForecasterValues 

func (x *ValueBundle) GetForecasterValues() []*WorkerAttributedValue

func (*ValueBundle) GetInfererValues 

func (x *ValueBundle) GetInfererValues() []*WorkerAttributedValue

func (*ValueBundle) GetNaiveValue 

func (x *ValueBundle) GetNaiveValue() string

func (*ValueBundle) GetOneInForecasterValues 

func (x *ValueBundle) GetOneInForecasterValues() []*WorkerAttributedValue

func (*ValueBundle) GetOneOutForecasterValues 

func (x *ValueBundle) GetOneOutForecasterValues() []*WithheldWorkerAttributedValue

func (*ValueBundle) GetOneOutInfererValues 

func (x *ValueBundle) GetOneOutInfererValues() []*WithheldWorkerAttributedValue

func (*ValueBundle) GetReputer 

func (x *ValueBundle) GetReputer() string

func (*ValueBundle) GetReputerRequestNonce 

func (x *ValueBundle) GetReputerRequestNonce() *ReputerRequestNonce

func (*ValueBundle) GetTopicId 

func (x *ValueBundle) GetTopicId() uint64

func (*ValueBundle) ProtoMessage 

func (*ValueBundle) ProtoMessage()

func (*ValueBundle) ProtoReflect 

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

func (*ValueBundle) Reset 

func (x *ValueBundle) Reset()

func (*ValueBundle) String 

func (x *ValueBundle) String() string

type WithheldWorkerAttributedValue 

type WithheldWorkerAttributedValue struct {
	Worker string `protobuf:"bytes,1,opt,name=worker,proto3" json:"worker,omitempty"`
	Value  string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*WithheldWorkerAttributedValue) Descriptor deprecated 

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

Deprecated: Use WithheldWorkerAttributedValue.ProtoReflect.Descriptor instead.

func (*WithheldWorkerAttributedValue) GetValue 

func (x *WithheldWorkerAttributedValue) GetValue() string

func (*WithheldWorkerAttributedValue) GetWorker 

func (x *WithheldWorkerAttributedValue) GetWorker() string

func (*WithheldWorkerAttributedValue) ProtoMessage 

func (*WithheldWorkerAttributedValue) ProtoMessage()

func (*WithheldWorkerAttributedValue) ProtoReflect 

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

func (*WithheldWorkerAttributedValue) Reset 

func (x *WithheldWorkerAttributedValue) Reset()

func (*WithheldWorkerAttributedValue) String 

func (x *WithheldWorkerAttributedValue) String() string

type WorkerAttributedValue 

type WorkerAttributedValue struct {
	Worker string `protobuf:"bytes,1,opt,name=worker,proto3" json:"worker,omitempty"` // worker who created the value
	Value  string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkerAttributedValue) Descriptor deprecated 

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

Deprecated: Use WorkerAttributedValue.ProtoReflect.Descriptor instead.

func (*WorkerAttributedValue) GetValue 

func (x *WorkerAttributedValue) GetValue() string

func (*WorkerAttributedValue) GetWorker 

func (x *WorkerAttributedValue) GetWorker() string

func (*WorkerAttributedValue) ProtoMessage 

func (*WorkerAttributedValue) ProtoMessage()

func (*WorkerAttributedValue) ProtoReflect 

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

func (*WorkerAttributedValue) Reset 

func (x *WorkerAttributedValue) Reset()

func (*WorkerAttributedValue) String 

func (x *WorkerAttributedValue) String() string

Source Files

View all Source files

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.