Documentation ¶
Index ¶
- Variables
- type AttestedReportMany
- func (*AttestedReportMany) Descriptor() ([]byte, []int)deprecated
- func (x *AttestedReportMany) GetAttributedSignatures() []*AttributedSignature
- func (x *AttestedReportMany) GetReport() []byte
- func (*AttestedReportMany) ProtoMessage()
- func (x *AttestedReportMany) ProtoReflect() protoreflect.Message
- func (x *AttestedReportMany) Reset()
- func (x *AttestedReportMany) String() string
- type AttestedReportOne
- func (*AttestedReportOne) Descriptor() ([]byte, []int)deprecated
- func (x *AttestedReportOne) GetReport() []byte
- func (x *AttestedReportOne) GetSignature() []byte
- func (x *AttestedReportOne) GetSkip() bool
- func (*AttestedReportOne) ProtoMessage()
- func (x *AttestedReportOne) ProtoReflect() protoreflect.Message
- func (x *AttestedReportOne) Reset()
- func (x *AttestedReportOne) String() string
- type AttributedSignature
- func (*AttributedSignature) Descriptor() ([]byte, []int)deprecated
- func (x *AttributedSignature) GetSignature() []byte
- func (x *AttributedSignature) GetSigner() uint32
- func (*AttributedSignature) ProtoMessage()
- func (x *AttributedSignature) ProtoReflect() protoreflect.Message
- func (x *AttributedSignature) Reset()
- func (x *AttributedSignature) String() string
- type AttributedSignedObservation
- func (*AttributedSignedObservation) Descriptor() ([]byte, []int)deprecated
- func (x *AttributedSignedObservation) GetObserver() uint32
- func (x *AttributedSignedObservation) GetSignedObservation() *SignedObservation
- func (*AttributedSignedObservation) ProtoMessage()
- func (x *AttributedSignedObservation) ProtoReflect() protoreflect.Message
- func (x *AttributedSignedObservation) Reset()
- func (x *AttributedSignedObservation) String() string
- type MessageFinal
- func (*MessageFinal) Descriptor() ([]byte, []int)deprecated
- func (x *MessageFinal) GetAttestedReport() *AttestedReportMany
- func (x *MessageFinal) GetEpoch() uint64
- func (x *MessageFinal) GetH() []byte
- func (x *MessageFinal) GetRound() uint32
- func (*MessageFinal) ProtoMessage()
- func (x *MessageFinal) ProtoReflect() protoreflect.Message
- func (x *MessageFinal) Reset()
- func (x *MessageFinal) String() string
- type MessageFinalEcho
- type MessageNewEpoch
- type MessageObserve
- func (*MessageObserve) Descriptor() ([]byte, []int)deprecated
- func (x *MessageObserve) GetEpoch() uint64
- func (x *MessageObserve) GetRound() uint32
- func (x *MessageObserve) GetSignedObservation() *SignedObservation
- func (*MessageObserve) ProtoMessage()
- func (x *MessageObserve) ProtoReflect() protoreflect.Message
- func (x *MessageObserve) Reset()
- func (x *MessageObserve) String() string
- type MessageObserveReq
- func (*MessageObserveReq) Descriptor() ([]byte, []int)deprecated
- func (x *MessageObserveReq) GetEpoch() uint64
- func (x *MessageObserveReq) GetQuery() []byte
- func (x *MessageObserveReq) GetRound() uint32
- func (*MessageObserveReq) ProtoMessage()
- func (x *MessageObserveReq) ProtoReflect() protoreflect.Message
- func (x *MessageObserveReq) Reset()
- func (x *MessageObserveReq) String() string
- type MessageReport
- func (*MessageReport) Descriptor() ([]byte, []int)deprecated
- func (x *MessageReport) GetAttestedReport() *AttestedReportOne
- func (x *MessageReport) GetEpoch() uint64
- func (x *MessageReport) GetRound() uint32
- func (*MessageReport) ProtoMessage()
- func (x *MessageReport) ProtoReflect() protoreflect.Message
- func (x *MessageReport) Reset()
- func (x *MessageReport) String() string
- type MessageReportReq
- func (*MessageReportReq) Descriptor() ([]byte, []int)deprecated
- func (x *MessageReportReq) GetAttributedSignedObservations() []*AttributedSignedObservation
- func (x *MessageReportReq) GetEpoch() uint64
- func (x *MessageReportReq) GetQuery() []byte
- func (x *MessageReportReq) GetRound() uint32
- func (*MessageReportReq) ProtoMessage()
- func (x *MessageReportReq) ProtoReflect() protoreflect.Message
- func (x *MessageReportReq) Reset()
- func (x *MessageReportReq) String() string
- type MessageWrapper
- func (*MessageWrapper) Descriptor() ([]byte, []int)deprecated
- func (x *MessageWrapper) GetMessageFinal() *MessageFinal
- func (x *MessageWrapper) GetMessageFinalEcho() *MessageFinalEcho
- func (x *MessageWrapper) GetMessageNewEpoch() *MessageNewEpoch
- func (x *MessageWrapper) GetMessageObserve() *MessageObserve
- func (x *MessageWrapper) GetMessageObserveReq() *MessageObserveReq
- func (x *MessageWrapper) GetMessageReport() *MessageReport
- func (x *MessageWrapper) GetMessageReportReq() *MessageReportReq
- func (m *MessageWrapper) GetMsg() isMessageWrapper_Msg
- func (*MessageWrapper) ProtoMessage()
- func (x *MessageWrapper) ProtoReflect() protoreflect.Message
- func (x *MessageWrapper) Reset()
- func (x *MessageWrapper) String() string
- type MessageWrapper_MessageFinal
- type MessageWrapper_MessageFinalEcho
- type MessageWrapper_MessageNewEpoch
- type MessageWrapper_MessageObserve
- type MessageWrapper_MessageObserveReq
- type MessageWrapper_MessageReport
- type MessageWrapper_MessageReportReq
- type SignedObservation
- func (*SignedObservation) Descriptor() ([]byte, []int)deprecated
- func (x *SignedObservation) GetObservation() []byte
- func (x *SignedObservation) GetSignature() []byte
- func (*SignedObservation) ProtoMessage()
- func (x *SignedObservation) ProtoReflect() protoreflect.Message
- func (x *SignedObservation) Reset()
- func (x *SignedObservation) String() string
- type TelemetryAssertionViolation
- func (*TelemetryAssertionViolation) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryAssertionViolation) GetInvalidSerialization() *TelemetryAssertionViolationInvalidSerialization
- func (m *TelemetryAssertionViolation) GetViolation() isTelemetryAssertionViolation_Violation
- func (*TelemetryAssertionViolation) ProtoMessage()
- func (x *TelemetryAssertionViolation) ProtoReflect() protoreflect.Message
- func (x *TelemetryAssertionViolation) Reset()
- func (x *TelemetryAssertionViolation) String() string
- type TelemetryAssertionViolationInvalidSerialization
- func (*TelemetryAssertionViolationInvalidSerialization) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryAssertionViolationInvalidSerialization) GetConfigDigest() []byte
- func (x *TelemetryAssertionViolationInvalidSerialization) GetSender() uint32
- func (x *TelemetryAssertionViolationInvalidSerialization) GetSerializedMsg() []byte
- func (*TelemetryAssertionViolationInvalidSerialization) ProtoMessage()
- func (x *TelemetryAssertionViolationInvalidSerialization) ProtoReflect() protoreflect.Message
- func (x *TelemetryAssertionViolationInvalidSerialization) Reset()
- func (x *TelemetryAssertionViolationInvalidSerialization) String() string
- type TelemetryAssertionViolation_InvalidSerialization
- type TelemetryMessageBroadcast
- func (*TelemetryMessageBroadcast) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryMessageBroadcast) GetConfigDigest() []byte
- func (x *TelemetryMessageBroadcast) GetMsg() *MessageWrapper
- func (x *TelemetryMessageBroadcast) GetSerializedMsg() []byte
- func (*TelemetryMessageBroadcast) ProtoMessage()
- func (x *TelemetryMessageBroadcast) ProtoReflect() protoreflect.Message
- func (x *TelemetryMessageBroadcast) Reset()
- func (x *TelemetryMessageBroadcast) String() string
- type TelemetryMessageReceived
- func (*TelemetryMessageReceived) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryMessageReceived) GetConfigDigest() []byte
- func (x *TelemetryMessageReceived) GetMsg() *MessageWrapper
- func (x *TelemetryMessageReceived) GetSender() uint32
- func (*TelemetryMessageReceived) ProtoMessage()
- func (x *TelemetryMessageReceived) ProtoReflect() protoreflect.Message
- func (x *TelemetryMessageReceived) Reset()
- func (x *TelemetryMessageReceived) String() string
- type TelemetryMessageSent
- func (*TelemetryMessageSent) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryMessageSent) GetConfigDigest() []byte
- func (x *TelemetryMessageSent) GetMsg() *MessageWrapper
- func (x *TelemetryMessageSent) GetReceiver() uint32
- func (x *TelemetryMessageSent) GetSerializedMsg() []byte
- func (*TelemetryMessageSent) ProtoMessage()
- func (x *TelemetryMessageSent) ProtoReflect() protoreflect.Message
- func (x *TelemetryMessageSent) Reset()
- func (x *TelemetryMessageSent) String() string
- type TelemetryRoundStarted
- func (*TelemetryRoundStarted) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryRoundStarted) GetConfigDigest() []byte
- func (x *TelemetryRoundStarted) GetEpoch() uint64
- func (x *TelemetryRoundStarted) GetLeader() uint64
- func (x *TelemetryRoundStarted) GetRound() uint64
- func (x *TelemetryRoundStarted) GetTime() uint64
- func (*TelemetryRoundStarted) ProtoMessage()
- func (x *TelemetryRoundStarted) ProtoReflect() protoreflect.Message
- func (x *TelemetryRoundStarted) Reset()
- func (x *TelemetryRoundStarted) String() string
- type TelemetryWrapper
- func (*TelemetryWrapper) Descriptor() ([]byte, []int)deprecated
- func (x *TelemetryWrapper) GetAssertionViolation() *TelemetryAssertionViolation
- func (x *TelemetryWrapper) GetMessageBroadcast() *TelemetryMessageBroadcast
- func (x *TelemetryWrapper) GetMessageReceived() *TelemetryMessageReceived
- func (x *TelemetryWrapper) GetMessageSent() *TelemetryMessageSent
- func (x *TelemetryWrapper) GetRoundStarted() *TelemetryRoundStarted
- func (x *TelemetryWrapper) GetUnixTimeNanoseconds() int64
- func (m *TelemetryWrapper) GetWrapped() isTelemetryWrapper_Wrapped
- func (*TelemetryWrapper) ProtoMessage()
- func (x *TelemetryWrapper) ProtoReflect() protoreflect.Message
- func (x *TelemetryWrapper) Reset()
- func (x *TelemetryWrapper) String() string
- type TelemetryWrapper_AssertionViolation
- type TelemetryWrapper_MessageBroadcast
- type TelemetryWrapper_MessageReceived
- type TelemetryWrapper_MessageSent
- type TelemetryWrapper_RoundStarted
Constants ¶
This section is empty.
Variables ¶
var File_offchainreporting2_messages_proto protoreflect.FileDescriptor
var File_offchainreporting2_telemetry_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AttestedReportMany ¶
type AttestedReportMany struct { Report []byte `protobuf:"bytes,3,opt,name=report,proto3" json:"report,omitempty"` AttributedSignatures []*AttributedSignature `protobuf:"bytes,4,rep,name=attributed_signatures,json=attributedSignatures,proto3" json:"attributed_signatures,omitempty"` // contains filtered or unexported fields }
func (*AttestedReportMany) Descriptor
deprecated
func (*AttestedReportMany) Descriptor() ([]byte, []int)
Deprecated: Use AttestedReportMany.ProtoReflect.Descriptor instead.
func (*AttestedReportMany) GetAttributedSignatures ¶
func (x *AttestedReportMany) GetAttributedSignatures() []*AttributedSignature
func (*AttestedReportMany) GetReport ¶
func (x *AttestedReportMany) GetReport() []byte
func (*AttestedReportMany) ProtoMessage ¶
func (*AttestedReportMany) ProtoMessage()
func (*AttestedReportMany) ProtoReflect ¶
func (x *AttestedReportMany) ProtoReflect() protoreflect.Message
func (*AttestedReportMany) Reset ¶
func (x *AttestedReportMany) Reset()
func (*AttestedReportMany) String ¶
func (x *AttestedReportMany) String() string
type AttestedReportOne ¶
type AttestedReportOne struct { Skip bool `protobuf:"varint,3,opt,name=skip,proto3" json:"skip,omitempty"` Report []byte `protobuf:"bytes,4,opt,name=report,proto3" json:"report,omitempty"` Signature []byte `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
func (*AttestedReportOne) Descriptor
deprecated
func (*AttestedReportOne) Descriptor() ([]byte, []int)
Deprecated: Use AttestedReportOne.ProtoReflect.Descriptor instead.
func (*AttestedReportOne) GetReport ¶
func (x *AttestedReportOne) GetReport() []byte
func (*AttestedReportOne) GetSignature ¶
func (x *AttestedReportOne) GetSignature() []byte
func (*AttestedReportOne) GetSkip ¶
func (x *AttestedReportOne) GetSkip() bool
func (*AttestedReportOne) ProtoMessage ¶
func (*AttestedReportOne) ProtoMessage()
func (*AttestedReportOne) ProtoReflect ¶
func (x *AttestedReportOne) ProtoReflect() protoreflect.Message
func (*AttestedReportOne) Reset ¶
func (x *AttestedReportOne) Reset()
func (*AttestedReportOne) String ¶
func (x *AttestedReportOne) String() string
type AttributedSignature ¶
type AttributedSignature struct { Signature []byte `protobuf:"bytes,1,opt,name=signature,proto3" json:"signature,omitempty"` Signer uint32 `protobuf:"varint,2,opt,name=signer,proto3" json:"signer,omitempty"` // contains filtered or unexported fields }
func (*AttributedSignature) Descriptor
deprecated
func (*AttributedSignature) Descriptor() ([]byte, []int)
Deprecated: Use AttributedSignature.ProtoReflect.Descriptor instead.
func (*AttributedSignature) GetSignature ¶
func (x *AttributedSignature) GetSignature() []byte
func (*AttributedSignature) GetSigner ¶
func (x *AttributedSignature) GetSigner() uint32
func (*AttributedSignature) ProtoMessage ¶
func (*AttributedSignature) ProtoMessage()
func (*AttributedSignature) ProtoReflect ¶
func (x *AttributedSignature) ProtoReflect() protoreflect.Message
func (*AttributedSignature) Reset ¶
func (x *AttributedSignature) Reset()
func (*AttributedSignature) String ¶
func (x *AttributedSignature) String() string
type AttributedSignedObservation ¶
type AttributedSignedObservation struct { SignedObservation *SignedObservation `protobuf:"bytes,1,opt,name=signed_observation,json=signedObservation,proto3" json:"signed_observation,omitempty"` Observer uint32 `protobuf:"varint,2,opt,name=observer,proto3" json:"observer,omitempty"` // contains filtered or unexported fields }
func (*AttributedSignedObservation) Descriptor
deprecated
func (*AttributedSignedObservation) Descriptor() ([]byte, []int)
Deprecated: Use AttributedSignedObservation.ProtoReflect.Descriptor instead.
func (*AttributedSignedObservation) GetObserver ¶
func (x *AttributedSignedObservation) GetObserver() uint32
func (*AttributedSignedObservation) GetSignedObservation ¶
func (x *AttributedSignedObservation) GetSignedObservation() *SignedObservation
func (*AttributedSignedObservation) ProtoMessage ¶
func (*AttributedSignedObservation) ProtoMessage()
func (*AttributedSignedObservation) ProtoReflect ¶
func (x *AttributedSignedObservation) ProtoReflect() protoreflect.Message
func (*AttributedSignedObservation) Reset ¶
func (x *AttributedSignedObservation) Reset()
func (*AttributedSignedObservation) String ¶
func (x *AttributedSignedObservation) String() string
type MessageFinal ¶
type MessageFinal struct { Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` Round uint32 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"` H []byte `protobuf:"bytes,4,opt,name=h,proto3" json:"h,omitempty"` AttestedReport *AttestedReportMany `protobuf:"bytes,5,opt,name=attested_report,json=attestedReport,proto3" json:"attested_report,omitempty"` // contains filtered or unexported fields }
func (*MessageFinal) Descriptor
deprecated
func (*MessageFinal) Descriptor() ([]byte, []int)
Deprecated: Use MessageFinal.ProtoReflect.Descriptor instead.
func (*MessageFinal) GetAttestedReport ¶
func (x *MessageFinal) GetAttestedReport() *AttestedReportMany
func (*MessageFinal) GetEpoch ¶
func (x *MessageFinal) GetEpoch() uint64
func (*MessageFinal) GetH ¶
func (x *MessageFinal) GetH() []byte
func (*MessageFinal) GetRound ¶
func (x *MessageFinal) GetRound() uint32
func (*MessageFinal) ProtoMessage ¶
func (*MessageFinal) ProtoMessage()
func (*MessageFinal) ProtoReflect ¶
func (x *MessageFinal) ProtoReflect() protoreflect.Message
func (*MessageFinal) Reset ¶
func (x *MessageFinal) Reset()
func (*MessageFinal) String ¶
func (x *MessageFinal) String() string
type MessageFinalEcho ¶
type MessageFinalEcho struct { Final *MessageFinal `protobuf:"bytes,1,opt,name=final,proto3" json:"final,omitempty"` // contains filtered or unexported fields }
MessageFinalEcho has exactly the same fields as MessageFinal
func (*MessageFinalEcho) Descriptor
deprecated
func (*MessageFinalEcho) Descriptor() ([]byte, []int)
Deprecated: Use MessageFinalEcho.ProtoReflect.Descriptor instead.
func (*MessageFinalEcho) GetFinal ¶
func (x *MessageFinalEcho) GetFinal() *MessageFinal
func (*MessageFinalEcho) ProtoMessage ¶
func (*MessageFinalEcho) ProtoMessage()
func (*MessageFinalEcho) ProtoReflect ¶
func (x *MessageFinalEcho) ProtoReflect() protoreflect.Message
func (*MessageFinalEcho) Reset ¶
func (x *MessageFinalEcho) Reset()
func (*MessageFinalEcho) String ¶
func (x *MessageFinalEcho) String() string
type MessageNewEpoch ¶
type MessageNewEpoch struct { Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` // contains filtered or unexported fields }
func (*MessageNewEpoch) Descriptor
deprecated
func (*MessageNewEpoch) Descriptor() ([]byte, []int)
Deprecated: Use MessageNewEpoch.ProtoReflect.Descriptor instead.
func (*MessageNewEpoch) GetEpoch ¶
func (x *MessageNewEpoch) GetEpoch() uint64
func (*MessageNewEpoch) ProtoMessage ¶
func (*MessageNewEpoch) ProtoMessage()
func (*MessageNewEpoch) ProtoReflect ¶
func (x *MessageNewEpoch) ProtoReflect() protoreflect.Message
func (*MessageNewEpoch) Reset ¶
func (x *MessageNewEpoch) Reset()
func (*MessageNewEpoch) String ¶
func (x *MessageNewEpoch) String() string
type MessageObserve ¶
type MessageObserve struct { Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` Round uint32 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"` SignedObservation *SignedObservation `protobuf:"bytes,3,opt,name=signed_observation,json=signedObservation,proto3" json:"signed_observation,omitempty"` // contains filtered or unexported fields }
func (*MessageObserve) Descriptor
deprecated
func (*MessageObserve) Descriptor() ([]byte, []int)
Deprecated: Use MessageObserve.ProtoReflect.Descriptor instead.
func (*MessageObserve) GetEpoch ¶
func (x *MessageObserve) GetEpoch() uint64
func (*MessageObserve) GetRound ¶
func (x *MessageObserve) GetRound() uint32
func (*MessageObserve) GetSignedObservation ¶
func (x *MessageObserve) GetSignedObservation() *SignedObservation
func (*MessageObserve) ProtoMessage ¶
func (*MessageObserve) ProtoMessage()
func (*MessageObserve) ProtoReflect ¶
func (x *MessageObserve) ProtoReflect() protoreflect.Message
func (*MessageObserve) Reset ¶
func (x *MessageObserve) Reset()
func (*MessageObserve) String ¶
func (x *MessageObserve) String() string
type MessageObserveReq ¶
type MessageObserveReq struct { Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` Round uint32 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"` Query []byte `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*MessageObserveReq) Descriptor
deprecated
func (*MessageObserveReq) Descriptor() ([]byte, []int)
Deprecated: Use MessageObserveReq.ProtoReflect.Descriptor instead.
func (*MessageObserveReq) GetEpoch ¶
func (x *MessageObserveReq) GetEpoch() uint64
func (*MessageObserveReq) GetQuery ¶
func (x *MessageObserveReq) GetQuery() []byte
func (*MessageObserveReq) GetRound ¶
func (x *MessageObserveReq) GetRound() uint32
func (*MessageObserveReq) ProtoMessage ¶
func (*MessageObserveReq) ProtoMessage()
func (*MessageObserveReq) ProtoReflect ¶
func (x *MessageObserveReq) ProtoReflect() protoreflect.Message
func (*MessageObserveReq) Reset ¶
func (x *MessageObserveReq) Reset()
func (*MessageObserveReq) String ¶
func (x *MessageObserveReq) String() string
type MessageReport ¶
type MessageReport struct { Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` Round uint32 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"` AttestedReport *AttestedReportOne `protobuf:"bytes,3,opt,name=attested_report,json=attestedReport,proto3" json:"attested_report,omitempty"` // contains filtered or unexported fields }
func (*MessageReport) Descriptor
deprecated
func (*MessageReport) Descriptor() ([]byte, []int)
Deprecated: Use MessageReport.ProtoReflect.Descriptor instead.
func (*MessageReport) GetAttestedReport ¶
func (x *MessageReport) GetAttestedReport() *AttestedReportOne
func (*MessageReport) GetEpoch ¶
func (x *MessageReport) GetEpoch() uint64
func (*MessageReport) GetRound ¶
func (x *MessageReport) GetRound() uint32
func (*MessageReport) ProtoMessage ¶
func (*MessageReport) ProtoMessage()
func (*MessageReport) ProtoReflect ¶
func (x *MessageReport) ProtoReflect() protoreflect.Message
func (*MessageReport) Reset ¶
func (x *MessageReport) Reset()
func (*MessageReport) String ¶
func (x *MessageReport) String() string
type MessageReportReq ¶
type MessageReportReq struct { Epoch uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"` Round uint32 `protobuf:"varint,2,opt,name=round,proto3" json:"round,omitempty"` Query []byte `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` AttributedSignedObservations []*AttributedSignedObservation `` /* 147-byte string literal not displayed */ // contains filtered or unexported fields }
func (*MessageReportReq) Descriptor
deprecated
func (*MessageReportReq) Descriptor() ([]byte, []int)
Deprecated: Use MessageReportReq.ProtoReflect.Descriptor instead.
func (*MessageReportReq) GetAttributedSignedObservations ¶
func (x *MessageReportReq) GetAttributedSignedObservations() []*AttributedSignedObservation
func (*MessageReportReq) GetEpoch ¶
func (x *MessageReportReq) GetEpoch() uint64
func (*MessageReportReq) GetQuery ¶
func (x *MessageReportReq) GetQuery() []byte
func (*MessageReportReq) GetRound ¶
func (x *MessageReportReq) GetRound() uint32
func (*MessageReportReq) ProtoMessage ¶
func (*MessageReportReq) ProtoMessage()
func (*MessageReportReq) ProtoReflect ¶
func (x *MessageReportReq) ProtoReflect() protoreflect.Message
func (*MessageReportReq) Reset ¶
func (x *MessageReportReq) Reset()
func (*MessageReportReq) String ¶
func (x *MessageReportReq) String() string
type MessageWrapper ¶
type MessageWrapper struct { // Types that are assignable to Msg: // *MessageWrapper_MessageNewEpoch // *MessageWrapper_MessageObserveReq // *MessageWrapper_MessageObserve // *MessageWrapper_MessageReportReq // *MessageWrapper_MessageReport // *MessageWrapper_MessageFinal // *MessageWrapper_MessageFinalEcho Msg isMessageWrapper_Msg `protobuf_oneof:"msg"` // contains filtered or unexported fields }
func Deserialize ¶
func Deserialize(b []byte) (protocol.Message, *MessageWrapper, error)
Deserialize decodes a binary payload into a protocol.Message
func Serialize ¶
func Serialize(m protocol.Message) (b []byte, pbm *MessageWrapper, err error)
Serialize encodes a protocol.Message into a binary payload
func (*MessageWrapper) Descriptor
deprecated
func (*MessageWrapper) Descriptor() ([]byte, []int)
Deprecated: Use MessageWrapper.ProtoReflect.Descriptor instead.
func (*MessageWrapper) GetMessageFinal ¶
func (x *MessageWrapper) GetMessageFinal() *MessageFinal
func (*MessageWrapper) GetMessageFinalEcho ¶
func (x *MessageWrapper) GetMessageFinalEcho() *MessageFinalEcho
func (*MessageWrapper) GetMessageNewEpoch ¶
func (x *MessageWrapper) GetMessageNewEpoch() *MessageNewEpoch
func (*MessageWrapper) GetMessageObserve ¶
func (x *MessageWrapper) GetMessageObserve() *MessageObserve
func (*MessageWrapper) GetMessageObserveReq ¶
func (x *MessageWrapper) GetMessageObserveReq() *MessageObserveReq
func (*MessageWrapper) GetMessageReport ¶
func (x *MessageWrapper) GetMessageReport() *MessageReport
func (*MessageWrapper) GetMessageReportReq ¶
func (x *MessageWrapper) GetMessageReportReq() *MessageReportReq
func (*MessageWrapper) GetMsg ¶
func (m *MessageWrapper) GetMsg() isMessageWrapper_Msg
func (*MessageWrapper) ProtoMessage ¶
func (*MessageWrapper) ProtoMessage()
func (*MessageWrapper) ProtoReflect ¶
func (x *MessageWrapper) ProtoReflect() protoreflect.Message
func (*MessageWrapper) Reset ¶
func (x *MessageWrapper) Reset()
func (*MessageWrapper) String ¶
func (x *MessageWrapper) String() string
type MessageWrapper_MessageFinal ¶
type MessageWrapper_MessageFinal struct {
MessageFinal *MessageFinal `protobuf:"bytes,7,opt,name=message_final,json=messageFinal,proto3,oneof"`
}
type MessageWrapper_MessageFinalEcho ¶
type MessageWrapper_MessageFinalEcho struct {
MessageFinalEcho *MessageFinalEcho `protobuf:"bytes,8,opt,name=message_final_echo,json=messageFinalEcho,proto3,oneof"`
}
type MessageWrapper_MessageNewEpoch ¶
type MessageWrapper_MessageNewEpoch struct {
MessageNewEpoch *MessageNewEpoch `protobuf:"bytes,2,opt,name=message_new_epoch,json=messageNewEpoch,proto3,oneof"`
}
type MessageWrapper_MessageObserve ¶
type MessageWrapper_MessageObserve struct {
MessageObserve *MessageObserve `protobuf:"bytes,4,opt,name=message_observe,json=messageObserve,proto3,oneof"`
}
type MessageWrapper_MessageObserveReq ¶
type MessageWrapper_MessageObserveReq struct {
MessageObserveReq *MessageObserveReq `protobuf:"bytes,3,opt,name=message_observe_req,json=messageObserveReq,proto3,oneof"`
}
type MessageWrapper_MessageReport ¶
type MessageWrapper_MessageReport struct {
MessageReport *MessageReport `protobuf:"bytes,6,opt,name=message_report,json=messageReport,proto3,oneof"`
}
type MessageWrapper_MessageReportReq ¶
type MessageWrapper_MessageReportReq struct {
MessageReportReq *MessageReportReq `protobuf:"bytes,5,opt,name=message_report_req,json=messageReportReq,proto3,oneof"`
}
type SignedObservation ¶
type SignedObservation struct { Observation []byte `protobuf:"bytes,1,opt,name=observation,proto3" json:"observation,omitempty"` Signature []byte `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"` // contains filtered or unexported fields }
func (*SignedObservation) Descriptor
deprecated
func (*SignedObservation) Descriptor() ([]byte, []int)
Deprecated: Use SignedObservation.ProtoReflect.Descriptor instead.
func (*SignedObservation) GetObservation ¶
func (x *SignedObservation) GetObservation() []byte
func (*SignedObservation) GetSignature ¶
func (x *SignedObservation) GetSignature() []byte
func (*SignedObservation) ProtoMessage ¶
func (*SignedObservation) ProtoMessage()
func (*SignedObservation) ProtoReflect ¶
func (x *SignedObservation) ProtoReflect() protoreflect.Message
func (*SignedObservation) Reset ¶
func (x *SignedObservation) Reset()
func (*SignedObservation) String ¶
func (x *SignedObservation) String() string
type TelemetryAssertionViolation ¶
type TelemetryAssertionViolation struct { // Types that are assignable to Violation: // *TelemetryAssertionViolation_InvalidSerialization Violation isTelemetryAssertionViolation_Violation `protobuf_oneof:"violation"` // contains filtered or unexported fields }
func (*TelemetryAssertionViolation) Descriptor
deprecated
func (*TelemetryAssertionViolation) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryAssertionViolation.ProtoReflect.Descriptor instead.
func (*TelemetryAssertionViolation) GetInvalidSerialization ¶
func (x *TelemetryAssertionViolation) GetInvalidSerialization() *TelemetryAssertionViolationInvalidSerialization
func (*TelemetryAssertionViolation) GetViolation ¶
func (m *TelemetryAssertionViolation) GetViolation() isTelemetryAssertionViolation_Violation
func (*TelemetryAssertionViolation) ProtoMessage ¶
func (*TelemetryAssertionViolation) ProtoMessage()
func (*TelemetryAssertionViolation) ProtoReflect ¶
func (x *TelemetryAssertionViolation) ProtoReflect() protoreflect.Message
func (*TelemetryAssertionViolation) Reset ¶
func (x *TelemetryAssertionViolation) Reset()
func (*TelemetryAssertionViolation) String ¶
func (x *TelemetryAssertionViolation) String() string
type TelemetryAssertionViolationInvalidSerialization ¶
type TelemetryAssertionViolationInvalidSerialization struct { ConfigDigest []byte `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"` SerializedMsg []byte `protobuf:"bytes,2,opt,name=serialized_msg,json=serializedMsg,proto3" json:"serialized_msg,omitempty"` Sender uint32 `protobuf:"varint,3,opt,name=sender,proto3" json:"sender,omitempty"` // contains filtered or unexported fields }
func (*TelemetryAssertionViolationInvalidSerialization) Descriptor
deprecated
func (*TelemetryAssertionViolationInvalidSerialization) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryAssertionViolationInvalidSerialization.ProtoReflect.Descriptor instead.
func (*TelemetryAssertionViolationInvalidSerialization) GetConfigDigest ¶
func (x *TelemetryAssertionViolationInvalidSerialization) GetConfigDigest() []byte
func (*TelemetryAssertionViolationInvalidSerialization) GetSender ¶
func (x *TelemetryAssertionViolationInvalidSerialization) GetSender() uint32
func (*TelemetryAssertionViolationInvalidSerialization) GetSerializedMsg ¶
func (x *TelemetryAssertionViolationInvalidSerialization) GetSerializedMsg() []byte
func (*TelemetryAssertionViolationInvalidSerialization) ProtoMessage ¶
func (*TelemetryAssertionViolationInvalidSerialization) ProtoMessage()
func (*TelemetryAssertionViolationInvalidSerialization) ProtoReflect ¶
func (x *TelemetryAssertionViolationInvalidSerialization) ProtoReflect() protoreflect.Message
func (*TelemetryAssertionViolationInvalidSerialization) Reset ¶
func (x *TelemetryAssertionViolationInvalidSerialization) Reset()
func (*TelemetryAssertionViolationInvalidSerialization) String ¶
func (x *TelemetryAssertionViolationInvalidSerialization) String() string
type TelemetryAssertionViolation_InvalidSerialization ¶
type TelemetryAssertionViolation_InvalidSerialization struct {
InvalidSerialization *TelemetryAssertionViolationInvalidSerialization `protobuf:"bytes,2,opt,name=invalid_serialization,json=invalidSerialization,proto3,oneof"`
}
type TelemetryMessageBroadcast ¶
type TelemetryMessageBroadcast struct { ConfigDigest []byte `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"` Msg *MessageWrapper `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` SerializedMsg []byte `protobuf:"bytes,3,opt,name=serialized_msg,json=serializedMsg,proto3" json:"serialized_msg,omitempty"` // contains filtered or unexported fields }
func (*TelemetryMessageBroadcast) Descriptor
deprecated
func (*TelemetryMessageBroadcast) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryMessageBroadcast.ProtoReflect.Descriptor instead.
func (*TelemetryMessageBroadcast) GetConfigDigest ¶
func (x *TelemetryMessageBroadcast) GetConfigDigest() []byte
func (*TelemetryMessageBroadcast) GetMsg ¶
func (x *TelemetryMessageBroadcast) GetMsg() *MessageWrapper
func (*TelemetryMessageBroadcast) GetSerializedMsg ¶
func (x *TelemetryMessageBroadcast) GetSerializedMsg() []byte
func (*TelemetryMessageBroadcast) ProtoMessage ¶
func (*TelemetryMessageBroadcast) ProtoMessage()
func (*TelemetryMessageBroadcast) ProtoReflect ¶
func (x *TelemetryMessageBroadcast) ProtoReflect() protoreflect.Message
func (*TelemetryMessageBroadcast) Reset ¶
func (x *TelemetryMessageBroadcast) Reset()
func (*TelemetryMessageBroadcast) String ¶
func (x *TelemetryMessageBroadcast) String() string
type TelemetryMessageReceived ¶
type TelemetryMessageReceived struct { ConfigDigest []byte `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"` Msg *MessageWrapper `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` Sender uint32 `protobuf:"varint,3,opt,name=sender,proto3" json:"sender,omitempty"` // contains filtered or unexported fields }
func (*TelemetryMessageReceived) Descriptor
deprecated
func (*TelemetryMessageReceived) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryMessageReceived.ProtoReflect.Descriptor instead.
func (*TelemetryMessageReceived) GetConfigDigest ¶
func (x *TelemetryMessageReceived) GetConfigDigest() []byte
func (*TelemetryMessageReceived) GetMsg ¶
func (x *TelemetryMessageReceived) GetMsg() *MessageWrapper
func (*TelemetryMessageReceived) GetSender ¶
func (x *TelemetryMessageReceived) GetSender() uint32
func (*TelemetryMessageReceived) ProtoMessage ¶
func (*TelemetryMessageReceived) ProtoMessage()
func (*TelemetryMessageReceived) ProtoReflect ¶
func (x *TelemetryMessageReceived) ProtoReflect() protoreflect.Message
func (*TelemetryMessageReceived) Reset ¶
func (x *TelemetryMessageReceived) Reset()
func (*TelemetryMessageReceived) String ¶
func (x *TelemetryMessageReceived) String() string
type TelemetryMessageSent ¶
type TelemetryMessageSent struct { ConfigDigest []byte `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"` Msg *MessageWrapper `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"` SerializedMsg []byte `protobuf:"bytes,3,opt,name=serialized_msg,json=serializedMsg,proto3" json:"serialized_msg,omitempty"` Receiver uint32 `protobuf:"varint,4,opt,name=receiver,proto3" json:"receiver,omitempty"` // contains filtered or unexported fields }
func (*TelemetryMessageSent) Descriptor
deprecated
func (*TelemetryMessageSent) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryMessageSent.ProtoReflect.Descriptor instead.
func (*TelemetryMessageSent) GetConfigDigest ¶
func (x *TelemetryMessageSent) GetConfigDigest() []byte
func (*TelemetryMessageSent) GetMsg ¶
func (x *TelemetryMessageSent) GetMsg() *MessageWrapper
func (*TelemetryMessageSent) GetReceiver ¶
func (x *TelemetryMessageSent) GetReceiver() uint32
func (*TelemetryMessageSent) GetSerializedMsg ¶
func (x *TelemetryMessageSent) GetSerializedMsg() []byte
func (*TelemetryMessageSent) ProtoMessage ¶
func (*TelemetryMessageSent) ProtoMessage()
func (*TelemetryMessageSent) ProtoReflect ¶
func (x *TelemetryMessageSent) ProtoReflect() protoreflect.Message
func (*TelemetryMessageSent) Reset ¶
func (x *TelemetryMessageSent) Reset()
func (*TelemetryMessageSent) String ¶
func (x *TelemetryMessageSent) String() string
type TelemetryRoundStarted ¶
type TelemetryRoundStarted struct { ConfigDigest []byte `protobuf:"bytes,1,opt,name=config_digest,json=configDigest,proto3" json:"config_digest,omitempty"` Epoch uint64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"` Round uint64 `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"` Leader uint64 `protobuf:"varint,4,opt,name=leader,proto3" json:"leader,omitempty"` Time uint64 `protobuf:"varint,5,opt,name=time,proto3" json:"time,omitempty"` // contains filtered or unexported fields }
func (*TelemetryRoundStarted) Descriptor
deprecated
func (*TelemetryRoundStarted) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryRoundStarted.ProtoReflect.Descriptor instead.
func (*TelemetryRoundStarted) GetConfigDigest ¶
func (x *TelemetryRoundStarted) GetConfigDigest() []byte
func (*TelemetryRoundStarted) GetEpoch ¶
func (x *TelemetryRoundStarted) GetEpoch() uint64
func (*TelemetryRoundStarted) GetLeader ¶
func (x *TelemetryRoundStarted) GetLeader() uint64
func (*TelemetryRoundStarted) GetRound ¶
func (x *TelemetryRoundStarted) GetRound() uint64
func (*TelemetryRoundStarted) GetTime ¶
func (x *TelemetryRoundStarted) GetTime() uint64
func (*TelemetryRoundStarted) ProtoMessage ¶
func (*TelemetryRoundStarted) ProtoMessage()
func (*TelemetryRoundStarted) ProtoReflect ¶
func (x *TelemetryRoundStarted) ProtoReflect() protoreflect.Message
func (*TelemetryRoundStarted) Reset ¶
func (x *TelemetryRoundStarted) Reset()
func (*TelemetryRoundStarted) String ¶
func (x *TelemetryRoundStarted) String() string
type TelemetryWrapper ¶
type TelemetryWrapper struct { // Types that are assignable to Wrapped: // *TelemetryWrapper_MessageReceived // *TelemetryWrapper_MessageBroadcast // *TelemetryWrapper_MessageSent // *TelemetryWrapper_AssertionViolation // *TelemetryWrapper_RoundStarted Wrapped isTelemetryWrapper_Wrapped `protobuf_oneof:"wrapped"` UnixTimeNanoseconds int64 `protobuf:"varint,6,opt,name=unix_time_nanoseconds,json=unixTimeNanoseconds,proto3" json:"unix_time_nanoseconds,omitempty"` // contains filtered or unexported fields }
func (*TelemetryWrapper) Descriptor
deprecated
func (*TelemetryWrapper) Descriptor() ([]byte, []int)
Deprecated: Use TelemetryWrapper.ProtoReflect.Descriptor instead.
func (*TelemetryWrapper) GetAssertionViolation ¶
func (x *TelemetryWrapper) GetAssertionViolation() *TelemetryAssertionViolation
func (*TelemetryWrapper) GetMessageBroadcast ¶
func (x *TelemetryWrapper) GetMessageBroadcast() *TelemetryMessageBroadcast
func (*TelemetryWrapper) GetMessageReceived ¶
func (x *TelemetryWrapper) GetMessageReceived() *TelemetryMessageReceived
func (*TelemetryWrapper) GetMessageSent ¶
func (x *TelemetryWrapper) GetMessageSent() *TelemetryMessageSent
func (*TelemetryWrapper) GetRoundStarted ¶
func (x *TelemetryWrapper) GetRoundStarted() *TelemetryRoundStarted
func (*TelemetryWrapper) GetUnixTimeNanoseconds ¶
func (x *TelemetryWrapper) GetUnixTimeNanoseconds() int64
func (*TelemetryWrapper) GetWrapped ¶
func (m *TelemetryWrapper) GetWrapped() isTelemetryWrapper_Wrapped
func (*TelemetryWrapper) ProtoMessage ¶
func (*TelemetryWrapper) ProtoMessage()
func (*TelemetryWrapper) ProtoReflect ¶
func (x *TelemetryWrapper) ProtoReflect() protoreflect.Message
func (*TelemetryWrapper) Reset ¶
func (x *TelemetryWrapper) Reset()
func (*TelemetryWrapper) String ¶
func (x *TelemetryWrapper) String() string
type TelemetryWrapper_AssertionViolation ¶
type TelemetryWrapper_AssertionViolation struct {
AssertionViolation *TelemetryAssertionViolation `protobuf:"bytes,4,opt,name=assertion_violation,json=assertionViolation,proto3,oneof"`
}
type TelemetryWrapper_MessageBroadcast ¶
type TelemetryWrapper_MessageBroadcast struct {
MessageBroadcast *TelemetryMessageBroadcast `protobuf:"bytes,2,opt,name=message_broadcast,json=messageBroadcast,proto3,oneof"`
}
type TelemetryWrapper_MessageReceived ¶
type TelemetryWrapper_MessageReceived struct {
MessageReceived *TelemetryMessageReceived `protobuf:"bytes,1,opt,name=message_received,json=messageReceived,proto3,oneof"`
}
type TelemetryWrapper_MessageSent ¶
type TelemetryWrapper_MessageSent struct {
MessageSent *TelemetryMessageSent `protobuf:"bytes,3,opt,name=message_sent,json=messageSent,proto3,oneof"`
}
type TelemetryWrapper_RoundStarted ¶
type TelemetryWrapper_RoundStarted struct {
RoundStarted *TelemetryRoundStarted `protobuf:"bytes,5,opt,name=round_started,json=roundStarted,proto3,oneof"`
}