isspb

package
v0.3.5 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2023 License: Apache-2.0 Imports: 8 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_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) 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) ReflectTypeOptions added in v0.3.5 

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

func (*ISSEvent) Reset 

func (x *ISSEvent) Reset()

func (*ISSEvent) String 

func (x *ISSEvent) String() string

type ISSEvent_PushCheckpoint 

type ISSEvent_PushCheckpoint struct {
	//    PersistCheckpoint       persist_checkpoint        = 1;
	//    PersistStableCheckpoint persist_stable_checkpoint = 3;
	PushCheckpoint *PushCheckpoint `protobuf:"bytes,5,opt,name=push_checkpoint,json=pushCheckpoint,proto3,oneof"`
}

func (*ISSEvent_PushCheckpoint) Unwrap added in v0.3.5 

func (w *ISSEvent_PushCheckpoint) Unwrap() *PushCheckpoint

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"`
}

func (*ISSEvent_SbDeliver) Unwrap added in v0.3.5 

func (w *ISSEvent_SbDeliver) Unwrap() *SBDeliver

type ISSEvent_Type added in v0.3.5 

type ISSEvent_Type = isISSEvent_Type

type ISSEvent_TypeWrapper added in v0.3.5 

type ISSEvent_TypeWrapper[T any] interface {
	ISSEvent_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 added in v0.3.5 

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"` //    RetransmitRequests              retransmit_requests = 4; // TODO Remove? not being used
}

func (*ISSMessage_StableCheckpoint) Unwrap added in v0.3.5 

func (w *ISSMessage_StableCheckpoint) Unwrap() *checkpointpb.StableCheckpoint

type ISSMessage_Type added in v0.3.5 

type ISSMessage_Type = isISSMessage_Type

type ISSMessage_TypeWrapper added in v0.3.5 

type ISSMessage_TypeWrapper[T any] interface {
	ISSMessage_Type
	Unwrap() *T
}

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 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

Directories

Path Synopsis

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.