isspb

package
v0.3.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_isspb_isspb_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type ISSEvent 

type ISSEvent struct {

	// Types that are assignable to Type:
	//	*ISSEvent_PersistCheckpoint
	//	*ISSEvent_PersistStableCheckpoint
	//	*ISSEvent_PushCheckpoint
	//	*ISSEvent_SbDeliver
	Type isISSEvent_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ISSEvent) Descriptor deprecated 

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

Deprecated: Use ISSEvent.ProtoReflect.Descriptor instead.

func (*ISSEvent) GetPersistCheckpoint 

func (x *ISSEvent) GetPersistCheckpoint() *PersistCheckpoint

func (*ISSEvent) GetPersistStableCheckpoint 

func (x *ISSEvent) GetPersistStableCheckpoint() *PersistStableCheckpoint

func (*ISSEvent) GetPushCheckpoint 

func (x *ISSEvent) GetPushCheckpoint() *PushCheckpoint

func (*ISSEvent) GetSbDeliver added in v0.2.0 

func (x *ISSEvent) GetSbDeliver() *SBDeliver

func (*ISSEvent) GetType 

func (m *ISSEvent) GetType() isISSEvent_Type

func (*ISSEvent) ProtoMessage 

func (*ISSEvent) ProtoMessage()

func (*ISSEvent) ProtoReflect 

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

func (*ISSEvent) Reset 

func (x *ISSEvent) Reset()

func (*ISSEvent) String 

func (x *ISSEvent) String() string

type ISSEvent_PersistCheckpoint 

type ISSEvent_PersistCheckpoint struct {
	PersistCheckpoint *PersistCheckpoint `protobuf:"bytes,1,opt,name=persist_checkpoint,json=persistCheckpoint,proto3,oneof"`
}

type ISSEvent_PersistStableCheckpoint 

type ISSEvent_PersistStableCheckpoint struct {
	PersistStableCheckpoint *PersistStableCheckpoint `protobuf:"bytes,3,opt,name=persist_stable_checkpoint,json=persistStableCheckpoint,proto3,oneof"`
}

type ISSEvent_PushCheckpoint 

type ISSEvent_PushCheckpoint struct {
	PushCheckpoint *PushCheckpoint `protobuf:"bytes,5,opt,name=push_checkpoint,json=pushCheckpoint,proto3,oneof"`
}

type ISSEvent_SbDeliver added in v0.2.0 

type ISSEvent_SbDeliver struct {
	SbDeliver *SBDeliver `protobuf:"bytes,6,opt,name=sb_deliver,json=sbDeliver,proto3,oneof"`
}

type ISSHashOrigin 

type ISSHashOrigin struct {

	// Types that are assignable to Type:
	//	*ISSHashOrigin_LogEntrySn
	//	*ISSHashOrigin_StateSnapshotEpoch
	//	*ISSHashOrigin_Requests
	Type isISSHashOrigin_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ISSHashOrigin) Descriptor deprecated 

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

Deprecated: Use ISSHashOrigin.ProtoReflect.Descriptor instead.

func (*ISSHashOrigin) GetLogEntrySn 

func (x *ISSHashOrigin) GetLogEntrySn() uint64

func (*ISSHashOrigin) GetRequests 

func (x *ISSHashOrigin) GetRequests() *RequestHashOrigin

func (*ISSHashOrigin) GetStateSnapshotEpoch 

func (x *ISSHashOrigin) GetStateSnapshotEpoch() uint64

func (*ISSHashOrigin) GetType 

func (m *ISSHashOrigin) GetType() isISSHashOrigin_Type

func (*ISSHashOrigin) ProtoMessage 

func (*ISSHashOrigin) ProtoMessage()

func (*ISSHashOrigin) ProtoReflect 

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

func (*ISSHashOrigin) Reset 

func (x *ISSHashOrigin) Reset()

func (*ISSHashOrigin) String 

func (x *ISSHashOrigin) String() string

type ISSHashOrigin_LogEntrySn 

type ISSHashOrigin_LogEntrySn struct {
	LogEntrySn uint64 `protobuf:"varint,2,opt,name=log_entry_sn,json=logEntrySn,proto3,oneof"`
}

type ISSHashOrigin_Requests 

type ISSHashOrigin_Requests struct {
	Requests *RequestHashOrigin `protobuf:"bytes,4,opt,name=requests,proto3,oneof"`
}

type ISSHashOrigin_StateSnapshotEpoch 

type ISSHashOrigin_StateSnapshotEpoch struct {
	StateSnapshotEpoch uint64 `protobuf:"varint,3,opt,name=state_snapshot_epoch,json=stateSnapshotEpoch,proto3,oneof"`
}

type ISSMessage 

