 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Variables
- type ISSEvent
- func (*ISSEvent) Descriptor() ([]byte, []int)deprecated
- func (x *ISSEvent) GetPersistCheckpoint() *PersistCheckpoint
- func (x *ISSEvent) GetPersistStableCheckpoint() *PersistStableCheckpoint
- func (x *ISSEvent) GetPushCheckpoint() *PushCheckpoint
- func (x *ISSEvent) GetSbDeliver() *SBDeliver
- func (m *ISSEvent) GetType() isISSEvent_Type
- func (*ISSEvent) ProtoMessage()
- func (x *ISSEvent) ProtoReflect() protoreflect.Message
- func (x *ISSEvent) Reset()
- func (x *ISSEvent) String() string
 
- type ISSEvent_PersistCheckpoint
- type ISSEvent_PersistStableCheckpoint
- type ISSEvent_PushCheckpoint
- type ISSEvent_SbDeliver
- type ISSHashOrigin
- func (*ISSHashOrigin) Descriptor() ([]byte, []int)deprecated
- func (x *ISSHashOrigin) GetLogEntrySn() uint64
- func (x *ISSHashOrigin) GetRequests() *RequestHashOrigin
- func (x *ISSHashOrigin) GetStateSnapshotEpoch() uint64
- func (m *ISSHashOrigin) GetType() isISSHashOrigin_Type
- func (*ISSHashOrigin) ProtoMessage()
- func (x *ISSHashOrigin) ProtoReflect() protoreflect.Message
- func (x *ISSHashOrigin) Reset()
- func (x *ISSHashOrigin) String() string
 
- type ISSHashOrigin_LogEntrySn
- type ISSHashOrigin_Requests
- type ISSHashOrigin_StateSnapshotEpoch
- type ISSMessage
- func (*ISSMessage) Descriptor() ([]byte, []int)deprecated
- func (x *ISSMessage) GetRetransmitRequests() *RetransmitRequests
- func (x *ISSMessage) GetStableCheckpoint() *checkpointpb.StableCheckpoint
- func (m *ISSMessage) GetType() isISSMessage_Type
- func (*ISSMessage) ProtoMessage()
- func (x *ISSMessage) ProtoReflect() protoreflect.Message
- func (x *ISSMessage) Reset()
- func (x *ISSMessage) String() string
 
- type ISSMessage_RetransmitRequests
- type ISSMessage_StableCheckpoint
- type ISSSigVerOrigin
- func (*ISSSigVerOrigin) Descriptor() ([]byte, []int)deprecated
- func (x *ISSSigVerOrigin) GetCheckpointEpoch() uint64
- func (x *ISSSigVerOrigin) GetStableCheckpoint() *checkpointpb.StableCheckpoint
- func (m *ISSSigVerOrigin) GetType() isISSSigVerOrigin_Type
- func (*ISSSigVerOrigin) ProtoMessage()
- func (x *ISSSigVerOrigin) ProtoReflect() protoreflect.Message
- func (x *ISSSigVerOrigin) Reset()
- func (x *ISSSigVerOrigin) String() string
 
- type ISSSigVerOrigin_CheckpointEpoch
- type ISSSigVerOrigin_StableCheckpoint
- type PersistCheckpoint
- func (*PersistCheckpoint) Descriptor() ([]byte, []int)deprecated
- func (x *PersistCheckpoint) GetSignature() []byte
- func (x *PersistCheckpoint) GetSn() uint64
- func (x *PersistCheckpoint) GetStateSnapshot() *commonpb.StateSnapshot
- func (x *PersistCheckpoint) GetStateSnapshotHash() []byte
- func (*PersistCheckpoint) ProtoMessage()
- func (x *PersistCheckpoint) ProtoReflect() protoreflect.Message
- func (x *PersistCheckpoint) Reset()
- func (x *PersistCheckpoint) String() string
 
- type PersistStableCheckpoint
- func (*PersistStableCheckpoint) Descriptor() ([]byte, []int)deprecated
- func (x *PersistStableCheckpoint) GetStableCheckpoint() *checkpointpb.StableCheckpoint
- func (*PersistStableCheckpoint) ProtoMessage()
- func (x *PersistStableCheckpoint) ProtoReflect() protoreflect.Message
- func (x *PersistStableCheckpoint) Reset()
- func (x *PersistStableCheckpoint) String() string
 
- type PushCheckpoint
- type RequestHashOrigin
- func (*RequestHashOrigin) Descriptor() ([]byte, []int)deprecated
- func (x *RequestHashOrigin) GetRequests() []*requestpb.Request
- func (*RequestHashOrigin) ProtoMessage()
- func (x *RequestHashOrigin) ProtoReflect() protoreflect.Message
- func (x *RequestHashOrigin) Reset()
- func (x *RequestHashOrigin) String() string
 
- type RetransmitRequests
- func (*RetransmitRequests) Descriptor() ([]byte, []int)deprecated
- func (x *RetransmitRequests) GetRequests() []*requestpb.Request
- func (*RetransmitRequests) ProtoMessage()
- func (x *RetransmitRequests) ProtoReflect() protoreflect.Message
- func (x *RetransmitRequests) Reset()
- func (x *RetransmitRequests) String() string
 
- type SBDeliver
- func (*SBDeliver) Descriptor() ([]byte, []int)deprecated
- func (x *SBDeliver) GetAborted() bool
- func (x *SBDeliver) GetCertData() []byte
- 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 ¶
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) 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 (*ISSEvent) ProtoMessage ¶
func (*ISSEvent) ProtoMessage()
func (*ISSEvent) ProtoReflect ¶
func (x *ISSEvent) ProtoReflect() protoreflect.Message
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"`
	CertData []byte `protobuf:"bytes,2,opt,name=cert_data,json=certData,proto3" json:"cert_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"`
	// contains filtered or unexported fields
}
    
        
          
            func (*SBDeliver) Descriptor
            deprecated
            
          
  
    
  
      
      
    func (*SBDeliver) GetAborted ¶
func (*SBDeliver) GetCertData ¶
func (*SBDeliver) ProtoMessage ¶
func (*SBDeliver) ProtoMessage()
func (*SBDeliver) ProtoReflect ¶
func (x *SBDeliver) ProtoReflect() protoreflect.Message