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

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.