type ISSMessage struct {

	// Types that are assignable to Type:
	//	*ISSMessage_StableCheckpoint
	//	*ISSMessage_RetransmitRequests
	Type isISSMessage_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ISSMessage) Descriptor deprecated 

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

Deprecated: Use ISSMessage.ProtoReflect.Descriptor instead.

func (*ISSMessage) GetRetransmitRequests 

func (x *ISSMessage) GetRetransmitRequests() *RetransmitRequests

func (*ISSMessage) GetStableCheckpoint 

func (x *ISSMessage) GetStableCheckpoint() *checkpointpb.StableCheckpoint

func (*ISSMessage) GetType 

func (m *ISSMessage) GetType() isISSMessage_Type

func (*ISSMessage) ProtoMessage 

func (*ISSMessage) ProtoMessage()

func (*ISSMessage) ProtoReflect 

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

func (*ISSMessage) Reset 

func (x *ISSMessage) Reset()

func (*ISSMessage) String 

func (x *ISSMessage) String() string

type ISSMessage_RetransmitRequests 

type ISSMessage_RetransmitRequests struct {
	RetransmitRequests *RetransmitRequests `protobuf:"bytes,4,opt,name=retransmit_requests,json=retransmitRequests,proto3,oneof"`
}

type ISSMessage_StableCheckpoint 

type ISSMessage_StableCheckpoint struct {
	// SBMessage                       sb                  = 1;
	StableCheckpoint *checkpointpb.StableCheckpoint `protobuf:"bytes,3,opt,name=stable_checkpoint,json=stableCheckpoint,proto3,oneof"`
}

type ISSSigVerOrigin 

type ISSSigVerOrigin struct {

	// Types that are assignable to Type:
	//	*ISSSigVerOrigin_CheckpointEpoch
	//	*ISSSigVerOrigin_StableCheckpoint
	Type isISSSigVerOrigin_Type `protobuf_oneof:"type"`
	// contains filtered or unexported fields
}

func (*ISSSigVerOrigin) Descriptor deprecated 

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

Deprecated: Use ISSSigVerOrigin.ProtoReflect.Descriptor instead.

func (*ISSSigVerOrigin) GetCheckpointEpoch 

func (x *ISSSigVerOrigin) GetCheckpointEpoch() uint64

func (*ISSSigVerOrigin) GetStableCheckpoint 

func (x *ISSSigVerOrigin) GetStableCheckpoint() *checkpointpb.StableCheckpoint

func (*ISSSigVerOrigin) GetType 

func (m *ISSSigVerOrigin) GetType() isISSSigVerOrigin_Type

func (*ISSSigVerOrigin) ProtoMessage 

func (*ISSSigVerOrigin) ProtoMessage()

func (*ISSSigVerOrigin) ProtoReflect 

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

func (*ISSSigVerOrigin) Reset 

func (x *ISSSigVerOrigin) Reset()

func (*ISSSigVerOrigin) String 

func (x *ISSSigVerOrigin) String() string

type ISSSigVerOrigin_CheckpointEpoch 

type ISSSigVerOrigin_CheckpointEpoch struct {
	CheckpointEpoch uint64 `protobuf:"varint,2,opt,name=checkpoint_epoch,json=checkpointEpoch,proto3,oneof"`
}

type ISSSigVerOrigin_StableCheckpoint 

type ISSSigVerOrigin_StableCheckpoint struct {
	StableCheckpoint *checkpointpb.StableCheckpoint `protobuf:"bytes,3,opt,name=stable_checkpoint,json=stableCheckpoint,proto3,oneof"`
}

type PersistCheckpoint 

type PersistCheckpoint struct {
	Sn                uint64                  `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	StateSnapshot     *commonpb.StateSnapshot `protobuf:"bytes,2,opt,name=state_snapshot,json=stateSnapshot,proto3" json:"state_snapshot,omitempty"`
	StateSnapshotHash []byte                  `protobuf:"bytes,3,opt,name=state_snapshot_hash,json=stateSnapshotHash,proto3" json:"state_snapshot_hash,omitempty"`
	Signature         []byte                  `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	// contains filtered or unexported fields
}

func (*PersistCheckpoint) Descriptor deprecated 

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

Deprecated: Use PersistCheckpoint.ProtoReflect.Descriptor instead.

func (*PersistCheckpoint) GetSignature 

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

func (*PersistCheckpoint) GetSn 

func (x *PersistCheckpoint) GetSn() uint64

func (*PersistCheckpoint) GetStateSnapshot 

func (x *PersistCheckpoint) GetStateSnapshot() *commonpb.StateSnapshot

func (*PersistCheckpoint) GetStateSnapshotHash 

func (x *PersistCheckpoint) GetStateSnapshotHash() []byte

