checkpointpb

package
v0.4.4 Latest Latest
Warning

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

 Go to latest Published: Aug 2, 2023 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_checkpointpb_checkpointpb_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Checkpoint 

type Checkpoint struct {
	Epoch        uint64 `protobuf:"varint,1,opt,name=epoch,proto3" json:"epoch,omitempty"`
	Sn           uint64 `protobuf:"varint,2,opt,name=sn,proto3" json:"sn,omitempty"`
	SnapshotHash []byte `protobuf:"bytes,3,opt,name=snapshotHash,proto3" json:"snapshotHash,omitempty"`
	Signature    []byte `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*Checkpoint) Descriptor deprecated 

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

Deprecated: Use Checkpoint.ProtoReflect.Descriptor instead.

func (*Checkpoint) GetEpoch 

func (x *Checkpoint) GetEpoch() uint64

func (*Checkpoint) GetSignature 

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

func (*Checkpoint) GetSn 

func (x *Checkpoint) GetSn() uint64

func (*Checkpoint) GetSnapshotHash 

func (x *Checkpoint) GetSnapshotHash() []byte

func (*Checkpoint) ProtoMessage 

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) ProtoReflect 

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

func (*Checkpoint) Reset 

func (x *Checkpoint) Reset()

func (*Checkpoint) String 

func (x *Checkpoint) String() string

type EpochProgress 

type EpochProgress struct {
	NodeId string `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	Epoch  uint64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
	// contains filtered or unexported fields
}

func (*EpochProgress) Descriptor deprecated 

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

Deprecated: Use EpochProgress.ProtoReflect.Descriptor instead.

func (*EpochProgress) GetEpoch 

func (x *EpochProgress) GetEpoch() uint64

func (*EpochProgress) GetNodeId 

func (x *EpochProgress) GetNodeId() string

func (*EpochProgress) ProtoMessage 

func (*EpochProgress) ProtoMessage()

func (*EpochProgress) ProtoReflect 

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

func (*EpochProgress) Reset 

func (x *EpochProgress) Reset()

func (*EpochProgress) String 

func (x *EpochProgress) String() string

type Event 

type Event struct {

	// Types that are assignable to Type:
	//	*Event_EpochConfig
	//	*Event_StableCheckpoint
	//	*Event_EpochProgress
	Type isEvent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor deprecated 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetEpochConfig 

func (x *Event) GetEpochConfig() *trantorpb.EpochConfig

func (*Event) GetEpochProgress 

func (x *Event) GetEpochProgress() *EpochProgress

func (*Event) GetStableCheckpoint 

func (x *Event) GetStableCheckpoint() *StableCheckpoint

func (*Event) GetType 

func (m *Event) GetType() isEvent_Type

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) ReflectTypeOptions added in v0.3.0 

func (*Event) ReflectTypeOptions() []reflect.Type

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) String 

func (x *Event) String() string

type Event_EpochConfig 

type Event_EpochConfig struct {
	EpochConfig *trantorpb.EpochConfig `protobuf:"bytes,1,opt,name=epoch_config,json=epochConfig,proto3,oneof"`
}

func (*Event_EpochConfig) Unwrap added in v0.3.0 

func (w *Event_EpochConfig) Unwrap() *trantorpb.EpochConfig

type Event_EpochProgress 

type Event_EpochProgress struct {
	EpochProgress *EpochProgress `protobuf:"bytes,3,opt,name=epoch_progress,json=epochProgress,proto3,oneof"`
}

func (*Event_EpochProgress) Unwrap added in v0.3.0 

func (w *Event_EpochProgress) Unwrap() *EpochProgress

type Event_StableCheckpoint 

type Event_StableCheckpoint struct {
	StableCheckpoint *StableCheckpoint `protobuf:"bytes,2,opt,name=stable_checkpoint,json=stableCheckpoint,proto3,oneof"`
}

func (*Event_StableCheckpoint) Unwrap added in v0.3.0 

func (w *Event_StableCheckpoint) Unwrap() *StableCheckpoint

type Event_Type added in v0.3.0 

type Event_Type = isEvent_Type

type Event_TypeWrapper added in v0.3.0 

type Event_TypeWrapper[T any] interface {
	Event_Type
	Unwrap() *T
}

type InstanceParams 

type InstanceParams struct {
	Membership       *trantorpb.Membership  `protobuf:"bytes,1,opt,name=membership,proto3" json:"membership,omitempty"`
	ResendPeriod     uint64                 `protobuf:"varint,2,opt,name=resend_period,json=resendPeriod,proto3" json:"resend_period,omitempty"`
	LeaderPolicyData []byte                 `protobuf:"bytes,3,opt,name=leader_policy_data,json=leaderPolicyData,proto3" json:"leader_policy_data,omitempty"`
	EpochConfig      *trantorpb.EpochConfig `protobuf:"bytes,4,opt,name=epoch_config,json=epochConfig,proto3" json:"epoch_config,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceParams) Descriptor deprecated 

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

Deprecated: Use InstanceParams.ProtoReflect.Descriptor instead.

func (*InstanceParams) GetEpochConfig added in v0.2.2 

func (x *InstanceParams) GetEpochConfig() *trantorpb.EpochConfig

func (*InstanceParams) GetLeaderPolicyData added in v0.2.1 

func (x *InstanceParams) GetLeaderPolicyData() []byte

func (*InstanceParams) GetMembership added in v0.2.2 

func (x *InstanceParams) GetMembership() *trantorpb.Membership

func (*InstanceParams) GetResendPeriod 

func (x *InstanceParams) GetResendPeriod() uint64

func (*InstanceParams) ProtoMessage 

func (*InstanceParams) ProtoMessage()

func (*InstanceParams) ProtoReflect 

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

func (*InstanceParams) Reset 

func (x *InstanceParams) Reset()

func (*InstanceParams) String 

func (x *InstanceParams) String() string

type Message 

type Message struct {

	// Types that are assignable to Type:
	//	*Message_Checkpoint
	Type isMessage_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*Message) Descriptor deprecated 

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

Deprecated: Use Message.ProtoReflect.Descriptor instead.

func (*Message) GetCheckpoint 

func (x *Message) GetCheckpoint() *Checkpoint

func (*Message) GetType 

func (m *Message) GetType() isMessage_Type

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) ProtoReflect 

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

func (*Message) ReflectTypeOptions added in v0.3.5 

func (*Message) ReflectTypeOptions() []reflect.Type

func (*Message) Reset 

func (x *Message) Reset()

func (*Message) String 

func (x *Message) String() string

type Message_Checkpoint 

type Message_Checkpoint struct {
	Checkpoint *Checkpoint `protobuf:"bytes,1,opt,name=checkpoint,proto3,oneof"`
}

func (*Message_Checkpoint) Unwrap added in v0.3.5 

func (w *Message_Checkpoint) Unwrap() *Checkpoint

type Message_Type added in v0.3.5 

type Message_Type = isMessage_Type

type Message_TypeWrapper added in v0.3.5 

type Message_TypeWrapper[T any] interface {
	Message_Type
	Unwrap() *T
}

type StableCheckpoint 

type StableCheckpoint struct {
	Sn       uint64                   `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	Snapshot *trantorpb.StateSnapshot `protobuf:"bytes,2,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	Cert     map[string][]byte        `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StableCheckpoint) Descriptor deprecated 

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

Deprecated: Use StableCheckpoint.ProtoReflect.Descriptor instead.

func (*StableCheckpoint) GetCert 

func (x *StableCheckpoint) GetCert() map[string][]byte

func (*StableCheckpoint) GetSn 

func (x *StableCheckpoint) GetSn() uint64

func (*StableCheckpoint) GetSnapshot 

func (x *StableCheckpoint) GetSnapshot() *trantorpb.StateSnapshot

func (*StableCheckpoint) ProtoMessage 

func (*StableCheckpoint) ProtoMessage()

func (*StableCheckpoint) ProtoReflect 

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

func (*StableCheckpoint) Reset 

func (x *StableCheckpoint) Reset()

func (*StableCheckpoint) String 

func (x *StableCheckpoint) String() string

Source Files

View all Source files

Directories

Path Synopsis
dsl
events
types

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.