checkpointpbtypes

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: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Checkpoint added in v0.3.5 

type Checkpoint struct {
	Epoch        types.EpochNr
	Sn           types.SeqNr
	SnapshotHash []uint8
	Signature    []uint8
}

func CheckpointFromPb added in v0.3.5 

func CheckpointFromPb(pb *checkpointpb.Checkpoint) *Checkpoint

func (*Checkpoint) MirReflect added in v0.3.5 

func (*Checkpoint) MirReflect() mirreflect.Type

func (*Checkpoint) Pb added in v0.3.5 

func (m *Checkpoint) Pb() *checkpointpb.Checkpoint

type EpochProgress added in v0.3.5 

type EpochProgress struct {
	NodeId types2.NodeID
	Epoch  types.EpochNr
}

func EpochProgressFromPb added in v0.3.5 

func EpochProgressFromPb(pb *checkpointpb.EpochProgress) *EpochProgress

func (*EpochProgress) MirReflect added in v0.3.5 

func (*EpochProgress) MirReflect() mirreflect.Type

func (*EpochProgress) Pb added in v0.3.5 

func (m *EpochProgress) Pb() *checkpointpb.EpochProgress

type Event 

type Event struct {
	Type Event_Type
}

func EventFromPb 

func EventFromPb(pb *checkpointpb.Event) *Event

func (*Event) MirReflect 

func (*Event) MirReflect() mirreflect.Type

func (*Event) Pb 

func (m *Event) Pb() *checkpointpb.Event

type Event_EpochConfig 

type Event_EpochConfig struct {
	EpochConfig *types1.EpochConfig
}

func (*Event_EpochConfig) MirReflect 

func (*Event_EpochConfig) MirReflect() mirreflect.Type

func (*Event_EpochConfig) Pb 

func (w *Event_EpochConfig) Pb() checkpointpb.Event_Type

func (*Event_EpochConfig) Unwrap 

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

type Event_EpochProgress 

type Event_EpochProgress struct {
	EpochProgress *EpochProgress
}

func (*Event_EpochProgress) MirReflect 

func (*Event_EpochProgress) MirReflect() mirreflect.Type

func (*Event_EpochProgress) Pb 

func (w *Event_EpochProgress) Pb() checkpointpb.Event_Type

func (*Event_EpochProgress) Unwrap 

func (w *Event_EpochProgress) Unwrap() *EpochProgress

type Event_StableCheckpoint 

type Event_StableCheckpoint struct {
	StableCheckpoint *StableCheckpoint
}

func (*Event_StableCheckpoint) MirReflect 

func (*Event_StableCheckpoint) MirReflect() mirreflect.Type

func (*Event_StableCheckpoint) Pb 

func (w *Event_StableCheckpoint) Pb() checkpointpb.Event_Type

func (*Event_StableCheckpoint) Unwrap 

func (w *Event_StableCheckpoint) Unwrap() *StableCheckpoint

type Event_Type 

type Event_Type interface {
	mirreflect.GeneratedType

	Pb() checkpointpb.Event_Type
	// contains filtered or unexported methods
}

func Event_TypeFromPb 

func Event_TypeFromPb(pb checkpointpb.Event_Type) Event_Type

type Event_TypeWrapper 

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

type InstanceParams added in v0.3.5 

type InstanceParams struct {
	Membership       *types1.Membership
	ResendPeriod     types4.Duration
	LeaderPolicyData []uint8
	EpochConfig      *types1.EpochConfig
}

func InstanceParamsFromPb added in v0.3.5 

func InstanceParamsFromPb(pb *checkpointpb.InstanceParams) *InstanceParams

func (*InstanceParams) MirReflect added in v0.3.5 

func (*InstanceParams) MirReflect() mirreflect.Type

func (*InstanceParams) Pb added in v0.3.5 

func (m *InstanceParams) Pb() *checkpointpb.InstanceParams

type Message added in v0.3.5 

type Message struct {
	Type Message_Type
}

func MessageFromPb added in v0.3.5 

func MessageFromPb(pb *checkpointpb.Message) *Message

func (*Message) MirReflect added in v0.3.5 

func (*Message) MirReflect() mirreflect.Type

func (*Message) Pb added in v0.3.5 

func (m *Message) Pb() *checkpointpb.Message

type Message_Checkpoint added in v0.3.5 

type Message_Checkpoint struct {
	Checkpoint *Checkpoint
}

func (*Message_Checkpoint) MirReflect added in v0.3.5 

func (*Message_Checkpoint) MirReflect() mirreflect.Type

func (*Message_Checkpoint) Pb added in v0.3.5 

func (w *Message_Checkpoint) Pb() checkpointpb.Message_Type

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 interface {
	mirreflect.GeneratedType

	Pb() checkpointpb.Message_Type
	// contains filtered or unexported methods
}

func Message_TypeFromPb added in v0.3.5 

func Message_TypeFromPb(pb checkpointpb.Message_Type) Message_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       types.SeqNr
	Snapshot *types1.StateSnapshot
	Cert     map[types2.NodeID][]uint8
}

func StableCheckpointFromPb 

func StableCheckpointFromPb(pb *checkpointpb.StableCheckpoint) *StableCheckpoint

func (*StableCheckpoint) MirReflect 

func (*StableCheckpoint) MirReflect() mirreflect.Type

func (*StableCheckpoint) Pb 

func (m *StableCheckpoint) Pb() *checkpointpb.StableCheckpoint

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.