func (*PersistCheckpoint) ProtoMessage 

func (*PersistCheckpoint) ProtoMessage()

func (*PersistCheckpoint) ProtoReflect 

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

func (*PersistCheckpoint) Reset 

func (x *PersistCheckpoint) Reset()

func (*PersistCheckpoint) String 

func (x *PersistCheckpoint) String() string

type PersistStableCheckpoint 

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

PersistStableCheckpoint needs to be a separate Event from StableCheckpoint, since both are ISSEvents, but, the protocol must differentiate between them. While the former will be applied on recovery from the WAL, the latter serves as a notification to the ISS protocol when a stable checkpoint has been persisted.

func (*PersistStableCheckpoint) Descriptor deprecated 

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

Deprecated: Use PersistStableCheckpoint.ProtoReflect.Descriptor instead.

func (*PersistStableCheckpoint) GetStableCheckpoint 

func (x *PersistStableCheckpoint) GetStableCheckpoint() *checkpointpb.StableCheckpoint

func (*PersistStableCheckpoint) ProtoMessage 

func (*PersistStableCheckpoint) ProtoMessage()

func (*PersistStableCheckpoint) ProtoReflect 

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

func (*PersistStableCheckpoint) Reset 

func (x *PersistStableCheckpoint) Reset()

func (*PersistStableCheckpoint) String 

func (x *PersistStableCheckpoint) String() string

type PushCheckpoint 

type PushCheckpoint struct {
	// contains filtered or unexported fields
}

func (*PushCheckpoint) Descriptor deprecated 

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

Deprecated: Use PushCheckpoint.ProtoReflect.Descriptor instead.

func (*PushCheckpoint) ProtoMessage 

func (*PushCheckpoint) ProtoMessage()

func (*PushCheckpoint) ProtoReflect 

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

func (*PushCheckpoint) Reset 

func (x *PushCheckpoint) Reset()

func (*PushCheckpoint) String 

func (x *PushCheckpoint) String() string

type RequestHashOrigin 

type RequestHashOrigin struct {
	Requests []*requestpb.Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*RequestHashOrigin) Descriptor deprecated 

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

Deprecated: Use RequestHashOrigin.ProtoReflect.Descriptor instead.

func (*RequestHashOrigin) GetRequests 

func (x *RequestHashOrigin) GetRequests() []*requestpb.Request

func (*RequestHashOrigin) ProtoMessage 

func (*RequestHashOrigin) ProtoMessage()

func (*RequestHashOrigin) ProtoReflect 

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

func (*RequestHashOrigin) Reset 

func (x *RequestHashOrigin) Reset()

func (*RequestHashOrigin) String 

func (x *RequestHashOrigin) String() string

type RetransmitRequests 

type RetransmitRequests struct {
	Requests []*requestpb.Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

func (*RetransmitRequests) Descriptor deprecated 

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

Deprecated: Use RetransmitRequests.ProtoReflect.Descriptor instead.

func (*RetransmitRequests) GetRequests 

func (x *RetransmitRequests) GetRequests() []*requestpb.Request

func (*RetransmitRequests) ProtoMessage 

func (*RetransmitRequests) ProtoMessage()

func (*RetransmitRequests) ProtoReflect 

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

func (*RetransmitRequests) Reset 

func (x *RetransmitRequests) Reset()

func (*RetransmitRequests) String 

func (x *RetransmitRequests) String() string

type SBDeliver 

type SBDeliver struct {
	Sn         uint64 `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"`
	Data       []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Aborted    bool   `protobuf:"varint,3,opt,name=aborted,proto3" json:"aborted,omitempty"`
	Leader     string `protobuf:"bytes,4,opt,name=leader,proto3" json:"leader,omitempty"`
	InstanceId string `protobuf:"bytes,5,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SBDeliver) Descriptor deprecated 

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

Deprecated: Use SBDeliver.ProtoReflect.Descriptor instead.

func (*SBDeliver) GetAborted 

func (x *SBDeliver) GetAborted() bool

func (*SBDeliver) GetData added in v0.2.2 

func (x *SBDeliver) GetData() []byte

func (*SBDeliver) GetInstanceId added in v0.2.2 

func (x *SBDeliver) GetInstanceId() string

func (*SBDeliver) GetLeader added in v0.2.0 

func (x *SBDeliver) GetLeader() string

func (*SBDeliver) GetSn 

func (x *SBDeliver) GetSn() uint64

func (*SBDeliver) ProtoMessage 

func (*SBDeliver) ProtoMessage()

func (*SBDeliver) ProtoReflect 

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

func (*SBDeliver) Reset 

func (x *SBDeliver) Reset()

func (*SBDeliver) String 

func (x *SBDeliver) 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.