types

package
v0.4.0 Latest Latest
Warning

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

Go to latest
Published: Dec 6, 2021 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_metrics_types_types_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Event

type Event struct {
	ID        uint32                 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
	Client    bool                   `protobuf:"varint,2,opt,name=Client,proto3" json:"Client,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=Timestamp,proto3" json:"Timestamp,omitempty"`
	// contains filtered or unexported fields
}

Event is the basic type that is recorded by hotstuff. It contains the ID of the replica/client, the type (replica/client), the timestamp of the event, and the data.

func NewClientEvent

func NewClientEvent(id uint32, timestamp time.Time) *Event

NewClientEvent creates a new client event.

func NewReplicaEvent

func NewReplicaEvent(id uint32, timestamp time.Time) *Event

NewReplicaEvent creates a new replica event.

func (*Event) Descriptor deprecated

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetClient

func (x *Event) GetClient() bool

func (*Event) GetID

func (x *Event) GetID() uint32

func (*Event) GetTimestamp

func (x *Event) GetTimestamp() *timestamppb.Timestamp

func (*Event) ProtoMessage

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type LatencyMeasurement

type LatencyMeasurement struct {
	Event    *Event  `protobuf:"bytes,1,opt,name=Event,proto3" json:"Event,omitempty"`
	Latency  float64 `protobuf:"fixed64,2,opt,name=Latency,proto3" json:"Latency,omitempty"`
	Variance float64 `protobuf:"fixed64,3,opt,name=Variance,proto3" json:"Variance,omitempty"`
	Count    uint64  `protobuf:"varint,4,opt,name=Count,proto3" json:"Count,omitempty"`
	// contains filtered or unexported fields
}

func (*LatencyMeasurement) Descriptor deprecated

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

Deprecated: Use LatencyMeasurement.ProtoReflect.Descriptor instead.

func (*LatencyMeasurement) GetCount

func (x *LatencyMeasurement) GetCount() uint64

func (*LatencyMeasurement) GetEvent

func (x *LatencyMeasurement) GetEvent() *Event

func (*LatencyMeasurement) GetLatency

func (x *LatencyMeasurement) GetLatency() float64

func (*LatencyMeasurement) GetVariance

func (x *LatencyMeasurement) GetVariance() float64

func (*LatencyMeasurement) ProtoMessage

func (*LatencyMeasurement) ProtoMessage()

func (*LatencyMeasurement) ProtoReflect

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

func (*LatencyMeasurement) Reset

func (x *LatencyMeasurement) Reset()

func (*LatencyMeasurement) String

func (x *LatencyMeasurement) String() string

type StartEvent

type StartEvent struct {
	Event *Event `protobuf:"bytes,1,opt,name=Event,proto3" json:"Event,omitempty"`
	// contains filtered or unexported fields
}

func (*StartEvent) Descriptor deprecated

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

Deprecated: Use StartEvent.ProtoReflect.Descriptor instead.

func (*StartEvent) GetEvent

func (x *StartEvent) GetEvent() *Event

func (*StartEvent) ProtoMessage

func (*StartEvent) ProtoMessage()

func (*StartEvent) ProtoReflect

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

func (*StartEvent) Reset

func (x *StartEvent) Reset()

func (*StartEvent) String

func (x *StartEvent) String() string

type ThroughputMeasurement

type ThroughputMeasurement struct {
	Event    *Event               `protobuf:"bytes,1,opt,name=Event,proto3" json:"Event,omitempty"`
	Commits  uint64               `protobuf:"varint,2,opt,name=Commits,proto3" json:"Commits,omitempty"`
	Commands uint64               `protobuf:"varint,3,opt,name=Commands,proto3" json:"Commands,omitempty"`
	Duration *durationpb.Duration `protobuf:"bytes,4,opt,name=Duration,proto3" json:"Duration,omitempty"`
	// contains filtered or unexported fields
}

func (*ThroughputMeasurement) Descriptor deprecated

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

Deprecated: Use ThroughputMeasurement.ProtoReflect.Descriptor instead.

func (*ThroughputMeasurement) GetCommands

func (x *ThroughputMeasurement) GetCommands() uint64

func (*ThroughputMeasurement) GetCommits

func (x *ThroughputMeasurement) GetCommits() uint64

func (*ThroughputMeasurement) GetDuration

func (x *ThroughputMeasurement) GetDuration() *durationpb.Duration

func (*ThroughputMeasurement) GetEvent

func (x *ThroughputMeasurement) GetEvent() *Event

func (*ThroughputMeasurement) ProtoMessage

func (*ThroughputMeasurement) ProtoMessage()

func (*ThroughputMeasurement) ProtoReflect

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

func (*ThroughputMeasurement) Reset

func (x *ThroughputMeasurement) Reset()

func (*ThroughputMeasurement) String

func (x *ThroughputMeasurement) String() string

type TickEvent

type TickEvent struct {
	// The time when the previous tick happened.
	LastTick time.Time
}

TickEvent is sent when new measurements should be recorded.

type ViewTimeouts

type ViewTimeouts struct {
	Event *Event `protobuf:"bytes,1,opt,name=Event,proto3" json:"Event,omitempty"`
	// Number of views since last reading.
	Views uint64 `protobuf:"varint,2,opt,name=Views,proto3" json:"Views,omitempty"`
	// Number of view timeouts.
	Timeouts uint64 `protobuf:"varint,3,opt,name=Timeouts,proto3" json:"Timeouts,omitempty"`
	// contains filtered or unexported fields
}

func (*ViewTimeouts) Descriptor deprecated

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

Deprecated: Use ViewTimeouts.ProtoReflect.Descriptor instead.

func (*ViewTimeouts) GetEvent

func (x *ViewTimeouts) GetEvent() *Event

func (*ViewTimeouts) GetTimeouts

func (x *ViewTimeouts) GetTimeouts() uint64

func (*ViewTimeouts) GetViews

func (x *ViewTimeouts) GetViews() uint64

func (*ViewTimeouts) ProtoMessage

func (*ViewTimeouts) ProtoMessage()

func (*ViewTimeouts) ProtoReflect

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

func (*ViewTimeouts) Reset

func (x *ViewTimeouts) Reset()

func (*ViewTimeouts) String

func (x *ViewTimeouts) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL