apppb

Documentation

Index

• Variables
• type Event
  • func (*Event) Descriptor() ([]byte, []int)
  • func (x *Event) GetNewEpoch() *NewEpoch
  • func (x *Event) GetRestoreState() *RestoreState
  • func (x *Event) GetSnapshot() *Snapshot
  • func (x *Event) GetSnapshotRequest() *SnapshotRequest
  • func (m *Event) GetType() isEvent_Type
  • func (*Event) ProtoMessage()
  • func (x *Event) ProtoReflect() protoreflect.Message
  • func (*Event) ReflectTypeOptions() []reflect.Type
  • func (x *Event) Reset()
  • func (x *Event) String() string
• type Event_NewEpoch
  • func (w *Event_NewEpoch) Unwrap() *NewEpoch
• type Event_RestoreState
  • func (w *Event_RestoreState) Unwrap() *RestoreState
• type Event_Snapshot
  • func (w *Event_Snapshot) Unwrap() *Snapshot
• type Event_SnapshotRequest
  • func (w *Event_SnapshotRequest) Unwrap() *SnapshotRequest
• type Event_Type
• type Event_TypeWrapper
• type NewEpoch
  • func (*NewEpoch) Descriptor() ([]byte, []int)
  • func (x *NewEpoch) GetEpochNr() uint64
  • func (x *NewEpoch) GetProtocolModule() string
  • func (*NewEpoch) ProtoMessage()
  • func (x *NewEpoch) ProtoReflect() protoreflect.Message
  • func (x *NewEpoch) Reset()
  • func (x *NewEpoch) String() string
• type RestoreState
  • func (*RestoreState) Descriptor() ([]byte, []int)
  • func (x *RestoreState) GetCheckpoint() *checkpointpb.StableCheckpoint
  • func (*RestoreState) ProtoMessage()
  • func (x *RestoreState) ProtoReflect() protoreflect.Message
  • func (x *RestoreState) Reset()
  • func (x *RestoreState) String() string
• type Snapshot
  • func (*Snapshot) Descriptor() ([]byte, []int)
  • func (x *Snapshot) GetAppData() []byte
  • func (*Snapshot) ProtoMessage()
  • func (x *Snapshot) ProtoReflect() protoreflect.Message
  • func (x *Snapshot) Reset()
  • func (x *Snapshot) String() string
• type SnapshotRequest
  • func (*SnapshotRequest) Descriptor() ([]byte, []int)
  • func (x *SnapshotRequest) GetReplyTo() string
  • func (*SnapshotRequest) ProtoMessage()
  • func (x *SnapshotRequest) ProtoReflect() protoreflect.Message
  • func (x *SnapshotRequest) Reset()
  • func (x *SnapshotRequest) String() string

Variables

var File_apppb_apppb_proto protoreflect.FileDescriptor

Types

type Event

type Event struct {

	// Types that are assignable to Type:
	//	*Event_SnapshotRequest
	//	*Event_Snapshot
	//	*Event_RestoreState
	//	*Event_NewEpoch
	Type isEvent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*Event) Descriptor

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetNewEpoch

func (x *Event) GetNewEpoch() *NewEpoch

func (*Event) GetRestoreState

func (x *Event) GetRestoreState() *RestoreState

func (*Event) GetSnapshot

func (x *Event) GetSnapshot() *Snapshot

func (*Event) GetSnapshotRequest

func (x *Event) GetSnapshotRequest() *SnapshotRequest

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

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

type Event_NewEpoch

type Event_NewEpoch struct {
	NewEpoch *NewEpoch `protobuf:"bytes,4,opt,name=new_epoch,json=newEpoch,proto3,oneof"`
}

func (*Event_NewEpoch) Unwrap

func (w *Event_NewEpoch) Unwrap() *NewEpoch

type Event_RestoreState

type Event_RestoreState struct {
	RestoreState *RestoreState `protobuf:"bytes,3,opt,name=restore_state,json=restoreState,proto3,oneof"`
}

func (*Event_RestoreState) Unwrap

func (w *Event_RestoreState) Unwrap() *RestoreState

type Event_Snapshot

type Event_Snapshot struct {
	Snapshot *Snapshot `protobuf:"bytes,2,opt,name=snapshot,proto3,oneof"`
}

func (*Event_Snapshot) Unwrap

func (w *Event_Snapshot) Unwrap() *Snapshot

type Event_SnapshotRequest

type Event_SnapshotRequest struct {
	SnapshotRequest *SnapshotRequest `protobuf:"bytes,1,opt,name=snapshot_request,json=snapshotRequest,proto3,oneof"`
}

func (*Event_SnapshotRequest) Unwrap

func (w *Event_SnapshotRequest) Unwrap() *SnapshotRequest

type Event_Type

type Event_Type = isEvent_Type

type Event_TypeWrapper

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

type NewEpoch

type NewEpoch struct {
	EpochNr        uint64 `protobuf:"varint,1,opt,name=epoch_nr,json=epochNr,proto3" json:"epoch_nr,omitempty"`
	ProtocolModule string `protobuf:"bytes,2,opt,name=protocol_module,json=protocolModule,proto3" json:"protocol_module,omitempty"`
	// contains filtered or unexported fields
}

func (*NewEpoch) Descriptor

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

Deprecated: Use NewEpoch.ProtoReflect.Descriptor instead.

func (*NewEpoch) GetEpochNr

func (x *NewEpoch) GetEpochNr() uint64

func (*NewEpoch) GetProtocolModule

func (x *NewEpoch) GetProtocolModule() string

func (*NewEpoch) ProtoMessage

func (*NewEpoch) ProtoMessage()

func (*NewEpoch) ProtoReflect

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

func (*NewEpoch) Reset

func (x *NewEpoch) Reset()

func (*NewEpoch) String

func (x *NewEpoch) String() string

type RestoreState

type RestoreState struct {
	Checkpoint *checkpointpb.StableCheckpoint `protobuf:"bytes,1,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*RestoreState) Descriptor

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

Deprecated: Use RestoreState.ProtoReflect.Descriptor instead.

func (*RestoreState) GetCheckpoint

func (x *RestoreState) GetCheckpoint() *checkpointpb.StableCheckpoint

func (*RestoreState) ProtoMessage

func (*RestoreState) ProtoMessage()

func (*RestoreState) ProtoReflect

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

func (*RestoreState) Reset

func (x *RestoreState) Reset()

func (*RestoreState) String

func (x *RestoreState) String() string

type Snapshot

type Snapshot struct {
	AppData []byte `protobuf:"bytes,1,opt,name=app_data,json=appData,proto3" json:"app_data,omitempty"`
	// contains filtered or unexported fields
}

func (*Snapshot) Descriptor

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

Deprecated: Use Snapshot.ProtoReflect.Descriptor instead.

func (*Snapshot) GetAppData

func (x *Snapshot) GetAppData() []byte

func (*Snapshot) ProtoMessage

func (*Snapshot) ProtoMessage()

func (*Snapshot) ProtoReflect

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

func (*Snapshot) Reset

func (x *Snapshot) Reset()

func (*Snapshot) String

func (x *Snapshot) String() string

type SnapshotRequest

type SnapshotRequest struct {
	ReplyTo string `protobuf:"bytes,1,opt,name=reply_to,json=replyTo,proto3" json:"reply_to,omitempty"`
	// contains filtered or unexported fields
}

func (*SnapshotRequest) Descriptor

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

Deprecated: Use SnapshotRequest.ProtoReflect.Descriptor instead.

func (*SnapshotRequest) GetReplyTo

func (x *SnapshotRequest) GetReplyTo() string

func (*SnapshotRequest) ProtoMessage

func (*SnapshotRequest) ProtoMessage()

func (*SnapshotRequest) ProtoReflect

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

func (*SnapshotRequest) Reset

func (x *SnapshotRequest) Reset()

func (*SnapshotRequest) String

func (x *SnapshotRequest) String() string