streamingpb

package
v0.0.2-0...-8a4ac8c Latest Latest
Warning

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

 Go to latest Published: Feb 7, 2025 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	StreamingCoordBroadcastService_Broadcast_FullMethodName = "/milvus.proto.streaming.StreamingCoordBroadcastService/Broadcast"
	StreamingCoordBroadcastService_Ack_FullMethodName       = "/milvus.proto.streaming.StreamingCoordBroadcastService/Ack"
	StreamingCoordBroadcastService_Watch_FullMethodName     = "/milvus.proto.streaming.StreamingCoordBroadcastService/Watch"
)
View Source 
const (
	StreamingNodeHandlerService_Produce_FullMethodName = "/milvus.proto.streaming.StreamingNodeHandlerService/Produce"
	StreamingNodeHandlerService_Consume_FullMethodName = "/milvus.proto.streaming.StreamingNodeHandlerService/Consume"
)
View Source 
const (
	StreamingNodeManagerService_Assign_FullMethodName        = "/milvus.proto.streaming.StreamingNodeManagerService/Assign"
	StreamingNodeManagerService_Remove_FullMethodName        = "/milvus.proto.streaming.StreamingNodeManagerService/Remove"
	StreamingNodeManagerService_CollectStatus_FullMethodName = "/milvus.proto.streaming.StreamingNodeManagerService/CollectStatus"
)
View Source 
const (
	ServiceMethodPrefix = "/milvus.proto.streaming"
)
View Source 
const (
	StreamingCoordAssignmentService_AssignmentDiscover_FullMethodName = "/milvus.proto.streaming.StreamingCoordAssignmentService/AssignmentDiscover"
)
View Source 
const (
	StreamingNodeStateService_GetComponentStates_FullMethodName = "/milvus.proto.streaming.StreamingNodeStateService/GetComponentStates"
)

Variables

View Source 
var (
	PChannelMetaState_name = map[int32]string{
		0: "PCHANNEL_META_STATE_UNKNOWN",
		1: "PCHANNEL_META_STATE_UNINITIALIZED",
		2: "PCHANNEL_META_STATE_ASSIGNING",
		3: "PCHANNEL_META_STATE_ASSIGNED",
		4: "PCHANNEL_META_STATE_UNAVAILABLE",
	}
	PChannelMetaState_value = map[string]int32{
		"PCHANNEL_META_STATE_UNKNOWN":       0,
		"PCHANNEL_META_STATE_UNINITIALIZED": 1,
		"PCHANNEL_META_STATE_ASSIGNING":     2,
		"PCHANNEL_META_STATE_ASSIGNED":      3,
		"PCHANNEL_META_STATE_UNAVAILABLE":   4,
	}
)

Enum value maps for PChannelMetaState.

View Source 
var (
	BroadcastTaskState_name = map[int32]string{
		0: "BROADCAST_TASK_STATE_UNKNOWN",
		1: "BROADCAST_TASK_STATE_PENDING",
		2: "BROADCAST_TASK_STATE_DONE",
		3: "BROADCAST_TASK_STATE_WAIT_ACK",
	}
	BroadcastTaskState_value = map[string]int32{
		"BROADCAST_TASK_STATE_UNKNOWN":  0,
		"BROADCAST_TASK_STATE_PENDING":  1,
		"BROADCAST_TASK_STATE_DONE":     2,
		"BROADCAST_TASK_STATE_WAIT_ACK": 3,
	}
)

Enum value maps for BroadcastTaskState.

View Source 
var (
	StreamingCode_name = map[int32]string{
		0:   "STREAMING_CODE_OK",
		1:   "STREAMING_CODE_CHANNEL_NOT_EXIST",
		2:   "STREAMING_CODE_CHANNEL_FENCED",
		3:   "STREAMING_CODE_ON_SHUTDOWN",
		4:   "STREAMING_CODE_INVALID_REQUEST_SEQ",
		5:   "STREAMING_CODE_UNMATCHED_CHANNEL_TERM",
		6:   "STREAMING_CODE_IGNORED_OPERATION",
		7:   "STREAMING_CODE_INNER",
		8:   "STREAMING_CODE_INVAILD_ARGUMENT",
		9:   "STREAMING_CODE_TRANSACTION_EXPIRED",
		10:  "STREAMING_CODE_INVALID_TRANSACTION_STATE",
		11:  "STREAMING_CODE_UNRECOVERABLE",
		12:  "STREAMING_CODE_RESOURCE_ACQUIRED",
		999: "STREAMING_CODE_UNKNOWN",
	}
	StreamingCode_value = map[string]int32{
		"STREAMING_CODE_OK":                        0,
		"STREAMING_CODE_CHANNEL_NOT_EXIST":         1,
		"STREAMING_CODE_CHANNEL_FENCED":            2,
		"STREAMING_CODE_ON_SHUTDOWN":               3,
		"STREAMING_CODE_INVALID_REQUEST_SEQ":       4,
		"STREAMING_CODE_UNMATCHED_CHANNEL_TERM":    5,
		"STREAMING_CODE_IGNORED_OPERATION":         6,
		"STREAMING_CODE_INNER":                     7,
		"STREAMING_CODE_INVAILD_ARGUMENT":          8,
		"STREAMING_CODE_TRANSACTION_EXPIRED":       9,
		"STREAMING_CODE_INVALID_TRANSACTION_STATE": 10,
		"STREAMING_CODE_UNRECOVERABLE":             11,
		"STREAMING_CODE_RESOURCE_ACQUIRED":         12,
		"STREAMING_CODE_UNKNOWN":                   999,
	}
)

Enum value maps for StreamingCode.

View Source 
var (
	SegmentAssignmentState_name = map[int32]string{
		0: "SEGMENT_ASSIGNMENT_STATE_UNKNOWN",
		1: "SEGMENT_ASSIGNMENT_STATE_PENDING",
		2: "SEGMENT_ASSIGNMENT_STATE_GROWING",
		3: "SEGMENT_ASSIGNMENT_STATE_SEALED",
		4: "SEGMENT_ASSIGNMENT_STATE_FLUSHED",
	}
	SegmentAssignmentState_value = map[string]int32{
		"SEGMENT_ASSIGNMENT_STATE_UNKNOWN": 0,
		"SEGMENT_ASSIGNMENT_STATE_PENDING": 1,
		"SEGMENT_ASSIGNMENT_STATE_GROWING": 2,
		"SEGMENT_ASSIGNMENT_STATE_SEALED":  3,
		"SEGMENT_ASSIGNMENT_STATE_FLUSHED": 4,
	}
)

Enum value maps for SegmentAssignmentState.

View Source 
var File_streaming_proto protoreflect.FileDescriptor
View Source 
var StreamingCoordAssignmentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.streaming.StreamingCoordAssignmentService",
	HandlerType: (*StreamingCoordAssignmentServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "AssignmentDiscover",
			Handler:       _StreamingCoordAssignmentService_AssignmentDiscover_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "streaming.proto",
}

StreamingCoordAssignmentService_ServiceDesc is the grpc.ServiceDesc for StreamingCoordAssignmentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var StreamingCoordBroadcastService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.streaming.StreamingCoordBroadcastService",
	HandlerType: (*StreamingCoordBroadcastServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Broadcast",
			Handler:    _StreamingCoordBroadcastService_Broadcast_Handler,
		},
		{
			MethodName: "Ack",
			Handler:    _StreamingCoordBroadcastService_Ack_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Watch",
			Handler:       _StreamingCoordBroadcastService_Watch_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "streaming.proto",
}

StreamingCoordBroadcastService_ServiceDesc is the grpc.ServiceDesc for StreamingCoordBroadcastService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var StreamingNodeHandlerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.streaming.StreamingNodeHandlerService",
	HandlerType: (*StreamingNodeHandlerServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Produce",
			Handler:       _StreamingNodeHandlerService_Produce_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "Consume",
			Handler:       _StreamingNodeHandlerService_Consume_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "streaming.proto",
}

StreamingNodeHandlerService_ServiceDesc is the grpc.ServiceDesc for StreamingNodeHandlerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var StreamingNodeManagerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.streaming.StreamingNodeManagerService",
	HandlerType: (*StreamingNodeManagerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Assign",
			Handler:    _StreamingNodeManagerService_Assign_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _StreamingNodeManagerService_Remove_Handler,
		},
		{
			MethodName: "CollectStatus",
			Handler:    _StreamingNodeManagerService_CollectStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "streaming.proto",
}

StreamingNodeManagerService_ServiceDesc is the grpc.ServiceDesc for StreamingNodeManagerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var StreamingNodeStateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "milvus.proto.streaming.StreamingNodeStateService",
	HandlerType: (*StreamingNodeStateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetComponentStates",
			Handler:    _StreamingNodeStateService_GetComponentStates_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "streaming.proto",
}

StreamingNodeStateService_ServiceDesc is the grpc.ServiceDesc for StreamingNodeStateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterStreamingCoordAssignmentServiceServer 

func RegisterStreamingCoordAssignmentServiceServer(s grpc.ServiceRegistrar, srv StreamingCoordAssignmentServiceServer)

func RegisterStreamingCoordBroadcastServiceServer 

func RegisterStreamingCoordBroadcastServiceServer(s grpc.ServiceRegistrar, srv StreamingCoordBroadcastServiceServer)

func RegisterStreamingNodeHandlerServiceServer 

func RegisterStreamingNodeHandlerServiceServer(s grpc.ServiceRegistrar, srv StreamingNodeHandlerServiceServer)

func RegisterStreamingNodeManagerServiceServer 

func RegisterStreamingNodeManagerServiceServer(s grpc.ServiceRegistrar, srv StreamingNodeManagerServiceServer)

func RegisterStreamingNodeStateServiceServer 

func RegisterStreamingNodeStateServiceServer(s grpc.ServiceRegistrar, srv StreamingNodeStateServiceServer)

Types

type AssignmentDiscoverRequest 

