Documentation ¶
Index ¶
- Variables
- type DeliverCert
- func (*DeliverCert) Descriptor() ([]byte, []int)deprecated
- func (x *DeliverCert) GetCert() *availabilitypb.Cert
- func (x *DeliverCert) GetEmpty() bool
- func (x *DeliverCert) GetSn() uint64
- func (*DeliverCert) ProtoMessage()
- func (x *DeliverCert) ProtoReflect() protoreflect.Message
- func (x *DeliverCert) Reset()
- func (x *DeliverCert) String() string
- type Event
- func (*Event) Descriptor() ([]byte, []int)deprecated
- func (x *Event) GetDeliverCert() *DeliverCert
- func (x *Event) GetNewConfig() *NewConfig
- func (x *Event) GetPushCheckpoint() *PushCheckpoint
- func (x *Event) GetSbDeliver() *SBDeliver
- 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_DeliverCert
- type Event_NewConfig
- type Event_PushCheckpoint
- type Event_SbDeliver
- type Event_Type
- type Event_TypeWrapper
- type ISSMessage
- func (*ISSMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ISSMessage) GetStableCheckpoint() *checkpointpb.StableCheckpoint
- func (m *ISSMessage) GetType() isISSMessage_Type
- func (*ISSMessage) ProtoMessage()
- func (x *ISSMessage) ProtoReflect() protoreflect.Message
- func (*ISSMessage) ReflectTypeOptions() []reflect.Type
- func (x *ISSMessage) Reset()
- func (x *ISSMessage) String() string
- type ISSMessage_StableCheckpoint
- type ISSMessage_Type
- type ISSMessage_TypeWrapper
- type NewConfig
- func (*NewConfig) Descriptor() ([]byte, []int)deprecated
- func (x *NewConfig) GetEpochNr() uint64
- func (x *NewConfig) GetMembership() *trantorpb.Membership
- func (*NewConfig) ProtoMessage()
- func (x *NewConfig) ProtoReflect() protoreflect.Message
- func (x *NewConfig) Reset()
- func (x *NewConfig) String() string
- type PushCheckpoint
- type SBDeliver
- func (*SBDeliver) Descriptor() ([]byte, []int)deprecated
- func (x *SBDeliver) GetAborted() bool
- func (x *SBDeliver) GetData() []byte
- func (x *SBDeliver) GetInstanceId() string
- func (x *SBDeliver) GetLeader() string
- func (x *SBDeliver) GetSn() uint64
- func (*SBDeliver) ProtoMessage()
- func (x *SBDeliver) ProtoReflect() protoreflect.Message
- func (x *SBDeliver) Reset()
- func (x *SBDeliver) String() string
Constants ¶
This section is empty.
Variables ¶
View Source
var File_isspb_isspb_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type DeliverCert ¶
type DeliverCert struct { Sn uint64 `protobuf:"varint,1,opt,name=sn,proto3" json:"sn,omitempty"` Cert *availabilitypb.Cert `protobuf:"bytes,2,opt,name=cert,proto3" json:"cert,omitempty"` Empty bool `protobuf:"varint,3,opt,name=empty,proto3" json:"empty,omitempty"` // contains filtered or unexported fields }
func (*DeliverCert) Descriptor
deprecated
func (*DeliverCert) Descriptor() ([]byte, []int)
Deprecated: Use DeliverCert.ProtoReflect.Descriptor instead.
func (*DeliverCert) GetCert ¶
func (x *DeliverCert) GetCert() *availabilitypb.Cert
func (*DeliverCert) GetEmpty ¶
func (x *DeliverCert) GetEmpty() bool
func (*DeliverCert) GetSn ¶
func (x *DeliverCert) GetSn() uint64
func (*DeliverCert) ProtoMessage ¶
func (*DeliverCert) ProtoMessage()
func (*DeliverCert) ProtoReflect ¶
func (x *DeliverCert) ProtoReflect() protoreflect.Message
func (*DeliverCert) Reset ¶
func (x *DeliverCert) Reset()
func (*DeliverCert) String ¶
func (x *DeliverCert) String() string
type Event ¶
type Event struct { // Types that are assignable to Type: // *Event_PushCheckpoint // *Event_SbDeliver // *Event_DeliverCert // *Event_NewConfig Type isEvent_Type `protobuf_oneof:"type"` // contains filtered or unexported fields }
func (*Event) Descriptor
deprecated
func (*Event) GetDeliverCert ¶
func (x *Event) GetDeliverCert() *DeliverCert
func (*Event) GetNewConfig ¶
func (*Event) GetPushCheckpoint ¶
func (x *Event) GetPushCheckpoint() *PushCheckpoint
func (*Event) GetSbDeliver ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) ProtoReflect ¶
func (x *Event) ProtoReflect() protoreflect.Message
func (*Event) ReflectTypeOptions ¶
type Event_DeliverCert ¶
type Event_DeliverCert struct {
DeliverCert *DeliverCert `protobuf:"bytes,3,opt,name=deliver_cert,json=deliverCert,proto3,oneof"`
}
func (*Event_DeliverCert) Unwrap ¶
func (w *Event_DeliverCert) Unwrap() *DeliverCert
type Event_NewConfig ¶
type Event_NewConfig struct {
NewConfig *NewConfig `protobuf:"bytes,4,opt,name=new_config,json=newConfig,proto3,oneof"`
}
func (*Event_NewConfig) Unwrap ¶
func (w *Event_NewConfig) Unwrap() *NewConfig
type Event_PushCheckpoint ¶
type Event_PushCheckpoint struct {
PushCheckpoint *PushCheckpoint `protobuf:"bytes,1,opt,name=push_checkpoint,json=pushCheckpoint,proto3,oneof"`
}
func (*Event_PushCheckpoint) Unwrap ¶
func (w *Event_PushCheckpoint) Unwrap() *PushCheckpoint
type Event_SbDeliver ¶
type Event_SbDeliver struct {
SbDeliver *SBDeliver `protobuf:"bytes,2,opt,name=sb_deliver,json=sbDeliver,proto3,oneof"`
}
func (*Event_SbDeliver) Unwrap ¶
func (w *Event_SbDeliver) Unwrap() *SBDeliver
type Event_Type ¶
type Event_Type = isEvent_Type
type Event_TypeWrapper ¶
type Event_TypeWrapper[T any] interface { Event_Type Unwrap() *T }
type ISSMessage ¶
type ISSMessage struct { // Types that are assignable to Type: // *ISSMessage_StableCheckpoint 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) 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) ReflectTypeOptions ¶
func (*ISSMessage) ReflectTypeOptions() []reflect.Type
func (*ISSMessage) Reset ¶
func (x *ISSMessage) Reset()
func (*ISSMessage) String ¶
func (x *ISSMessage) String() string
type ISSMessage_StableCheckpoint ¶
type ISSMessage_StableCheckpoint struct {
StableCheckpoint *checkpointpb.StableCheckpoint `protobuf:"bytes,3,opt,name=stable_checkpoint,json=stableCheckpoint,proto3,oneof"`
}
func (*ISSMessage_StableCheckpoint) Unwrap ¶
func (w *ISSMessage_StableCheckpoint) Unwrap() *checkpointpb.StableCheckpoint
type ISSMessage_Type ¶
type ISSMessage_Type = isISSMessage_Type
type ISSMessage_TypeWrapper ¶
type ISSMessage_TypeWrapper[T any] interface { ISSMessage_Type Unwrap() *T }
type NewConfig ¶
type NewConfig struct { EpochNr uint64 `protobuf:"varint,1,opt,name=epoch_nr,json=epochNr,proto3" json:"epoch_nr,omitempty"` Membership *trantorpb.Membership `protobuf:"bytes,2,opt,name=membership,proto3" json:"membership,omitempty"` // contains filtered or unexported fields }
func (*NewConfig) Descriptor
deprecated
func (*NewConfig) GetEpochNr ¶
func (*NewConfig) GetMembership ¶
func (x *NewConfig) GetMembership() *trantorpb.Membership
func (*NewConfig) ProtoMessage ¶
func (*NewConfig) ProtoMessage()
func (*NewConfig) ProtoReflect ¶
func (x *NewConfig) ProtoReflect() protoreflect.Message
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 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) GetAborted ¶
func (*SBDeliver) GetInstanceId ¶
func (*SBDeliver) ProtoMessage ¶
func (*SBDeliver) ProtoMessage()
func (*SBDeliver) ProtoReflect ¶
func (x *SBDeliver) ProtoReflect() protoreflect.Message
Click to show internal directories.
Click to hide internal directories.