type AssignmentDiscoverRequest struct {

	// Types that are assignable to Command:
	//
	//	*AssignmentDiscoverRequest_ReportError
	//	*AssignmentDiscoverRequest_Close
	Command isAssignmentDiscoverRequest_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

AssignmentDiscoverRequest is the request of Discovery

func (*AssignmentDiscoverRequest) Descriptor deprecated 

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

Deprecated: Use AssignmentDiscoverRequest.ProtoReflect.Descriptor instead.

func (*AssignmentDiscoverRequest) GetClose 

func (x *AssignmentDiscoverRequest) GetClose() *CloseAssignmentDiscoverRequest

func (*AssignmentDiscoverRequest) GetCommand 

func (m *AssignmentDiscoverRequest) GetCommand() isAssignmentDiscoverRequest_Command

func (*AssignmentDiscoverRequest) GetReportError 

func (x *AssignmentDiscoverRequest) GetReportError() *ReportAssignmentErrorRequest

func (*AssignmentDiscoverRequest) ProtoMessage 

func (*AssignmentDiscoverRequest) ProtoMessage()

func (*AssignmentDiscoverRequest) ProtoReflect 

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

func (*AssignmentDiscoverRequest) Reset 

func (x *AssignmentDiscoverRequest) Reset()

func (*AssignmentDiscoverRequest) String 

func (x *AssignmentDiscoverRequest) String() string

type AssignmentDiscoverRequest_Close 

type AssignmentDiscoverRequest_Close struct {
	Close *CloseAssignmentDiscoverRequest `protobuf:"bytes,2,opt,name=close,proto3,oneof"` // close the stream.
}

type AssignmentDiscoverRequest_ReportError 

type AssignmentDiscoverRequest_ReportError struct {
	ReportError *ReportAssignmentErrorRequest `protobuf:"bytes,1,opt,name=report_error,json=reportError,proto3,oneof"` // report streaming error, trigger reassign right now.
}

type AssignmentDiscoverResponse 

type AssignmentDiscoverResponse struct {

	// Types that are assignable to Response:
	//
	//	*AssignmentDiscoverResponse_FullAssignment
	//	*AssignmentDiscoverResponse_Close
	Response isAssignmentDiscoverResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

AssignmentDiscoverResponse is the response of Discovery

func (*AssignmentDiscoverResponse) Descriptor deprecated 

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

Deprecated: Use AssignmentDiscoverResponse.ProtoReflect.Descriptor instead.

func (*AssignmentDiscoverResponse) GetClose 

func (x *AssignmentDiscoverResponse) GetClose() *CloseAssignmentDiscoverResponse

func (*AssignmentDiscoverResponse) GetFullAssignment 

func (x *AssignmentDiscoverResponse) GetFullAssignment() *FullStreamingNodeAssignmentWithVersion

func (*AssignmentDiscoverResponse) GetResponse 

func (m *AssignmentDiscoverResponse) GetResponse() isAssignmentDiscoverResponse_Response

func (*AssignmentDiscoverResponse) ProtoMessage 

func (*AssignmentDiscoverResponse) ProtoMessage()

func (*AssignmentDiscoverResponse) ProtoReflect 

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

func (*AssignmentDiscoverResponse) Reset 

func (x *AssignmentDiscoverResponse) Reset()

func (*AssignmentDiscoverResponse) String 

func (x *AssignmentDiscoverResponse) String() string

type AssignmentDiscoverResponse_Close 

type AssignmentDiscoverResponse_Close struct {
	// TODO: may be support partial assignment info in future.
	Close *CloseAssignmentDiscoverResponse `protobuf:"bytes,2,opt,name=close,proto3,oneof"`
}

type AssignmentDiscoverResponse_FullAssignment 

type AssignmentDiscoverResponse_FullAssignment struct {
	FullAssignment *FullStreamingNodeAssignmentWithVersion `protobuf:"bytes,1,opt,name=full_assignment,json=fullAssignment,proto3,oneof"` // all assignment info.
}

type BroadcastAckRequest 

type BroadcastAckRequest struct {
	BroadcastId uint64 `protobuf:"varint,1,opt,name=broadcast_id,json=broadcastId,proto3" json:"broadcast_id,omitempty"` // broadcast id.
	Vchannel    string `protobuf:"bytes,2,opt,name=vchannel,proto3" json:"vchannel,omitempty"`                           // the vchannel that acked the message.
	// contains filtered or unexported fields
}

func (*BroadcastAckRequest) Descriptor deprecated 

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

Deprecated: Use BroadcastAckRequest.ProtoReflect.Descriptor instead.

func (*BroadcastAckRequest) GetBroadcastId 

func (x *BroadcastAckRequest) GetBroadcastId() uint64

func (*BroadcastAckRequest) GetVchannel 

func (x *BroadcastAckRequest) GetVchannel() string

func (*BroadcastAckRequest) ProtoMessage 

func (*BroadcastAckRequest) ProtoMessage()

func (*BroadcastAckRequest) ProtoReflect 

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

func (*BroadcastAckRequest) Reset 

func (x *BroadcastAckRequest) Reset()

func (*BroadcastAckRequest) String 

func (x *BroadcastAckRequest) String() string

type BroadcastAckResponse 

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

func (*BroadcastAckResponse) Descriptor deprecated 

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

Deprecated: Use BroadcastAckResponse.ProtoReflect.Descriptor instead.

func (*BroadcastAckResponse) ProtoMessage 

func (*BroadcastAckResponse) ProtoMessage()

func (*BroadcastAckResponse) ProtoReflect 

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

func (*BroadcastAckResponse) Reset 

func (x *BroadcastAckResponse) Reset()

func (*BroadcastAckResponse) String 

func (x *BroadcastAckResponse) String() string

type BroadcastCreateEventWatchRequest 

type BroadcastCreateEventWatchRequest struct {
	Event *messagespb.BroadcastEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastCreateEventWatchRequest) Descriptor deprecated 

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

Deprecated: Use BroadcastCreateEventWatchRequest.ProtoReflect.Descriptor instead.

func (*BroadcastCreateEventWatchRequest) GetEvent 

func (x *BroadcastCreateEventWatchRequest) GetEvent() *messagespb.BroadcastEvent

func (*BroadcastCreateEventWatchRequest) ProtoMessage 

func (*BroadcastCreateEventWatchRequest) ProtoMessage()

func (*BroadcastCreateEventWatchRequest) ProtoReflect 

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

func (*BroadcastCreateEventWatchRequest) Reset 

func (x *BroadcastCreateEventWatchRequest) Reset()

func (*BroadcastCreateEventWatchRequest) String 

func (x *BroadcastCreateEventWatchRequest) String() string

type BroadcastEventWatchResponse 

type BroadcastEventWatchResponse struct {
	Event *messagespb.BroadcastEvent `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

func (*BroadcastEventWatchResponse) Descriptor deprecated 

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

Deprecated: Use BroadcastEventWatchResponse.ProtoReflect.Descriptor instead.

func (*BroadcastEventWatchResponse) GetEvent 

func (x *BroadcastEventWatchResponse) GetEvent() *messagespb.BroadcastEvent

func (*BroadcastEventWatchResponse) ProtoMessage 

func (*BroadcastEventWatchResponse) ProtoMessage()

func (*BroadcastEventWatchResponse) ProtoReflect 

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

func (*BroadcastEventWatchResponse) Reset 

func (x *BroadcastEventWatchResponse) Reset()

func (*BroadcastEventWatchResponse) String 

func (x *BroadcastEventWatchResponse) String() string

type BroadcastRequest 

type BroadcastRequest struct {
	Message *messagespb.Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // message to be broadcast.
	// contains filtered or unexported fields
}

BroadcastRequest is the request of the Broadcast RPC.

func (*BroadcastRequest) Descriptor deprecated 

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

Deprecated: Use BroadcastRequest.ProtoReflect.Descriptor instead.

func (*BroadcastRequest) GetMessage 

func (x *BroadcastRequest) GetMessage() *messagespb.Message

func (*BroadcastRequest) ProtoMessage 

func (*BroadcastRequest) ProtoMessage()

func (*BroadcastRequest) ProtoReflect 

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

func (*BroadcastRequest) Reset 

func (x *BroadcastRequest) Reset()

func (*BroadcastRequest) String 

func (x *BroadcastRequest) String() string

type BroadcastResponse 

type BroadcastResponse struct {
	Results     map[string]*ProduceMessageResponseResult `` /* 155-byte string literal not displayed */
	BroadcastId uint64                                   `protobuf:"varint,2,opt,name=broadcast_id,json=broadcastId,proto3" json:"broadcast_id,omitempty"`
	// contains filtered or unexported fields
}

BroadcastResponse is the response of the Broadcast RPC.

func (*BroadcastResponse) Descriptor deprecated 

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

Deprecated: Use BroadcastResponse.ProtoReflect.Descriptor instead.

func (*BroadcastResponse) GetBroadcastId 

func (x *BroadcastResponse) GetBroadcastId() uint64

func (*BroadcastResponse) GetResults 

func (x *BroadcastResponse) GetResults() map[string]*ProduceMessageResponseResult

func (*BroadcastResponse) ProtoMessage 

func (*BroadcastResponse) ProtoMessage()

func (*BroadcastResponse) ProtoReflect 

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

func (*BroadcastResponse) Reset 

func (x *BroadcastResponse) Reset()

func (*BroadcastResponse) String 

func (x *BroadcastResponse) String() string

type BroadcastTask 

type BroadcastTask struct {
	Message             *messagespb.Message `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`                                                      // message to be broadcast.
	State               BroadcastTaskState  `protobuf:"varint,2,opt,name=state,proto3,enum=milvus.proto.streaming.BroadcastTaskState" json:"state,omitempty"`          // state of the task.
	AckedVchannelBitmap []byte              `protobuf:"bytes,3,opt,name=acked_vchannel_bitmap,json=ackedVchannelBitmap,proto3" json:"acked_vchannel_bitmap,omitempty"` // given vchannels that have been acked, the size of bitmap is same with message.BroadcastHeader().VChannels.
	// contains filtered or unexported fields
}

BroadcastTask is the task to broadcast the messake.

func (*BroadcastTask) Descriptor deprecated 

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

Deprecated: Use BroadcastTask.ProtoReflect.Descriptor instead.

func (*BroadcastTask) GetAckedVchannelBitmap 

func (x *BroadcastTask) GetAckedVchannelBitmap() []byte

func (*BroadcastTask) GetMessage 

func (x *BroadcastTask) GetMessage() *messagespb.Message

func (*BroadcastTask) GetState 

func (x *BroadcastTask) GetState() BroadcastTaskState

func (*BroadcastTask) ProtoMessage 

func (*BroadcastTask) ProtoMessage()

func (*BroadcastTask) ProtoReflect 

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

func (*BroadcastTask) Reset 

func (x *BroadcastTask) Reset()

func (*BroadcastTask) String 

func (x *BroadcastTask) String() string

type BroadcastTaskState 

type BroadcastTaskState int32

BroadcastTaskState is the state of the broadcast task. 

const (
	BroadcastTaskState_BROADCAST_TASK_STATE_UNKNOWN  BroadcastTaskState = 0 // should never used.
	BroadcastTaskState_BROADCAST_TASK_STATE_PENDING  BroadcastTaskState = 1 // task is pending.
	BroadcastTaskState_BROADCAST_TASK_STATE_DONE     BroadcastTaskState = 2 // task has been broadcasted and acknowledged, the resource lock is released, and the persisted task can be cleared.
	BroadcastTaskState_BROADCAST_TASK_STATE_WAIT_ACK BroadcastTaskState = 3 // task has been broadcasted, waiting for ack, the resource lock is still acquired by some vchannels.
)

func (BroadcastTaskState) Descriptor 

func (BroadcastTaskState) Descriptor() protoreflect.EnumDescriptor

func (BroadcastTaskState) Enum 

func (x BroadcastTaskState) Enum() *BroadcastTaskState

func (BroadcastTaskState) EnumDescriptor deprecated 

func (BroadcastTaskState) EnumDescriptor() ([]byte, []int)

Deprecated: Use BroadcastTaskState.Descriptor instead.

func (BroadcastTaskState) Number 

func (x BroadcastTaskState) Number() protoreflect.EnumNumber

func (BroadcastTaskState) String 

func (x BroadcastTaskState) String() string

func (BroadcastTaskState) Type 

func (BroadcastTaskState) Type() protoreflect.EnumType

type BroadcastWatchRequest 

type BroadcastWatchRequest struct {

	// Types that are assignable to Command:
	//
	//	*BroadcastWatchRequest_CreateEventWatch
	//	*BroadcastWatchRequest_Close
	Command isBroadcastWatchRequest_Command `protobuf_oneof:"command"`
	// contains filtered or unexported fields
}

func (*BroadcastWatchRequest) Descriptor deprecated 

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

Deprecated: Use BroadcastWatchRequest.ProtoReflect.Descriptor instead.

func (*BroadcastWatchRequest) GetClose 

func (x *BroadcastWatchRequest) GetClose() *CloseBroadcastWatchRequest

func (*BroadcastWatchRequest) GetCommand 

func (m *BroadcastWatchRequest) GetCommand() isBroadcastWatchRequest_Command

func (*BroadcastWatchRequest) GetCreateEventWatch 

func (x *BroadcastWatchRequest) GetCreateEventWatch() *BroadcastCreateEventWatchRequest

func (*BroadcastWatchRequest) ProtoMessage 

func (*BroadcastWatchRequest) ProtoMessage()

func (*BroadcastWatchRequest) ProtoReflect 

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

func (*BroadcastWatchRequest) Reset 

func (x *BroadcastWatchRequest) Reset()

func (*BroadcastWatchRequest) String 

func (x *BroadcastWatchRequest) String() string

type BroadcastWatchRequest_Close 

type BroadcastWatchRequest_Close struct {
	Close *CloseBroadcastWatchRequest `protobuf:"bytes,2,opt,name=close,proto3,oneof"`
}

type BroadcastWatchRequest_CreateEventWatch 

type BroadcastWatchRequest_CreateEventWatch struct {
	CreateEventWatch *BroadcastCreateEventWatchRequest `protobuf:"bytes,1,opt,name=create_event_watch,json=createEventWatch,proto3,oneof"`
}

type BroadcastWatchResponse 

type BroadcastWatchResponse struct {

	// Types that are assignable to Response:
	//
	//	*BroadcastWatchResponse_EventDone
	//	*BroadcastWatchResponse_Close
	Response isBroadcastWatchResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

func (*BroadcastWatchResponse) Descriptor deprecated 

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

Deprecated: Use BroadcastWatchResponse.ProtoReflect.Descriptor instead.

func (*BroadcastWatchResponse) GetClose 

func (x *BroadcastWatchResponse) GetClose() *CloseBroadcastWatchResponse

func (*BroadcastWatchResponse) GetEventDone 

func (x *BroadcastWatchResponse) GetEventDone() *BroadcastEventWatchResponse

func (*BroadcastWatchResponse) GetResponse 

func (m *BroadcastWatchResponse) GetResponse() isBroadcastWatchResponse_Response

func (*BroadcastWatchResponse) ProtoMessage 

func (*BroadcastWatchResponse) ProtoMessage()

func (*BroadcastWatchResponse) ProtoReflect 

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

func (*BroadcastWatchResponse) Reset 

func (x *BroadcastWatchResponse) Reset()

func (*BroadcastWatchResponse) String 

func (x *BroadcastWatchResponse) String() string

type BroadcastWatchResponse_Close 

type BroadcastWatchResponse_Close struct {
	Close *CloseBroadcastWatchResponse `protobuf:"bytes,2,opt,name=close,proto3,oneof"`
}

type BroadcastWatchResponse_EventDone 

type BroadcastWatchResponse_EventDone struct {
	EventDone *BroadcastEventWatchResponse `protobuf:"bytes,1,opt,name=event_done,json=eventDone,proto3,oneof"`
}

type CloseAssignmentDiscoverRequest 

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

CloseAssignmentDiscoverRequest is the request to close the stream.

func (*CloseAssignmentDiscoverRequest) Descriptor deprecated 

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

Deprecated: Use CloseAssignmentDiscoverRequest.ProtoReflect.Descriptor instead.

func (*CloseAssignmentDiscoverRequest) ProtoMessage 

func (*CloseAssignmentDiscoverRequest) ProtoMessage()

func (*CloseAssignmentDiscoverRequest) ProtoReflect 

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

func (*CloseAssignmentDiscoverRequest) Reset 

func (x *CloseAssignmentDiscoverRequest) Reset()

func (*CloseAssignmentDiscoverRequest) String 

func (x *CloseAssignmentDiscoverRequest) String() string

type CloseAssignmentDiscoverResponse 

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

func (*CloseAssignmentDiscoverResponse) Descriptor deprecated 

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

Deprecated: Use CloseAssignmentDiscoverResponse.ProtoReflect.Descriptor instead.

func (*CloseAssignmentDiscoverResponse) ProtoMessage 

func (*CloseAssignmentDiscoverResponse) ProtoMessage()

func (*CloseAssignmentDiscoverResponse) ProtoReflect 

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

func (*CloseAssignmentDiscoverResponse) Reset 

func (x *CloseAssignmentDiscoverResponse) Reset()

func (*CloseAssignmentDiscoverResponse) String 

func (x *CloseAssignmentDiscoverResponse) String() string

type CloseBroadcastWatchRequest 

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

func (*CloseBroadcastWatchRequest) Descriptor deprecated 

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

Deprecated: Use CloseBroadcastWatchRequest.ProtoReflect.Descriptor instead.

func (*CloseBroadcastWatchRequest) ProtoMessage 

func (*CloseBroadcastWatchRequest) ProtoMessage()

func (*CloseBroadcastWatchRequest) ProtoReflect 

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

func (*CloseBroadcastWatchRequest) Reset 

func (x *CloseBroadcastWatchRequest) Reset()

func (*CloseBroadcastWatchRequest) String 

func (x *CloseBroadcastWatchRequest) String() string

type CloseBroadcastWatchResponse 

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

func (*CloseBroadcastWatchResponse) Descriptor deprecated 

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

Deprecated: Use CloseBroadcastWatchResponse.ProtoReflect.Descriptor instead.

func (*CloseBroadcastWatchResponse) ProtoMessage 

func (*CloseBroadcastWatchResponse) ProtoMessage()

func (*CloseBroadcastWatchResponse) ProtoReflect 

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

func (*CloseBroadcastWatchResponse) Reset 

func (x *CloseBroadcastWatchResponse) Reset()

func (*CloseBroadcastWatchResponse) String 

func (x *CloseBroadcastWatchResponse) String() string

type CloseConsumerRequest 

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

CloseConsumerRequest is the request of the CloseConsumer RPC. After CloseConsumerRequest is requested, no more ConsumeRequest can be sent.

func (*CloseConsumerRequest) Descriptor deprecated 

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

Deprecated: Use CloseConsumerRequest.ProtoReflect.Descriptor instead.

func (*CloseConsumerRequest) ProtoMessage 

func (*CloseConsumerRequest) ProtoMessage()

func (*CloseConsumerRequest) ProtoReflect 

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

func (*CloseConsumerRequest) Reset 

func (x *CloseConsumerRequest) Reset()

func (*CloseConsumerRequest) String 

func (x *CloseConsumerRequest) String() string

type CloseConsumerResponse 

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

func (*CloseConsumerResponse) Descriptor deprecated 

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

Deprecated: Use CloseConsumerResponse.ProtoReflect.Descriptor instead.

func (*CloseConsumerResponse) ProtoMessage 

func (*CloseConsumerResponse) ProtoMessage()

func (*CloseConsumerResponse) ProtoReflect 

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

func (*CloseConsumerResponse) Reset 

func (x *CloseConsumerResponse) Reset()

func (*CloseConsumerResponse) String 

func (x *CloseConsumerResponse) String() string

type CloseProducerRequest 

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

CloseProducerRequest is the request of the CloseProducer RPC. After CloseProducerRequest is requested, no more ProduceRequest can be sent.

func (*CloseProducerRequest) Descriptor deprecated 

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

Deprecated: Use CloseProducerRequest.ProtoReflect.Descriptor instead.

func (*CloseProducerRequest) ProtoMessage 

func (*CloseProducerRequest) ProtoMessage()

func (*CloseProducerRequest) ProtoReflect 

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

func (*CloseProducerRequest) Reset 

func (x *CloseProducerRequest) Reset()

func (*CloseProducerRequest) String 

func (x *CloseProducerRequest) String() string

type CloseProducerResponse 

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

CloseProducerResponse is the result of the CloseProducer RPC.

func (*CloseProducerResponse) Descriptor deprecated 

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

Deprecated: Use CloseProducerResponse.ProtoReflect.Descriptor instead.

func (*CloseProducerResponse) ProtoMessage 

func (*CloseProducerResponse) ProtoMessage()

func (*CloseProducerResponse) ProtoReflect 

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

func (*CloseProducerResponse) Reset 

func (x *CloseProducerResponse) Reset()

func (*CloseProducerResponse) String 

func (x *CloseProducerResponse) String() string

type CloseVChannelConsumerRequest 

type CloseVChannelConsumerRequest struct {
	ConsumerId int64 `protobuf:"varint,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
	// contains filtered or unexported fields
}

CloseVChannelConsumerRequest is the request of the CloseVChannelConsumer RPC.

func (*CloseVChannelConsumerRequest) Descriptor deprecated 

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

Deprecated: Use CloseVChannelConsumerRequest.ProtoReflect.Descriptor instead.

func (*CloseVChannelConsumerRequest) GetConsumerId 

func (x *CloseVChannelConsumerRequest) GetConsumerId() int64

func (*CloseVChannelConsumerRequest) ProtoMessage 

func (*CloseVChannelConsumerRequest) ProtoMessage()

func (*CloseVChannelConsumerRequest) ProtoReflect 

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

func (*CloseVChannelConsumerRequest) Reset 

func (x *CloseVChannelConsumerRequest) Reset()

func (*CloseVChannelConsumerRequest) String 

func (x *CloseVChannelConsumerRequest) String() string

type CloseVChannelConsumerResponse 

type CloseVChannelConsumerResponse struct {
	ConsumerId int64 `protobuf:"varint,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
	// contains filtered or unexported fields
}

CloseVChannelConsumerResponse is the response of the CloseVChannelConsumer RPC.

func (*CloseVChannelConsumerResponse) Descriptor deprecated 

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

Deprecated: Use CloseVChannelConsumerResponse.ProtoReflect.Descriptor instead.

func (*CloseVChannelConsumerResponse) GetConsumerId 

func (x *CloseVChannelConsumerResponse) GetConsumerId() int64

func (*CloseVChannelConsumerResponse) ProtoMessage 

func (*CloseVChannelConsumerResponse) ProtoMessage()

func (*CloseVChannelConsumerResponse) ProtoReflect 

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

func (*CloseVChannelConsumerResponse) Reset 

func (x *CloseVChannelConsumerResponse) Reset()

func (*CloseVChannelConsumerResponse) String 

func (x *CloseVChannelConsumerResponse) String() string

type ConsumeMessageReponse 

type ConsumeMessageReponse struct {
	ConsumerId int64                        `protobuf:"varint,1,opt,name=consumer_id,json=consumerId,proto3" json:"consumer_id,omitempty"`
	Message    *messagespb.ImmutableMessage `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ConsumeMessageReponse) Descriptor deprecated 

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

Deprecated: Use ConsumeMessageReponse.ProtoReflect.Descriptor instead.

func (*ConsumeMessageReponse) GetConsumerId 

func (x *ConsumeMessageReponse) GetConsumerId() int64

func (*ConsumeMessageReponse) GetMessage 

func (x *ConsumeMessageReponse) GetMessage() *messagespb.ImmutableMessage

func (*ConsumeMessageReponse) ProtoMessage 

func (*ConsumeMessageReponse) ProtoMessage()

func (*ConsumeMessageReponse) ProtoReflect 

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

func (*ConsumeMessageReponse) Reset 

func (x *ConsumeMessageReponse) Reset()

func (*ConsumeMessageReponse) String 

func (x *ConsumeMessageReponse) String() string

type ConsumeRequest 

type ConsumeRequest struct {

	// Types that are assignable to Request:
	//
	//	*ConsumeRequest_CreateVchannelConsumer
	//	*ConsumeRequest_CreateVchannelConsumers
	//	*ConsumeRequest_CloseVchannel
	//	*ConsumeRequest_Close
	Request isConsumeRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

ConsumeRequest is the request of the Consume RPC. Add more control block in future.

func (*ConsumeRequest) Descriptor deprecated 

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

Deprecated: Use ConsumeRequest.ProtoReflect.Descriptor instead.

func (*ConsumeRequest) GetClose 

func (x *ConsumeRequest) GetClose() *CloseConsumerRequest

func (*ConsumeRequest) GetCloseVchannel 

func (x *ConsumeRequest) GetCloseVchannel() *CloseVChannelConsumerRequest

func (*ConsumeRequest) GetCreateVchannelConsumer 

func (x *ConsumeRequest) GetCreateVchannelConsumer() *CreateVChannelConsumerRequest

func (*ConsumeRequest) GetCreateVchannelConsumers 

func (x *ConsumeRequest) GetCreateVchannelConsumers() *CreateVChannelConsumersRequest

func (*ConsumeRequest) GetRequest 

func (m *ConsumeRequest) GetRequest() isConsumeRequest_Request

func (*ConsumeRequest) ProtoMessage 

func (*ConsumeRequest) ProtoMessage()

func (*ConsumeRequest) ProtoReflect 

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

func (*ConsumeRequest) Reset 

func (x *ConsumeRequest) Reset()

func (*ConsumeRequest) String 

func (x *ConsumeRequest) String() string

type ConsumeRequest_Close 

type ConsumeRequest_Close struct {
	Close *CloseConsumerRequest `protobuf:"bytes,4,opt,name=close,proto3,oneof"`
}

type ConsumeRequest_CloseVchannel 

type ConsumeRequest_CloseVchannel struct {
	CloseVchannel *CloseVChannelConsumerRequest `protobuf:"bytes,3,opt,name=close_vchannel,json=closeVchannel,proto3,oneof"`
}

type ConsumeRequest_CreateVchannelConsumer 

type ConsumeRequest_CreateVchannelConsumer struct {
	CreateVchannelConsumer *CreateVChannelConsumerRequest `protobuf:"bytes,1,opt,name=create_vchannel_consumer,json=createVchannelConsumer,proto3,oneof"`
}

type ConsumeRequest_CreateVchannelConsumers 

type ConsumeRequest_CreateVchannelConsumers struct {
	CreateVchannelConsumers *CreateVChannelConsumersRequest `protobuf:"bytes,2,opt,name=create_vchannel_consumers,json=createVchannelConsumers,proto3,oneof"` // Create multiple vchannel consumers, used for recovery in future.
}

type ConsumeResponse 

type ConsumeResponse struct {

	// Types that are assignable to Response:
	//
	//	*ConsumeResponse_Create
	//	*ConsumeResponse_Consume
	//	*ConsumeResponse_CreateVchannel
	//	*ConsumeResponse_CreateVchannels
	//	*ConsumeResponse_CloseVchannel
	//	*ConsumeResponse_Close
	Response isConsumeResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

ConsumeResponse is the reponse of the Consume RPC.

func (*ConsumeResponse) Descriptor deprecated 

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

Deprecated: Use ConsumeResponse.ProtoReflect.Descriptor instead.

func (*ConsumeResponse) GetClose 

func (x *ConsumeResponse) GetClose() *CloseConsumerResponse

func (*ConsumeResponse) GetCloseVchannel 

func (x *ConsumeResponse) GetCloseVchannel() *CloseVChannelConsumerResponse

func (*ConsumeResponse) GetConsume 

func (x *ConsumeResponse) GetConsume() *ConsumeMessageReponse

func (*ConsumeResponse) GetCreate 

func (x *ConsumeResponse) GetCreate() *CreateConsumerResponse

func (*ConsumeResponse) GetCreateVchannel 

func (x *ConsumeResponse) GetCreateVchannel() *CreateVChannelConsumerResponse

func (*ConsumeResponse) GetCreateVchannels 

func (x *ConsumeResponse) GetCreateVchannels() *CreateVChannelConsumersResponse

func (*ConsumeResponse) GetResponse 

func (m *ConsumeResponse) GetResponse() isConsumeResponse_Response

func (*ConsumeResponse) ProtoMessage 

func (*ConsumeResponse) ProtoMessage()

func (*ConsumeResponse) ProtoReflect 

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

func (*ConsumeResponse) Reset 

func (x *ConsumeResponse) Reset()

func (*ConsumeResponse) String 

func (x *ConsumeResponse) String() string

type ConsumeResponse_Close 

type ConsumeResponse_Close struct {
	Close *CloseConsumerResponse `protobuf:"bytes,6,opt,name=close,proto3,oneof"`
}

type ConsumeResponse_CloseVchannel 

type ConsumeResponse_CloseVchannel struct {
	CloseVchannel *CloseVChannelConsumerResponse `protobuf:"bytes,5,opt,name=close_vchannel,json=closeVchannel,proto3,oneof"`
}

type ConsumeResponse_Consume 

type ConsumeResponse_Consume struct {
	Consume *ConsumeMessageReponse `protobuf:"bytes,2,opt,name=consume,proto3,oneof"`
}

type ConsumeResponse_Create 

type ConsumeResponse_Create struct {
	Create *CreateConsumerResponse `protobuf:"bytes,1,opt,name=create,proto3,oneof"`
}

type ConsumeResponse_CreateVchannel 

type ConsumeResponse_CreateVchannel struct {
	CreateVchannel *CreateVChannelConsumerResponse `protobuf:"bytes,3,opt,name=create_vchannel,json=createVchannel,proto3,oneof"`
}

type ConsumeResponse_CreateVchannels 

type ConsumeResponse_CreateVchannels struct {
	CreateVchannels *CreateVChannelConsumersResponse `protobuf:"bytes,4,opt,name=create_vchannels,json=createVchannels,proto3,oneof"`
}

type CreateConsumerRequest 

type CreateConsumerRequest struct {
	Pchannel *PChannelInfo `protobuf:"bytes,1,opt,name=pchannel,proto3" json:"pchannel,omitempty"`
	// contains filtered or unexported fields
}

CreateConsumerRequest is the request of the CreateConsumer RPC. CreateConsumerRequest is passed in the header of stream.

func (*CreateConsumerRequest) Descriptor deprecated 

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

Deprecated: Use CreateConsumerRequest.ProtoReflect.Descriptor instead.

func (*CreateConsumerRequest) GetPchannel 

func (x *CreateConsumerRequest) GetPchannel() *PChannelInfo

func (*CreateConsumerRequest) ProtoMessage 

func (*CreateConsumerRequest) ProtoMessage()

func (*CreateConsumerRequest) ProtoReflect 

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

func (*CreateConsumerRequest) Reset 

func (x *CreateConsumerRequest) Reset()

func (*CreateConsumerRequest) String 

func (x *CreateConsumerRequest) String() string

type CreateConsumerResponse 

type CreateConsumerResponse struct {
	WalName string `protobuf:"bytes,1,opt,name=wal_name,json=walName,proto3" json:"wal_name,omitempty"` // wal name at server side.
	// A unique consumer id on streamingnode for this
	// consumer in streamingnode lifetime.
	ConsumerServerId int64 `protobuf:"varint,2,opt,name=consumer_server_id,json=consumerServerId,proto3" json:"consumer_server_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateConsumerResponse) Descriptor deprecated 

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

Deprecated: Use CreateConsumerResponse.ProtoReflect.Descriptor instead.

func (*CreateConsumerResponse) GetConsumerServerId 

func (x *CreateConsumerResponse) GetConsumerServerId() int64

func (*CreateConsumerResponse) GetWalName 

func (x *CreateConsumerResponse) GetWalName() string

func (*CreateConsumerResponse) ProtoMessage 

func (*CreateConsumerResponse) ProtoMessage()

func (*CreateConsumerResponse) ProtoReflect 

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

func (*CreateConsumerResponse) Reset 

func (x *CreateConsumerResponse) Reset()

func (*CreateConsumerResponse) String 

func (x *CreateConsumerResponse) String() string

type CreateProducerRequest 

type CreateProducerRequest struct {
	Pchannel *PChannelInfo `protobuf:"bytes,1,opt,name=pchannel,proto3" json:"pchannel,omitempty"`
	// contains filtered or unexported fields
}

CreateProducerRequest is the request of the CreateProducer RPC. CreateProducerRequest is passed in the header of stream.

func (*CreateProducerRequest) Descriptor deprecated 

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

Deprecated: Use CreateProducerRequest.ProtoReflect.Descriptor instead.

func (*CreateProducerRequest) GetPchannel 

func (x *CreateProducerRequest) GetPchannel() *PChannelInfo

func (*CreateProducerRequest) ProtoMessage 

func (*CreateProducerRequest) ProtoMessage()

func (*CreateProducerRequest) ProtoReflect 

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

func (*CreateProducerRequest) Reset 

func (x *CreateProducerRequest) Reset()

func (*CreateProducerRequest) String 

func (x *CreateProducerRequest) String() string

type CreateProducerResponse 

type CreateProducerResponse struct {
	WalName          string `protobuf:"bytes,1,opt,name=wal_name,json=walName,proto3" json:"wal_name,omitempty"`                               // wal name at server side.
	ProducerServerId int64  `protobuf:"varint,2,opt,name=producer_server_id,json=producerServerId,proto3" json:"producer_server_id,omitempty"` // A unique producer server id on streamingnode
	// contains filtered or unexported fields
}

CreateProducerResponse is the result of the CreateProducer RPC.

func (*CreateProducerResponse) Descriptor deprecated 

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

Deprecated: Use CreateProducerResponse.ProtoReflect.Descriptor instead.

func (*CreateProducerResponse) GetProducerServerId 

func (x *CreateProducerResponse) GetProducerServerId() int64

func (*CreateProducerResponse) GetWalName 

func (x *CreateProducerResponse) GetWalName() string

func (*CreateProducerResponse) ProtoMessage 

func (*CreateProducerResponse) ProtoMessage()

func (*CreateProducerResponse) ProtoReflect 

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

func (*CreateProducerResponse) Reset 

func (x *CreateProducerResponse) Reset()

func (*CreateProducerResponse) String 

func (x *CreateProducerResponse) String() string

type CreateVChannelConsumerRequest 

type CreateVChannelConsumerRequest struct {
	Vchannel       string           `protobuf:"bytes,1,opt,name=vchannel,proto3" json:"vchannel,omitempty"`
	DeliverPolicy  *DeliverPolicy   `protobuf:"bytes,2,opt,name=deliver_policy,json=deliverPolicy,proto3" json:"deliver_policy,omitempty"`    // deliver policy.
	DeliverFilters []*DeliverFilter `protobuf:"bytes,3,rep,name=deliver_filters,json=deliverFilters,proto3" json:"deliver_filters,omitempty"` // deliver filter.
	// contains filtered or unexported fields
}

CreateVChannelConsumerRequest is the request of the CreateVChannelConsumer RPC. It's used to create a new vchannel consumer at server side.

func (*CreateVChannelConsumerRequest) Descriptor deprecated 

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

Deprecated: Use CreateVChannelConsumerRequest.ProtoReflect.Descriptor instead.

func (*CreateVChannelConsumerRequest) GetDeliverFilters 

func (x *CreateVChannelConsumerRequest) GetDeliverFilters() []*DeliverFilter

func (*CreateVChannelConsumerRequest) GetDeliverPolicy 

func (x *CreateVChannelConsumerRequest) GetDeliverPolicy() *DeliverPolicy

func (*CreateVChannelConsumerRequest) GetVchannel 

func (x *CreateVChannelConsumerRequest) GetVchannel() string

func (*CreateVChannelConsumerRequest) ProtoMessage 

func (*CreateVChannelConsumerRequest) ProtoMessage()

func (*CreateVChannelConsumerRequest) ProtoReflect 

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

func (*CreateVChannelConsumerRequest) Reset 

func (x *CreateVChannelConsumerRequest) Reset()

func (*CreateVChannelConsumerRequest) String 

func (x *CreateVChannelConsumerRequest) String() string

type CreateVChannelConsumerResponse 

type CreateVChannelConsumerResponse struct {

	// Types that are assignable to Response:
	//
	//	*CreateVChannelConsumerResponse_ConsumerId
	//	*CreateVChannelConsumerResponse_Error
	Response isCreateVChannelConsumerResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

CreateVChannelConsumerResponse is the response of the CreateVChannelConsumer RPC.

func (*CreateVChannelConsumerResponse) Descriptor deprecated 

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

Deprecated: Use CreateVChannelConsumerResponse.ProtoReflect.Descriptor instead.

func (*CreateVChannelConsumerResponse) GetConsumerId 

func (x *CreateVChannelConsumerResponse) GetConsumerId() int64

func (*CreateVChannelConsumerResponse) GetError 

func (x *CreateVChannelConsumerResponse) GetError() *StreamingError

func (*CreateVChannelConsumerResponse) GetResponse 

func (m *CreateVChannelConsumerResponse) GetResponse() isCreateVChannelConsumerResponse_Response

func (*CreateVChannelConsumerResponse) ProtoMessage 

func (*CreateVChannelConsumerResponse) ProtoMessage()

func (*CreateVChannelConsumerResponse) ProtoReflect 

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

func (*CreateVChannelConsumerResponse) Reset 

func (x *CreateVChannelConsumerResponse) Reset()

func (*CreateVChannelConsumerResponse) String 

func (x *CreateVChannelConsumerResponse) String() string

type CreateVChannelConsumerResponse_ConsumerId 

type CreateVChannelConsumerResponse_ConsumerId struct {
	ConsumerId int64 `protobuf:"varint,1,opt,name=consumer_id,json=consumerId,proto3,oneof"`
}

type CreateVChannelConsumerResponse_Error 

type CreateVChannelConsumerResponse_Error struct {
	Error *StreamingError `protobuf:"bytes,2,opt,name=error,proto3,oneof"`
}

type CreateVChannelConsumersRequest 

type CreateVChannelConsumersRequest struct {
	CreateVchannels []*CreateVChannelConsumerRequest `protobuf:"bytes,1,rep,name=create_vchannels,json=createVchannels,proto3" json:"create_vchannels,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateVChannelConsumersRequest) Descriptor deprecated 

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

Deprecated: Use CreateVChannelConsumersRequest.ProtoReflect.Descriptor instead.

func (*CreateVChannelConsumersRequest) GetCreateVchannels 

func (x *CreateVChannelConsumersRequest) GetCreateVchannels() []*CreateVChannelConsumerRequest

func (*CreateVChannelConsumersRequest) ProtoMessage 

func (*CreateVChannelConsumersRequest) ProtoMessage()

func (*CreateVChannelConsumersRequest) ProtoReflect 

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

func (*CreateVChannelConsumersRequest) Reset 

func (x *CreateVChannelConsumersRequest) Reset()

func (*CreateVChannelConsumersRequest) String 

func (x *CreateVChannelConsumersRequest) String() string

type CreateVChannelConsumersResponse 

type CreateVChannelConsumersResponse struct {
	CreateVchannels []*CreateVChannelConsumerResponse `protobuf:"bytes,1,rep,name=create_vchannels,json=createVchannels,proto3" json:"create_vchannels,omitempty"`
	// contains filtered or unexported fields
}

ConsumeMessageRequest is the request of the Consume RPC.

func (*CreateVChannelConsumersResponse) Descriptor deprecated 

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

Deprecated: Use CreateVChannelConsumersResponse.ProtoReflect.Descriptor instead.

func (*CreateVChannelConsumersResponse) GetCreateVchannels 

func (x *CreateVChannelConsumersResponse) GetCreateVchannels() []*CreateVChannelConsumerResponse

func (*CreateVChannelConsumersResponse) ProtoMessage 

func (*CreateVChannelConsumersResponse) ProtoMessage()

func (*CreateVChannelConsumersResponse) ProtoReflect 

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

func (*CreateVChannelConsumersResponse) Reset 

func (x *CreateVChannelConsumersResponse) Reset()

func (*CreateVChannelConsumersResponse) String 

func (x *CreateVChannelConsumersResponse) String() string

type DeliverFilter 

type DeliverFilter struct {

	// Types that are assignable to Filter:
	//
	//	*DeliverFilter_TimeTickGt
	//	*DeliverFilter_TimeTickGte
	//	*DeliverFilter_MessageType
	Filter isDeliverFilter_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

DeliverFilter is the filter to deliver message.

func (*DeliverFilter) Descriptor deprecated 

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

Deprecated: Use DeliverFilter.ProtoReflect.Descriptor instead.

func (*DeliverFilter) GetFilter 

func (m *DeliverFilter) GetFilter() isDeliverFilter_Filter

func (*DeliverFilter) GetMessageType 

func (x *DeliverFilter) GetMessageType() *DeliverFilterMessageType

func (*DeliverFilter) GetTimeTickGt 

func (x *DeliverFilter) GetTimeTickGt() *DeliverFilterTimeTickGT

func (*DeliverFilter) GetTimeTickGte 

func (x *DeliverFilter) GetTimeTickGte() *DeliverFilterTimeTickGTE

func (*DeliverFilter) ProtoMessage 

func (*DeliverFilter) ProtoMessage()

func (*DeliverFilter) ProtoReflect 

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

func (*DeliverFilter) Reset 

func (x *DeliverFilter) Reset()

func (*DeliverFilter) String 

func (x *DeliverFilter) String() string

type DeliverFilterMessageType 

type DeliverFilterMessageType struct {

	// deliver message with message type.
	MessageTypes []messagespb.MessageType `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeliverFilterMessageType) Descriptor deprecated 

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

Deprecated: Use DeliverFilterMessageType.ProtoReflect.Descriptor instead.

func (*DeliverFilterMessageType) GetMessageTypes 

func (x *DeliverFilterMessageType) GetMessageTypes() []messagespb.MessageType

func (*DeliverFilterMessageType) ProtoMessage 

func (*DeliverFilterMessageType) ProtoMessage()

func (*DeliverFilterMessageType) ProtoReflect 

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

func (*DeliverFilterMessageType) Reset 

func (x *DeliverFilterMessageType) Reset()

func (*DeliverFilterMessageType) String 

func (x *DeliverFilterMessageType) String() string

type DeliverFilterTimeTickGT 

type DeliverFilterTimeTickGT struct {
	TimeTick uint64 `protobuf:"varint,1,opt,name=time_tick,json=timeTick,proto3" json:"time_tick,omitempty"` // deliver message with time tick greater than this value.
	// contains filtered or unexported fields
}

DeliverFilterTimeTickGT is the filter to deliver message with time tick greater than this value.

func (*DeliverFilterTimeTickGT) Descriptor deprecated 

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

Deprecated: Use DeliverFilterTimeTickGT.ProtoReflect.Descriptor instead.

func (*DeliverFilterTimeTickGT) GetTimeTick 

func (x *DeliverFilterTimeTickGT) GetTimeTick() uint64

func (*DeliverFilterTimeTickGT) ProtoMessage 

func (*DeliverFilterTimeTickGT) ProtoMessage()

func (*DeliverFilterTimeTickGT) ProtoReflect 

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

func (*DeliverFilterTimeTickGT) Reset 

func (x *DeliverFilterTimeTickGT) Reset()

func (*DeliverFilterTimeTickGT) String 

func (x *DeliverFilterTimeTickGT) String() string

type DeliverFilterTimeTickGTE 

type DeliverFilterTimeTickGTE struct {
	TimeTick uint64 `protobuf:"varint,1,opt,name=time_tick,json=timeTick,proto3" json:"time_tick,omitempty"` // deliver message with time tick greater than or
	// contains filtered or unexported fields
}

DeliverFilterTimeTickGTE is the filter to deliver message with time tick greater than or equal to this value.

func (*DeliverFilterTimeTickGTE) Descriptor deprecated 

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

Deprecated: Use DeliverFilterTimeTickGTE.ProtoReflect.Descriptor instead.

func (*DeliverFilterTimeTickGTE) GetTimeTick 

func (x *DeliverFilterTimeTickGTE) GetTimeTick() uint64

func (*DeliverFilterTimeTickGTE) ProtoMessage 

func (*DeliverFilterTimeTickGTE) ProtoMessage()

func (*DeliverFilterTimeTickGTE) ProtoReflect 

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

func (*DeliverFilterTimeTickGTE) Reset 

func (x *DeliverFilterTimeTickGTE) Reset()

func (*DeliverFilterTimeTickGTE) String 

func (x *DeliverFilterTimeTickGTE) String() string

type DeliverFilter_MessageType 

type DeliverFilter_MessageType struct {
	MessageType *DeliverFilterMessageType `protobuf:"bytes,3,opt,name=message_type,json=messageType,proto3,oneof"`
}

type DeliverFilter_TimeTickGt 

type DeliverFilter_TimeTickGt struct {
	TimeTickGt *DeliverFilterTimeTickGT `protobuf:"bytes,1,opt,name=time_tick_gt,json=timeTickGt,proto3,oneof"`
}

type DeliverFilter_TimeTickGte 

type DeliverFilter_TimeTickGte struct {
	TimeTickGte *DeliverFilterTimeTickGTE `protobuf:"bytes,2,opt,name=time_tick_gte,json=timeTickGte,proto3,oneof"`
}

type DeliverPolicy 

type DeliverPolicy struct {

	// Types that are assignable to Policy:
	//
	//	*DeliverPolicy_All
	//	*DeliverPolicy_Latest
	//	*DeliverPolicy_StartFrom
	//	*DeliverPolicy_StartAfter
	Policy isDeliverPolicy_Policy `protobuf_oneof:"policy"`
	// contains filtered or unexported fields
}

DeliverPolicy is the policy to deliver message.

func (*DeliverPolicy) Descriptor deprecated 

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

Deprecated: Use DeliverPolicy.ProtoReflect.Descriptor instead.

func (*DeliverPolicy) GetAll 

func (x *DeliverPolicy) GetAll() *emptypb.Empty

func (*DeliverPolicy) GetLatest 

func (x *DeliverPolicy) GetLatest() *emptypb.Empty

func (*DeliverPolicy) GetPolicy 

func (m *DeliverPolicy) GetPolicy() isDeliverPolicy_Policy

func (*DeliverPolicy) GetStartAfter 

func (x *DeliverPolicy) GetStartAfter() *messagespb.MessageID

func (*DeliverPolicy) GetStartFrom 

func (x *DeliverPolicy) GetStartFrom() *messagespb.MessageID

func (*DeliverPolicy) ProtoMessage 

func (*DeliverPolicy) ProtoMessage()

func (*DeliverPolicy) ProtoReflect 

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

func (*DeliverPolicy) Reset 

func (x *DeliverPolicy) Reset()

func (*DeliverPolicy) String 

func (x *DeliverPolicy) String() string

type DeliverPolicy_All 

type DeliverPolicy_All struct {
	All *emptypb.Empty `protobuf:"bytes,1,opt,name=all,proto3,oneof"` // deliver all messages.
}

type DeliverPolicy_Latest 

type DeliverPolicy_Latest struct {
	Latest *emptypb.Empty `protobuf:"bytes,2,opt,name=latest,proto3,oneof"` // deliver the latest message.
}

type DeliverPolicy_StartAfter 

type DeliverPolicy_StartAfter struct {
	StartAfter *messagespb.MessageID `protobuf:"bytes,4,opt,name=start_after,json=startAfter,proto3,oneof"` // deliver message after this message id. (startAfter, ...]
}

type DeliverPolicy_StartFrom 

type DeliverPolicy_StartFrom struct {
	StartFrom *messagespb.MessageID `protobuf:"bytes,3,opt,name=start_from,json=startFrom,proto3,oneof"` // deliver message from this message id. [startFrom, ...]
}

type FullStreamingNodeAssignmentWithVersion 

type FullStreamingNodeAssignmentWithVersion struct {
	Version     *VersionPair               `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Assignments []*StreamingNodeAssignment `protobuf:"bytes,2,rep,name=assignments,proto3" json:"assignments,omitempty"`
	// contains filtered or unexported fields
}

FullStreamingNodeAssignmentWithVersion is the full assignment info of a log node with version.

func (*FullStreamingNodeAssignmentWithVersion) Descriptor deprecated 

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

Deprecated: Use FullStreamingNodeAssignmentWithVersion.ProtoReflect.Descriptor instead.

func (*FullStreamingNodeAssignmentWithVersion) GetAssignments 

func (x *FullStreamingNodeAssignmentWithVersion) GetAssignments() []*StreamingNodeAssignment

func (*FullStreamingNodeAssignmentWithVersion) GetVersion 

func (x *FullStreamingNodeAssignmentWithVersion) GetVersion() *VersionPair

func (*FullStreamingNodeAssignmentWithVersion) ProtoMessage 

func (*FullStreamingNodeAssignmentWithVersion) ProtoMessage()

func (*FullStreamingNodeAssignmentWithVersion) ProtoReflect 

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

func (*FullStreamingNodeAssignmentWithVersion) Reset 

func (x *FullStreamingNodeAssignmentWithVersion) Reset()

func (*FullStreamingNodeAssignmentWithVersion) String 

func (x *FullStreamingNodeAssignmentWithVersion) String() string

type PChannelAssignmentLog 

type PChannelAssignmentLog struct {
	Term int64              `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"` // term when server assigned.
	Node *StreamingNodeInfo `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`  // streaming node that the channel is assigned to.
	// contains filtered or unexported fields
}

PChannelAssignmentLog is the log of meta information of a pchannel, should only keep the data that is necessary to persistent.

func (*PChannelAssignmentLog) Descriptor deprecated 

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

Deprecated: Use PChannelAssignmentLog.ProtoReflect.Descriptor instead.

func (*PChannelAssignmentLog) GetNode 

func (x *PChannelAssignmentLog) GetNode() *StreamingNodeInfo

func (*PChannelAssignmentLog) GetTerm 

func (x *PChannelAssignmentLog) GetTerm() int64

func (*PChannelAssignmentLog) ProtoMessage 

func (*PChannelAssignmentLog) ProtoMessage()

func (*PChannelAssignmentLog) ProtoReflect 

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

func (*PChannelAssignmentLog) Reset 

func (x *PChannelAssignmentLog) Reset()

func (*PChannelAssignmentLog) String 

func (x *PChannelAssignmentLog) String() string

type PChannelInfo 

type PChannelInfo struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`  // channel name
	Term int64  `protobuf:"varint,2,opt,name=term,proto3" json:"term,omitempty"` // A monotonic increasing term, every time the channel is
	// contains filtered or unexported fields
}

PChannelInfo is the information of a pchannel info, should only keep the basic info of a pchannel. It's used in many rpc and meta, so keep it simple.

func (*PChannelInfo) Descriptor deprecated 

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

Deprecated: Use PChannelInfo.ProtoReflect.Descriptor instead.

func (*PChannelInfo) GetName 

func (x *PChannelInfo) GetName() string

func (*PChannelInfo) GetTerm 

func (x *PChannelInfo) GetTerm() int64

func (*PChannelInfo) ProtoMessage 

func (*PChannelInfo) ProtoMessage()

func (*PChannelInfo) ProtoReflect 

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

func (*PChannelInfo) Reset 

func (x *PChannelInfo) Reset()

func (*PChannelInfo) String 

func (x *PChannelInfo) String() string

type PChannelMeta 

type PChannelMeta struct {
	Channel   *PChannelInfo            `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`                                            // keep the meta info that current assigned to.
	Node      *StreamingNodeInfo       `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`                                                  // nil if channel is not uninitialized.
	State     PChannelMetaState        `protobuf:"varint,3,opt,name=state,proto3,enum=milvus.proto.streaming.PChannelMetaState" json:"state,omitempty"` // state of the channel.
	Histories []*PChannelAssignmentLog `protobuf:"bytes,4,rep,name=histories,proto3" json:"histories,omitempty"`                                        // keep the meta info assignment log that used to be assigned to.
	// contains filtered or unexported fields
}

PChannelMeta is the meta information of a pchannel, should only keep the data that is necessary to persistent. It's only used in meta, so do not use it in rpc.

func (*PChannelMeta) Descriptor deprecated 

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

Deprecated: Use PChannelMeta.ProtoReflect.Descriptor instead.

func (*PChannelMeta) GetChannel 

func (x *PChannelMeta) GetChannel() *PChannelInfo

func (*PChannelMeta) GetHistories 

func (x *PChannelMeta) GetHistories() []*PChannelAssignmentLog

func (*PChannelMeta) GetNode 

func (x *PChannelMeta) GetNode() *StreamingNodeInfo

func (*PChannelMeta) GetState 

func (x *PChannelMeta) GetState() PChannelMetaState

func (*PChannelMeta) ProtoMessage 

func (*PChannelMeta) ProtoMessage()

func (*PChannelMeta) ProtoReflect 

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

func (*PChannelMeta) Reset 

func (x *PChannelMeta) Reset()

func (*PChannelMeta) String 

func (x *PChannelMeta) String() string

type PChannelMetaState 

type PChannelMetaState int32

PChannelMetaState 

const (
	PChannelMetaState_PCHANNEL_META_STATE_UNKNOWN       PChannelMetaState = 0 // should never used.
	PChannelMetaState_PCHANNEL_META_STATE_UNINITIALIZED PChannelMetaState = 1 // channel is uninitialized, never assgined to any streaming node.
	PChannelMetaState_PCHANNEL_META_STATE_ASSIGNING     PChannelMetaState = 2 // new term is allocated, but not determined to be assgined.
	PChannelMetaState_PCHANNEL_META_STATE_ASSIGNED      PChannelMetaState = 3 // channel is assigned to a streaming node.
	PChannelMetaState_PCHANNEL_META_STATE_UNAVAILABLE   PChannelMetaState = 4 // channel is unavailable at this term.
)

func (PChannelMetaState) Descriptor 

func (PChannelMetaState) Descriptor() protoreflect.EnumDescriptor

func (PChannelMetaState) Enum 

func (x PChannelMetaState) Enum() *PChannelMetaState

func (PChannelMetaState) EnumDescriptor deprecated 

func (PChannelMetaState) EnumDescriptor() ([]byte, []int)

Deprecated: Use PChannelMetaState.Descriptor instead.

func (PChannelMetaState) Number 

func (x PChannelMetaState) Number() protoreflect.EnumNumber

func (PChannelMetaState) String 

func (x PChannelMetaState) String() string

func (PChannelMetaState) Type 

func (PChannelMetaState) Type() protoreflect.EnumType

type ProduceMessageRequest 

type ProduceMessageRequest struct {
	RequestId int64               `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // request id for reply.
	Message   *messagespb.Message `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`                       // message to be sent.
	// contains filtered or unexported fields
}

ProduceMessageRequest is the request of the Produce RPC.

func (*ProduceMessageRequest) Descriptor deprecated 

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

Deprecated: Use ProduceMessageRequest.ProtoReflect.Descriptor instead.

func (*ProduceMessageRequest) GetMessage 

func (x *ProduceMessageRequest) GetMessage() *messagespb.Message

func (*ProduceMessageRequest) GetRequestId 

func (x *ProduceMessageRequest) GetRequestId() int64

func (*ProduceMessageRequest) ProtoMessage 

func (*ProduceMessageRequest) ProtoMessage()

func (*ProduceMessageRequest) ProtoReflect 

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

func (*ProduceMessageRequest) Reset 

func (x *ProduceMessageRequest) Reset()

func (*ProduceMessageRequest) String 

func (x *ProduceMessageRequest) String() string

type ProduceMessageResponse 

type ProduceMessageResponse struct {
	RequestId int64 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are assignable to Response:
	//
	//	*ProduceMessageResponse_Result
	//	*ProduceMessageResponse_Error
	Response isProduceMessageResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

ProduceMessageResponse is the response of the ProduceMessage RPC.

func (*ProduceMessageResponse) Descriptor deprecated 

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

Deprecated: Use ProduceMessageResponse.ProtoReflect.Descriptor instead.

func (*ProduceMessageResponse) GetError 

func (x *ProduceMessageResponse) GetError() *StreamingError

func (*ProduceMessageResponse) GetRequestId 

func (x *ProduceMessageResponse) GetRequestId() int64

func (*ProduceMessageResponse) GetResponse 

func (m *ProduceMessageResponse) GetResponse() isProduceMessageResponse_Response

func (*ProduceMessageResponse) GetResult 

func (x *ProduceMessageResponse) GetResult() *ProduceMessageResponseResult

func (*ProduceMessageResponse) ProtoMessage 

func (*ProduceMessageResponse) ProtoMessage()

func (*ProduceMessageResponse) ProtoReflect 

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

func (*ProduceMessageResponse) Reset 

func (x *ProduceMessageResponse) Reset()

func (*ProduceMessageResponse) String 

func (x *ProduceMessageResponse) String() string

type ProduceMessageResponseResult 

type ProduceMessageResponseResult struct {
	Id         *messagespb.MessageID  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                 // the offset of the message in the channel.
	Timetick   uint64                 `protobuf:"varint,2,opt,name=timetick,proto3" json:"timetick,omitempty"`    // the timetick of that message sent.
	TxnContext *messagespb.TxnContext `protobuf:"bytes,3,opt,name=txnContext,proto3" json:"txnContext,omitempty"` // the txn context of the message.
	Extra      *anypb.Any             `protobuf:"bytes,4,opt,name=extra,proto3" json:"extra,omitempty"`           // the extra message.
	// contains filtered or unexported fields
}

ProduceMessageResponseResult is the result of the produce message streaming RPC.

func (*ProduceMessageResponseResult) Descriptor deprecated 

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

Deprecated: Use ProduceMessageResponseResult.ProtoReflect.Descriptor instead.

func (*ProduceMessageResponseResult) GetExtra 

func (x *ProduceMessageResponseResult) GetExtra() *anypb.Any

func (*ProduceMessageResponseResult) GetId 

func (x *ProduceMessageResponseResult) GetId() *messagespb.MessageID

func (*ProduceMessageResponseResult) GetTimetick 

func (x *ProduceMessageResponseResult) GetTimetick() uint64

func (*ProduceMessageResponseResult) GetTxnContext 

func (x *ProduceMessageResponseResult) GetTxnContext() *messagespb.TxnContext

func (*ProduceMessageResponseResult) ProtoMessage 

func (*ProduceMessageResponseResult) ProtoMessage()

func (*ProduceMessageResponseResult) ProtoReflect 

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

func (*ProduceMessageResponseResult) Reset 

func (x *ProduceMessageResponseResult) Reset()

func (*ProduceMessageResponseResult) String 

func (x *ProduceMessageResponseResult) String() string

type ProduceMessageResponse_Error 

type ProduceMessageResponse_Error struct {
	Error *StreamingError `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}

type ProduceMessageResponse_Result 

type ProduceMessageResponse_Result struct {
	Result *ProduceMessageResponseResult `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

type ProduceRequest 

type ProduceRequest struct {

	// Types that are assignable to Request:
	//
	//	*ProduceRequest_Produce
	//	*ProduceRequest_Close
	Request isProduceRequest_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

ProduceRequest is the request of the Produce RPC. Channel name will be passthrough in the header of stream bu not in the request body.

func (*ProduceRequest) Descriptor deprecated 

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

Deprecated: Use ProduceRequest.ProtoReflect.Descriptor instead.

func (*ProduceRequest) GetClose 

func (x *ProduceRequest) GetClose() *CloseProducerRequest

func (*ProduceRequest) GetProduce 

func (x *ProduceRequest) GetProduce() *ProduceMessageRequest

func (*ProduceRequest) GetRequest 

func (m *ProduceRequest) GetRequest() isProduceRequest_Request

func (*ProduceRequest) ProtoMessage 

func (*ProduceRequest) ProtoMessage()

func (*ProduceRequest) ProtoReflect 

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

func (*ProduceRequest) Reset 

func (x *ProduceRequest) Reset()

func (*ProduceRequest) String 

func (x *ProduceRequest) String() string

type ProduceRequest_Close 

type ProduceRequest_Close struct {
	Close *CloseProducerRequest `protobuf:"bytes,2,opt,name=close,proto3,oneof"`
}

type ProduceRequest_Produce 

type ProduceRequest_Produce struct {
	Produce *ProduceMessageRequest `protobuf:"bytes,1,opt,name=produce,proto3,oneof"`
}

type ProduceResponse 

type ProduceResponse struct {

	// Types that are assignable to Response:
	//
	//	*ProduceResponse_Create
	//	*ProduceResponse_Produce
	//	*ProduceResponse_Close
	Response isProduceResponse_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

ProduceResponse is the response of the Produce RPC.

func (*ProduceResponse) Descriptor deprecated 

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

Deprecated: Use ProduceResponse.ProtoReflect.Descriptor instead.

func (*ProduceResponse) GetClose 

func (x *ProduceResponse) GetClose() *CloseProducerResponse

func (*ProduceResponse) GetCreate 

func (x *ProduceResponse) GetCreate() *CreateProducerResponse

func (*ProduceResponse) GetProduce 

func (x *ProduceResponse) GetProduce() *ProduceMessageResponse

func (*ProduceResponse) GetResponse 

func (m *ProduceResponse) GetResponse() isProduceResponse_Response

func (*ProduceResponse) ProtoMessage 

func (*ProduceResponse) ProtoMessage()

func (*ProduceResponse) ProtoReflect 

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

func (*ProduceResponse) Reset 

func (x *ProduceResponse) Reset()

func (*ProduceResponse) String 

func (x *ProduceResponse) String() string

type ProduceResponse_Close 

type ProduceResponse_Close struct {
	Close *CloseProducerResponse `protobuf:"bytes,3,opt,name=close,proto3,oneof"`
}

type ProduceResponse_Create 

type ProduceResponse_Create struct {
	Create *CreateProducerResponse `protobuf:"bytes,1,opt,name=create,proto3,oneof"`
}

type ProduceResponse_Produce 

type ProduceResponse_Produce struct {
	Produce *ProduceMessageResponse `protobuf:"bytes,2,opt,name=produce,proto3,oneof"`
}

type ReportAssignmentErrorRequest 

type ReportAssignmentErrorRequest struct {
	Pchannel *PChannelInfo   `protobuf:"bytes,1,opt,name=pchannel,proto3" json:"pchannel,omitempty"` // channel
	Err      *StreamingError `protobuf:"bytes,2,opt,name=err,proto3" json:"err,omitempty"`           // error happend on log node
	// contains filtered or unexported fields
}

ReportAssignmentErrorRequest is the request to report assignment error happens.

func (*ReportAssignmentErrorRequest) Descriptor deprecated 

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

Deprecated: Use ReportAssignmentErrorRequest.ProtoReflect.Descriptor instead.

func (*ReportAssignmentErrorRequest) GetErr 

func (x *ReportAssignmentErrorRequest) GetErr() *StreamingError

func (*ReportAssignmentErrorRequest) GetPchannel 

func (x *ReportAssignmentErrorRequest) GetPchannel() *PChannelInfo

func (*ReportAssignmentErrorRequest) ProtoMessage 

func (*ReportAssignmentErrorRequest) ProtoMessage()

func (*ReportAssignmentErrorRequest) ProtoReflect 

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

func (*ReportAssignmentErrorRequest) Reset 

func (x *ReportAssignmentErrorRequest) Reset()

func (*ReportAssignmentErrorRequest) String 

func (x *ReportAssignmentErrorRequest) String() string

type SegmentAssignmentMeta 

type SegmentAssignmentMeta struct {
	CollectionId int64                  `protobuf:"varint,1,opt,name=collection_id,json=collectionId,proto3" json:"collection_id,omitempty"`
	PartitionId  int64                  `protobuf:"varint,2,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	SegmentId    int64                  `protobuf:"varint,3,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	Vchannel     string                 `protobuf:"bytes,4,opt,name=vchannel,proto3" json:"vchannel,omitempty"`
	State        SegmentAssignmentState `protobuf:"varint,5,opt,name=state,proto3,enum=milvus.proto.streaming.SegmentAssignmentState" json:"state,omitempty"`
	Stat         *SegmentAssignmentStat `protobuf:"bytes,6,opt,name=stat,proto3" json:"stat,omitempty"`
	// contains filtered or unexported fields
}

/ / SegmentAssignment / SegmentAssignmentMeta is the stat of segment assignment. These meta is only used to recover status at streaming node segment assignment, don't use it outside. Used to storage the segment assignment stat at meta-store. The WAL use it to determine when to make the segment sealed.

func (*SegmentAssignmentMeta) Descriptor deprecated 

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

Deprecated: Use SegmentAssignmentMeta.ProtoReflect.Descriptor instead.

func (*SegmentAssignmentMeta) GetCollectionId 

func (x *SegmentAssignmentMeta) GetCollectionId() int64

func (*SegmentAssignmentMeta) GetPartitionId 

func (x *SegmentAssignmentMeta) GetPartitionId() int64

func (*SegmentAssignmentMeta) GetSegmentId 

func (x *SegmentAssignmentMeta) GetSegmentId() int64

func (*SegmentAssignmentMeta) GetStat 

func (x *SegmentAssignmentMeta) GetStat() *SegmentAssignmentStat

func (*SegmentAssignmentMeta) GetState 

func (x *SegmentAssignmentMeta) GetState() SegmentAssignmentState

func (*SegmentAssignmentMeta) GetVchannel 

func (x *SegmentAssignmentMeta) GetVchannel() string

func (*SegmentAssignmentMeta) ProtoMessage 

func (*SegmentAssignmentMeta) ProtoMessage()

func (*SegmentAssignmentMeta) ProtoReflect 

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

func (*SegmentAssignmentMeta) Reset 

func (x *SegmentAssignmentMeta) Reset()

func (*SegmentAssignmentMeta) String 

func (x *SegmentAssignmentMeta) String() string

type SegmentAssignmentStat 

type SegmentAssignmentStat struct {
	MaxBinarySize                    uint64 `protobuf:"varint,1,opt,name=max_binary_size,json=maxBinarySize,proto3" json:"max_binary_size,omitempty"`
	InsertedRows                     uint64 `protobuf:"varint,2,opt,name=inserted_rows,json=insertedRows,proto3" json:"inserted_rows,omitempty"`
	InsertedBinarySize               uint64 `protobuf:"varint,3,opt,name=inserted_binary_size,json=insertedBinarySize,proto3" json:"inserted_binary_size,omitempty"`
	CreateTimestampNanoseconds       int64  `` /* 142-byte string literal not displayed */
	LastModifiedTimestampNanoseconds int64  `` /* 162-byte string literal not displayed */
	BinlogCounter                    uint64 `protobuf:"varint,6,opt,name=binlog_counter,json=binlogCounter,proto3" json:"binlog_counter,omitempty"`
	CreateSegmentTimeTick            uint64 `` // The timetick of create segment message in wal.
	/* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

SegmentAssignmentStat is the stat of segment assignment.

func (*SegmentAssignmentStat) Descriptor deprecated 

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

Deprecated: Use SegmentAssignmentStat.ProtoReflect.Descriptor instead.

func (*SegmentAssignmentStat) GetBinlogCounter 

func (x *SegmentAssignmentStat) GetBinlogCounter() uint64

func (*SegmentAssignmentStat) GetCreateSegmentTimeTick 

func (x *SegmentAssignmentStat) GetCreateSegmentTimeTick() uint64

func (*SegmentAssignmentStat) GetCreateTimestampNanoseconds 

func (x *SegmentAssignmentStat) GetCreateTimestampNanoseconds() int64

func (*SegmentAssignmentStat) GetInsertedBinarySize 

func (x *SegmentAssignmentStat) GetInsertedBinarySize() uint64

func (*SegmentAssignmentStat) GetInsertedRows 

func (x *SegmentAssignmentStat) GetInsertedRows() uint64

func (*SegmentAssignmentStat) GetLastModifiedTimestampNanoseconds 

func (x *SegmentAssignmentStat) GetLastModifiedTimestampNanoseconds() int64

func (*SegmentAssignmentStat) GetMaxBinarySize 

func (x *SegmentAssignmentStat) GetMaxBinarySize() uint64

func (*SegmentAssignmentStat) ProtoMessage 

func (*SegmentAssignmentStat) ProtoMessage()

func (*SegmentAssignmentStat) ProtoReflect 

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

func (*SegmentAssignmentStat) Reset 

func (x *SegmentAssignmentStat) Reset()

func (*SegmentAssignmentStat) String 

func (x *SegmentAssignmentStat) String() string

type SegmentAssignmentState 

type SegmentAssignmentState int32

SegmentAssignmentState is the state of segment assignment. The state machine can be described as following: 1. PENDING -> GROWING -> SEALED -> FLUSHED 

const (
	SegmentAssignmentState_SEGMENT_ASSIGNMENT_STATE_UNKNOWN SegmentAssignmentState = 0 // should never used.
	SegmentAssignmentState_SEGMENT_ASSIGNMENT_STATE_PENDING SegmentAssignmentState = 1
	SegmentAssignmentState_SEGMENT_ASSIGNMENT_STATE_GROWING SegmentAssignmentState = 2
	SegmentAssignmentState_SEGMENT_ASSIGNMENT_STATE_SEALED  SegmentAssignmentState = 3
	SegmentAssignmentState_SEGMENT_ASSIGNMENT_STATE_FLUSHED SegmentAssignmentState = 4 // can never be seen, because it's
)

func (SegmentAssignmentState) Descriptor 

func (SegmentAssignmentState) Descriptor() protoreflect.EnumDescriptor

func (SegmentAssignmentState) Enum 

func (x SegmentAssignmentState) Enum() *SegmentAssignmentState

func (SegmentAssignmentState) EnumDescriptor deprecated 

func (SegmentAssignmentState) EnumDescriptor() ([]byte, []int)

Deprecated: Use SegmentAssignmentState.Descriptor instead.

func (SegmentAssignmentState) Number 

func (x SegmentAssignmentState) Number() protoreflect.EnumNumber

func (SegmentAssignmentState) String 

func (x SegmentAssignmentState) String() string

func (SegmentAssignmentState) Type 

func (SegmentAssignmentState) Type() protoreflect.EnumType

type StreamingCode 

type StreamingCode int32

StreamingCode is the error code for log internal component. 

const (
	StreamingCode_STREAMING_CODE_OK                        StreamingCode = 0
	StreamingCode_STREAMING_CODE_CHANNEL_NOT_EXIST         StreamingCode = 1   // channel not exist
	StreamingCode_STREAMING_CODE_CHANNEL_FENCED            StreamingCode = 2   // channel is fenced
	StreamingCode_STREAMING_CODE_ON_SHUTDOWN               StreamingCode = 3   // component is on shutdown
	StreamingCode_STREAMING_CODE_INVALID_REQUEST_SEQ       StreamingCode = 4   // invalid request sequence
	StreamingCode_STREAMING_CODE_UNMATCHED_CHANNEL_TERM    StreamingCode = 5   // unmatched channel term
	StreamingCode_STREAMING_CODE_IGNORED_OPERATION         StreamingCode = 6   // ignored operation
	StreamingCode_STREAMING_CODE_INNER                     StreamingCode = 7   // underlying service failure.
	StreamingCode_STREAMING_CODE_INVAILD_ARGUMENT          StreamingCode = 8   // invalid argument
	StreamingCode_STREAMING_CODE_TRANSACTION_EXPIRED       StreamingCode = 9   // transaction expired
	StreamingCode_STREAMING_CODE_INVALID_TRANSACTION_STATE StreamingCode = 10  // invalid transaction state
	StreamingCode_STREAMING_CODE_UNRECOVERABLE             StreamingCode = 11  // unrecoverable error
	StreamingCode_STREAMING_CODE_RESOURCE_ACQUIRED         StreamingCode = 12  // resource is acquired by other operation
	StreamingCode_STREAMING_CODE_UNKNOWN                   StreamingCode = 999 // unknown error
)

func (StreamingCode) Descriptor 

func (StreamingCode) Descriptor() protoreflect.EnumDescriptor

func (StreamingCode) Enum 

func (x StreamingCode) Enum() *StreamingCode

func (StreamingCode) EnumDescriptor deprecated 

func (StreamingCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use StreamingCode.Descriptor instead.

func (StreamingCode) Number 

func (x StreamingCode) Number() protoreflect.EnumNumber

func (StreamingCode) String 

func (x StreamingCode) String() string

func (StreamingCode) Type 

func (StreamingCode) Type() protoreflect.EnumType

type StreamingCoordAssignmentServiceClient 

type StreamingCoordAssignmentServiceClient interface {
	// AssignmentDiscover is used to discover all log nodes managed by the
	// streamingcoord. Channel assignment information will be pushed to client
	// by stream.
	AssignmentDiscover(ctx context.Context, opts ...grpc.CallOption) (StreamingCoordAssignmentService_AssignmentDiscoverClient, error)
}

StreamingCoordAssignmentServiceClient is the client API for StreamingCoordAssignmentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamingCoordAssignmentServiceClient 

func NewStreamingCoordAssignmentServiceClient(cc grpc.ClientConnInterface) StreamingCoordAssignmentServiceClient

type StreamingCoordAssignmentServiceServer 

type StreamingCoordAssignmentServiceServer interface {
	// AssignmentDiscover is used to discover all log nodes managed by the
	// streamingcoord. Channel assignment information will be pushed to client
	// by stream.
	AssignmentDiscover(StreamingCoordAssignmentService_AssignmentDiscoverServer) error
}

StreamingCoordAssignmentServiceServer is the server API for StreamingCoordAssignmentService service. All implementations should embed UnimplementedStreamingCoordAssignmentServiceServer for forward compatibility

type StreamingCoordAssignmentService_AssignmentDiscoverClient 

type StreamingCoordAssignmentService_AssignmentDiscoverClient interface {
	Send(*AssignmentDiscoverRequest) error
	Recv() (*AssignmentDiscoverResponse, error)
	grpc.ClientStream
}

type StreamingCoordAssignmentService_AssignmentDiscoverServer 

type StreamingCoordAssignmentService_AssignmentDiscoverServer interface {
	Send(*AssignmentDiscoverResponse) error
	Recv() (*AssignmentDiscoverRequest, error)
	grpc.ServerStream
}

type StreamingCoordBroadcastServiceClient 

type StreamingCoordBroadcastServiceClient interface {
	// Broadcast receives broadcast messages from other component and make sure that the message is broadcast to all wal.
	// It performs an atomic broadcast to all wal, achieve eventual consistency.
	Broadcast(ctx context.Context, in *BroadcastRequest, opts ...grpc.CallOption) (*BroadcastResponse, error)
	// Ack acknowledge broadcast message is consumed.
	Ack(ctx context.Context, in *BroadcastAckRequest, opts ...grpc.CallOption) (*BroadcastAckResponse, error)
	// Watch watch the broadcast events.
	Watch(ctx context.Context, opts ...grpc.CallOption) (StreamingCoordBroadcastService_WatchClient, error)
}

StreamingCoordBroadcastServiceClient is the client API for StreamingCoordBroadcastService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamingCoordBroadcastServiceClient 

func NewStreamingCoordBroadcastServiceClient(cc grpc.ClientConnInterface) StreamingCoordBroadcastServiceClient

type StreamingCoordBroadcastServiceServer 

type StreamingCoordBroadcastServiceServer interface {
	// Broadcast receives broadcast messages from other component and make sure that the message is broadcast to all wal.
	// It performs an atomic broadcast to all wal, achieve eventual consistency.
	Broadcast(context.Context, *BroadcastRequest) (*BroadcastResponse, error)
	// Ack acknowledge broadcast message is consumed.
	Ack(context.Context, *BroadcastAckRequest) (*BroadcastAckResponse, error)
	// Watch watch the broadcast events.
	Watch(StreamingCoordBroadcastService_WatchServer) error
}

StreamingCoordBroadcastServiceServer is the server API for StreamingCoordBroadcastService service. All implementations should embed UnimplementedStreamingCoordBroadcastServiceServer for forward compatibility

type StreamingCoordBroadcastService_WatchClient 

type StreamingCoordBroadcastService_WatchClient interface {
	Send(*BroadcastWatchRequest) error
	Recv() (*BroadcastWatchResponse, error)
	grpc.ClientStream
}

type StreamingCoordBroadcastService_WatchServer 

type StreamingCoordBroadcastService_WatchServer interface {
	Send(*BroadcastWatchResponse) error
	Recv() (*BroadcastWatchRequest, error)
	grpc.ServerStream
}

type StreamingError 

type StreamingError struct {
	Code  StreamingCode `protobuf:"varint,1,opt,name=code,proto3,enum=milvus.proto.streaming.StreamingCode" json:"code,omitempty"`
	Cause string        `protobuf:"bytes,2,opt,name=cause,proto3" json:"cause,omitempty"`
	// contains filtered or unexported fields
}

StreamingError is the error type for log internal component.

func (*StreamingError) Descriptor deprecated 

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

Deprecated: Use StreamingError.ProtoReflect.Descriptor instead.

func (*StreamingError) GetCause 

func (x *StreamingError) GetCause() string

func (*StreamingError) GetCode 

func (x *StreamingError) GetCode() StreamingCode

func (*StreamingError) ProtoMessage 

func (*StreamingError) ProtoMessage()

func (*StreamingError) ProtoReflect 

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

func (*StreamingError) Reset 

func (x *StreamingError) Reset()

func (*StreamingError) String 

func (x *StreamingError) String() string

type StreamingNodeAssignment 

type StreamingNodeAssignment struct {
	Node     *StreamingNodeInfo `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Channels []*PChannelInfo    `protobuf:"bytes,2,rep,name=channels,proto3" json:"channels,omitempty"`
	// contains filtered or unexported fields
}

StreamingNodeAssignment is the assignment info of a streaming node.

func (*StreamingNodeAssignment) Descriptor deprecated 

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

Deprecated: Use StreamingNodeAssignment.ProtoReflect.Descriptor instead.

func (*StreamingNodeAssignment) GetChannels 

func (x *StreamingNodeAssignment) GetChannels() []*PChannelInfo

func (*StreamingNodeAssignment) GetNode 

func (x *StreamingNodeAssignment) GetNode() *StreamingNodeInfo

func (*StreamingNodeAssignment) ProtoMessage 

func (*StreamingNodeAssignment) ProtoMessage()

func (*StreamingNodeAssignment) ProtoReflect 

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

func (*StreamingNodeAssignment) Reset 

func (x *StreamingNodeAssignment) Reset()

func (*StreamingNodeAssignment) String 

func (x *StreamingNodeAssignment) String() string

type StreamingNodeBalanceAttributes 

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

func (*StreamingNodeBalanceAttributes) Descriptor deprecated 

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

Deprecated: Use StreamingNodeBalanceAttributes.ProtoReflect.Descriptor instead.

func (*StreamingNodeBalanceAttributes) ProtoMessage 

func (*StreamingNodeBalanceAttributes) ProtoMessage()

func (*StreamingNodeBalanceAttributes) ProtoReflect 

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

func (*StreamingNodeBalanceAttributes) Reset 

func (x *StreamingNodeBalanceAttributes) Reset()

func (*StreamingNodeBalanceAttributes) String 

func (x *StreamingNodeBalanceAttributes) String() string

type StreamingNodeHandlerServiceClient 

type StreamingNodeHandlerServiceClient interface {
	// Produce is a bi-directional streaming RPC to send messages to a channel.
	// All messages sent to a channel will be assigned a unique messageID.
	// The messageID is used to identify the message in the channel.
	// The messageID isn't promised to be monotonous increasing with the
	// sequence of responsing. Error: If channel isn't assign to this log node,
	// the RPC will return error CHANNEL_NOT_EXIST. If channel is moving away to
	// other log node, the RPC will return error CHANNEL_FENCED.
	Produce(ctx context.Context, opts ...grpc.CallOption) (StreamingNodeHandlerService_ProduceClient, error)
	// Consume is a server streaming RPC to receive messages from a channel.
	// All message after given startMessageID and excluding will be sent to the
	// client by stream. If no more message in the channel, the stream will be
	// blocked until new message coming. Error: If channel isn't assign to this
	// log node, the RPC will return error CHANNEL_NOT_EXIST. If channel is
	// moving away to other log node, the RPC will return error CHANNEL_FENCED.
	Consume(ctx context.Context, opts ...grpc.CallOption) (StreamingNodeHandlerService_ConsumeClient, error)
}

StreamingNodeHandlerServiceClient is the client API for StreamingNodeHandlerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamingNodeHandlerServiceClient 

func NewStreamingNodeHandlerServiceClient(cc grpc.ClientConnInterface) StreamingNodeHandlerServiceClient

type StreamingNodeHandlerServiceServer 

type StreamingNodeHandlerServiceServer interface {
	// Produce is a bi-directional streaming RPC to send messages to a channel.
	// All messages sent to a channel will be assigned a unique messageID.
	// The messageID is used to identify the message in the channel.
	// The messageID isn't promised to be monotonous increasing with the
	// sequence of responsing. Error: If channel isn't assign to this log node,
	// the RPC will return error CHANNEL_NOT_EXIST. If channel is moving away to
	// other log node, the RPC will return error CHANNEL_FENCED.
	Produce(StreamingNodeHandlerService_ProduceServer) error
	// Consume is a server streaming RPC to receive messages from a channel.
	// All message after given startMessageID and excluding will be sent to the
	// client by stream. If no more message in the channel, the stream will be
	// blocked until new message coming. Error: If channel isn't assign to this
	// log node, the RPC will return error CHANNEL_NOT_EXIST. If channel is
	// moving away to other log node, the RPC will return error CHANNEL_FENCED.
	Consume(StreamingNodeHandlerService_ConsumeServer) error
}

StreamingNodeHandlerServiceServer is the server API for StreamingNodeHandlerService service. All implementations should embed UnimplementedStreamingNodeHandlerServiceServer for forward compatibility

type StreamingNodeHandlerService_ConsumeClient 

type StreamingNodeHandlerService_ConsumeClient interface {
	Send(*ConsumeRequest) error
	Recv() (*ConsumeResponse, error)
	grpc.ClientStream
}

type StreamingNodeHandlerService_ConsumeServer 

type StreamingNodeHandlerService_ConsumeServer interface {
	Send(*ConsumeResponse) error
	Recv() (*ConsumeRequest, error)
	grpc.ServerStream
}

type StreamingNodeHandlerService_ProduceClient 

type StreamingNodeHandlerService_ProduceClient interface {
	Send(*ProduceRequest) error
	Recv() (*ProduceResponse, error)
	grpc.ClientStream
}

type StreamingNodeHandlerService_ProduceServer 

type StreamingNodeHandlerService_ProduceServer interface {
	Send(*ProduceResponse) error
	Recv() (*ProduceRequest, error)
	grpc.ServerStream
}

type StreamingNodeInfo 

type StreamingNodeInfo struct {
	ServerId int64  `protobuf:"varint,1,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	Address  string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

StreamingNodeInfo is the information of a streaming node.

func (*StreamingNodeInfo) Descriptor deprecated 

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

Deprecated: Use StreamingNodeInfo.ProtoReflect.Descriptor instead.

func (*StreamingNodeInfo) GetAddress 

func (x *StreamingNodeInfo) GetAddress() string

func (*StreamingNodeInfo) GetServerId 

func (x *StreamingNodeInfo) GetServerId() int64

func (*StreamingNodeInfo) ProtoMessage 

func (*StreamingNodeInfo) ProtoMessage()

func (*StreamingNodeInfo) ProtoReflect 

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

func (*StreamingNodeInfo) Reset 

func (x *StreamingNodeInfo) Reset()

func (*StreamingNodeInfo) String 

func (x *StreamingNodeInfo) String() string

type StreamingNodeManagerAssignRequest 

type StreamingNodeManagerAssignRequest struct {
	Pchannel *PChannelInfo `protobuf:"bytes,1,opt,name=pchannel,proto3" json:"pchannel,omitempty"`
	// contains filtered or unexported fields
}

StreamingManagerAssignRequest is the request message of Assign RPC.

func (*StreamingNodeManagerAssignRequest) Descriptor deprecated 

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

Deprecated: Use StreamingNodeManagerAssignRequest.ProtoReflect.Descriptor instead.

func (*StreamingNodeManagerAssignRequest) GetPchannel 

func (x *StreamingNodeManagerAssignRequest) GetPchannel() *PChannelInfo

func (*StreamingNodeManagerAssignRequest) ProtoMessage 

func (*StreamingNodeManagerAssignRequest) ProtoMessage()

func (*StreamingNodeManagerAssignRequest) ProtoReflect 

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

func (*StreamingNodeManagerAssignRequest) Reset 

func (x *StreamingNodeManagerAssignRequest) Reset()

func (*StreamingNodeManagerAssignRequest) String 

func (x *StreamingNodeManagerAssignRequest) String() string

type StreamingNodeManagerAssignResponse 

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

func (*StreamingNodeManagerAssignResponse) Descriptor deprecated 

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

Deprecated: Use StreamingNodeManagerAssignResponse.ProtoReflect.Descriptor instead.

func (*StreamingNodeManagerAssignResponse) ProtoMessage 

func (*StreamingNodeManagerAssignResponse) ProtoMessage()

func (*StreamingNodeManagerAssignResponse) ProtoReflect 

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

func (*StreamingNodeManagerAssignResponse) Reset 

func (x *StreamingNodeManagerAssignResponse) Reset()

func (*StreamingNodeManagerAssignResponse) String 

func (x *StreamingNodeManagerAssignResponse) String() string

type StreamingNodeManagerCollectStatusRequest 

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

func (*StreamingNodeManagerCollectStatusRequest) Descriptor deprecated 

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

Deprecated: Use StreamingNodeManagerCollectStatusRequest.ProtoReflect.Descriptor instead.

func (*StreamingNodeManagerCollectStatusRequest) ProtoMessage 

func (*StreamingNodeManagerCollectStatusRequest) ProtoMessage()

func (*StreamingNodeManagerCollectStatusRequest) ProtoReflect 

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

func (*StreamingNodeManagerCollectStatusRequest) Reset 

func (x *StreamingNodeManagerCollectStatusRequest) Reset()

func (*StreamingNodeManagerCollectStatusRequest) String 

func (x *StreamingNodeManagerCollectStatusRequest) String() string

type StreamingNodeManagerCollectStatusResponse 

type StreamingNodeManagerCollectStatusResponse struct {
	BalanceAttributes *StreamingNodeBalanceAttributes `protobuf:"bytes,1,opt,name=balance_attributes,json=balanceAttributes,proto3" json:"balance_attributes,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamingNodeManagerCollectStatusResponse) Descriptor deprecated 

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

Deprecated: Use StreamingNodeManagerCollectStatusResponse.ProtoReflect.Descriptor instead.

func (*StreamingNodeManagerCollectStatusResponse) GetBalanceAttributes 

func (x *StreamingNodeManagerCollectStatusResponse) GetBalanceAttributes() *StreamingNodeBalanceAttributes

func (*StreamingNodeManagerCollectStatusResponse) ProtoMessage 

func (*StreamingNodeManagerCollectStatusResponse) ProtoMessage()

func (*StreamingNodeManagerCollectStatusResponse) ProtoReflect 

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

func (*StreamingNodeManagerCollectStatusResponse) Reset 

func (x *StreamingNodeManagerCollectStatusResponse) Reset()

func (*StreamingNodeManagerCollectStatusResponse) String 

func (x *StreamingNodeManagerCollectStatusResponse) String() string

type StreamingNodeManagerRemoveRequest 

type StreamingNodeManagerRemoveRequest struct {
	Pchannel *PChannelInfo `protobuf:"bytes,1,opt,name=pchannel,proto3" json:"pchannel,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamingNodeManagerRemoveRequest) Descriptor deprecated 

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

Deprecated: Use StreamingNodeManagerRemoveRequest.ProtoReflect.Descriptor instead.

func (*StreamingNodeManagerRemoveRequest) GetPchannel 

func (x *StreamingNodeManagerRemoveRequest) GetPchannel() *PChannelInfo

func (*StreamingNodeManagerRemoveRequest) ProtoMessage 

func (*StreamingNodeManagerRemoveRequest) ProtoMessage()

func (*StreamingNodeManagerRemoveRequest) ProtoReflect 

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

func (*StreamingNodeManagerRemoveRequest) Reset 

func (x *StreamingNodeManagerRemoveRequest) Reset()

func (*StreamingNodeManagerRemoveRequest) String 

func (x *StreamingNodeManagerRemoveRequest) String() string

type StreamingNodeManagerRemoveResponse 

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

func (*StreamingNodeManagerRemoveResponse) Descriptor deprecated 

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

Deprecated: Use StreamingNodeManagerRemoveResponse.ProtoReflect.Descriptor instead.

func (*StreamingNodeManagerRemoveResponse) ProtoMessage 

func (*StreamingNodeManagerRemoveResponse) ProtoMessage()

func (*StreamingNodeManagerRemoveResponse) ProtoReflect 

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

func (*StreamingNodeManagerRemoveResponse) Reset 

func (x *StreamingNodeManagerRemoveResponse) Reset()

func (*StreamingNodeManagerRemoveResponse) String 

func (x *StreamingNodeManagerRemoveResponse) String() string

type StreamingNodeManagerServiceClient 

type StreamingNodeManagerServiceClient interface {
	// Assign is a unary RPC to assign a channel on a log node.
	// Block until the channel assignd is ready to read or write on the log
	// node. Error: If the channel already exists, return error with code
	// CHANNEL_EXIST.
	Assign(ctx context.Context, in *StreamingNodeManagerAssignRequest, opts ...grpc.CallOption) (*StreamingNodeManagerAssignResponse, error)
	// Remove is unary RPC to remove a channel on a log node.
	// Data of the channel on flying would be sent or flused as much as
	// possible. Block until the resource of channel is released on the log
	// node. New incoming request of handler of this channel will be rejected
	// with special error. Error: If the channel does not exist, return error
	// with code CHANNEL_NOT_EXIST.
	Remove(ctx context.Context, in *StreamingNodeManagerRemoveRequest, opts ...grpc.CallOption) (*StreamingNodeManagerRemoveResponse, error)
	// rpc CollectStatus() ...
	// CollectStatus is unary RPC to collect all avaliable channel info and load
	// balance info on a log node. Used to recover channel info on log coord,
	// collect balance info and health check.
	CollectStatus(ctx context.Context, in *StreamingNodeManagerCollectStatusRequest, opts ...grpc.CallOption) (*StreamingNodeManagerCollectStatusResponse, error)
}

StreamingNodeManagerServiceClient is the client API for StreamingNodeManagerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamingNodeManagerServiceClient 

func NewStreamingNodeManagerServiceClient(cc grpc.ClientConnInterface) StreamingNodeManagerServiceClient

type StreamingNodeManagerServiceServer 

type StreamingNodeManagerServiceServer interface {
	// Assign is a unary RPC to assign a channel on a log node.
	// Block until the channel assignd is ready to read or write on the log
	// node. Error: If the channel already exists, return error with code
	// CHANNEL_EXIST.
	Assign(context.Context, *StreamingNodeManagerAssignRequest) (*StreamingNodeManagerAssignResponse, error)
	// Remove is unary RPC to remove a channel on a log node.
	// Data of the channel on flying would be sent or flused as much as
	// possible. Block until the resource of channel is released on the log
	// node. New incoming request of handler of this channel will be rejected
	// with special error. Error: If the channel does not exist, return error
	// with code CHANNEL_NOT_EXIST.
	Remove(context.Context, *StreamingNodeManagerRemoveRequest) (*StreamingNodeManagerRemoveResponse, error)
	// rpc CollectStatus() ...
	// CollectStatus is unary RPC to collect all avaliable channel info and load
	// balance info on a log node. Used to recover channel info on log coord,
	// collect balance info and health check.
	CollectStatus(context.Context, *StreamingNodeManagerCollectStatusRequest) (*StreamingNodeManagerCollectStatusResponse, error)
}

StreamingNodeManagerServiceServer is the server API for StreamingNodeManagerService service. All implementations should embed UnimplementedStreamingNodeManagerServiceServer for forward compatibility

type StreamingNodeStateServiceClient 

type StreamingNodeStateServiceClient interface {
	GetComponentStates(ctx context.Context, in *milvuspb.GetComponentStatesRequest, opts ...grpc.CallOption) (*milvuspb.ComponentStates, error)
}

StreamingNodeStateServiceClient is the client API for StreamingNodeStateService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewStreamingNodeStateServiceClient 

func NewStreamingNodeStateServiceClient(cc grpc.ClientConnInterface) StreamingNodeStateServiceClient

type StreamingNodeStateServiceServer 

type StreamingNodeStateServiceServer interface {
	GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)
}

StreamingNodeStateServiceServer is the server API for StreamingNodeStateService service. All implementations should embed UnimplementedStreamingNodeStateServiceServer for forward compatibility

type UnimplementedStreamingCoordAssignmentServiceServer 

type UnimplementedStreamingCoordAssignmentServiceServer struct {
}

UnimplementedStreamingCoordAssignmentServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamingCoordAssignmentServiceServer) AssignmentDiscover 

func (UnimplementedStreamingCoordAssignmentServiceServer) AssignmentDiscover(StreamingCoordAssignmentService_AssignmentDiscoverServer) error

type UnimplementedStreamingCoordBroadcastServiceServer 

type UnimplementedStreamingCoordBroadcastServiceServer struct {
}

UnimplementedStreamingCoordBroadcastServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamingCoordBroadcastServiceServer) Ack 

func (UnimplementedStreamingCoordBroadcastServiceServer) Ack(context.Context, *BroadcastAckRequest) (*BroadcastAckResponse, error)

func (UnimplementedStreamingCoordBroadcastServiceServer) Broadcast 

func (UnimplementedStreamingCoordBroadcastServiceServer) Broadcast(context.Context, *BroadcastRequest) (*BroadcastResponse, error)

func (UnimplementedStreamingCoordBroadcastServiceServer) Watch 

func (UnimplementedStreamingCoordBroadcastServiceServer) Watch(StreamingCoordBroadcastService_WatchServer) error

type UnimplementedStreamingNodeHandlerServiceServer 

type UnimplementedStreamingNodeHandlerServiceServer struct {
}

UnimplementedStreamingNodeHandlerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamingNodeHandlerServiceServer) Consume 

func (UnimplementedStreamingNodeHandlerServiceServer) Consume(StreamingNodeHandlerService_ConsumeServer) error

func (UnimplementedStreamingNodeHandlerServiceServer) Produce 

func (UnimplementedStreamingNodeHandlerServiceServer) Produce(StreamingNodeHandlerService_ProduceServer) error

type UnimplementedStreamingNodeManagerServiceServer 

type UnimplementedStreamingNodeManagerServiceServer struct {
}

UnimplementedStreamingNodeManagerServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamingNodeManagerServiceServer) Assign 

func (UnimplementedStreamingNodeManagerServiceServer) Assign(context.Context, *StreamingNodeManagerAssignRequest) (*StreamingNodeManagerAssignResponse, error)

func (UnimplementedStreamingNodeManagerServiceServer) CollectStatus 

func (UnimplementedStreamingNodeManagerServiceServer) CollectStatus(context.Context, *StreamingNodeManagerCollectStatusRequest) (*StreamingNodeManagerCollectStatusResponse, error)

func (UnimplementedStreamingNodeManagerServiceServer) Remove 

func (UnimplementedStreamingNodeManagerServiceServer) Remove(context.Context, *StreamingNodeManagerRemoveRequest) (*StreamingNodeManagerRemoveResponse, error)

type UnimplementedStreamingNodeStateServiceServer 

type UnimplementedStreamingNodeStateServiceServer struct {
}

UnimplementedStreamingNodeStateServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedStreamingNodeStateServiceServer) GetComponentStates 

func (UnimplementedStreamingNodeStateServiceServer) GetComponentStates(context.Context, *milvuspb.GetComponentStatesRequest) (*milvuspb.ComponentStates, error)

type UnsafeStreamingCoordAssignmentServiceServer 

type UnsafeStreamingCoordAssignmentServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamingCoordAssignmentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamingCoordAssignmentServiceServer will result in compilation errors.

type UnsafeStreamingCoordBroadcastServiceServer 

type UnsafeStreamingCoordBroadcastServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamingCoordBroadcastServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamingCoordBroadcastServiceServer will result in compilation errors.

type UnsafeStreamingNodeHandlerServiceServer 

type UnsafeStreamingNodeHandlerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamingNodeHandlerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamingNodeHandlerServiceServer will result in compilation errors.

type UnsafeStreamingNodeManagerServiceServer 

type UnsafeStreamingNodeManagerServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamingNodeManagerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamingNodeManagerServiceServer will result in compilation errors.

type UnsafeStreamingNodeStateServiceServer 

type UnsafeStreamingNodeStateServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeStreamingNodeStateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StreamingNodeStateServiceServer will result in compilation errors.

type VersionPair 

type VersionPair struct {
	Global int64 `protobuf:"varint,1,opt,name=global,proto3" json:"global,omitempty"`
	Local  int64 `protobuf:"varint,2,opt,name=local,proto3" json:"local,omitempty"`
	// contains filtered or unexported fields
}

VersionPair is the version pair of global and local.

func (*VersionPair) Descriptor deprecated 

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

Deprecated: Use VersionPair.ProtoReflect.Descriptor instead.

func (*VersionPair) GetGlobal 

func (x *VersionPair) GetGlobal() int64

func (*VersionPair) GetLocal 

func (x *VersionPair) GetLocal() int64

func (*VersionPair) ProtoMessage 

func (*VersionPair) ProtoMessage()

func (*VersionPair) ProtoReflect 

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

func (*VersionPair) Reset 

func (x *VersionPair) Reset()

func (*VersionPair) String 

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