segment

package
v0.0.0-...-1334a7b Latest Latest
Warning

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

 Go to latest Published: Dec 21, 2023 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	XVanusBlockOffset = "xvanusblockoffset"
	XVanusLogOffset   = "xvanuslogoffset"
	// XVanusStime is an attribute of CloudEvent whose value is a millisecond timestamp when writing the event to
	// Block.
	XVanusStime = "xvanusstime"
)
View Source 
const (
	SegmentServer_Start_FullMethodName               = "/vanus.core.segment.SegmentServer/Start"
	SegmentServer_Stop_FullMethodName                = "/vanus.core.segment.SegmentServer/Stop"
	SegmentServer_CreateBlock_FullMethodName         = "/vanus.core.segment.SegmentServer/CreateBlock"
	SegmentServer_RemoveBlock_FullMethodName         = "/vanus.core.segment.SegmentServer/RemoveBlock"
	SegmentServer_DescribeBlock_FullMethodName       = "/vanus.core.segment.SegmentServer/DescribeBlock"
	SegmentServer_ActivateSegment_FullMethodName     = "/vanus.core.segment.SegmentServer/ActivateSegment"
	SegmentServer_InactivateSegment_FullMethodName   = "/vanus.core.segment.SegmentServer/InactivateSegment"
	SegmentServer_AppendToBlock_FullMethodName       = "/vanus.core.segment.SegmentServer/AppendToBlock"
	SegmentServer_ReadFromBlock_FullMethodName       = "/vanus.core.segment.SegmentServer/ReadFromBlock"
	SegmentServer_LookupOffsetInBlock_FullMethodName = "/vanus.core.segment.SegmentServer/LookupOffsetInBlock"
	SegmentServer_Status_FullMethodName              = "/vanus.core.segment.SegmentServer/Status"
)

Variables

View Source 
var File_vanus_core_segment_segment_proto protoreflect.FileDescriptor
View Source 
var SegmentServer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "vanus.core.segment.SegmentServer",
	HandlerType: (*SegmentServerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Start",
			Handler:    _SegmentServer_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _SegmentServer_Stop_Handler,
		},
		{
			MethodName: "CreateBlock",
			Handler:    _SegmentServer_CreateBlock_Handler,
		},
		{
			MethodName: "RemoveBlock",
			Handler:    _SegmentServer_RemoveBlock_Handler,
		},
		{
			MethodName: "DescribeBlock",
			Handler:    _SegmentServer_DescribeBlock_Handler,
		},
		{
			MethodName: "ActivateSegment",
			Handler:    _SegmentServer_ActivateSegment_Handler,
		},
		{
			MethodName: "InactivateSegment",
			Handler:    _SegmentServer_InactivateSegment_Handler,
		},
		{
			MethodName: "AppendToBlock",
			Handler:    _SegmentServer_AppendToBlock_Handler,
		},
		{
			MethodName: "ReadFromBlock",
			Handler:    _SegmentServer_ReadFromBlock_Handler,
		},
		{
			MethodName: "LookupOffsetInBlock",
			Handler:    _SegmentServer_LookupOffsetInBlock_Handler,
		},
		{
			MethodName: "Status",
			Handler:    _SegmentServer_Status_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "vanus/core/segment/segment.proto",
}

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

Functions

func RegisterSegmentServerServer 

func RegisterSegmentServerServer(s grpc.ServiceRegistrar, srv SegmentServerServer)

Types

type ActivateSegmentRequest 

type ActivateSegmentRequest struct {
	EventlogId     uint64 `protobuf:"varint,1,opt,name=eventlog_id,json=eventlogId,proto3" json:"eventlog_id,omitempty"`
	ReplicaGroupId uint64 `protobuf:"varint,2,opt,name=replica_group_id,json=replicaGroupId,proto3" json:"replica_group_id,omitempty"`
	// block ID and its server endpoint.
	Replicas map[uint64]string `` /* 158-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ActivateSegmentRequest) Descriptor deprecated 

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

Deprecated: Use ActivateSegmentRequest.ProtoReflect.Descriptor instead.

func (*ActivateSegmentRequest) GetEventlogId 

func (x *ActivateSegmentRequest) GetEventlogId() uint64

func (*ActivateSegmentRequest) GetReplicaGroupId 

func (x *ActivateSegmentRequest) GetReplicaGroupId() uint64

func (*ActivateSegmentRequest) GetReplicas 

func (x *ActivateSegmentRequest) GetReplicas() map[uint64]string

func (*ActivateSegmentRequest) ProtoMessage 

func (*ActivateSegmentRequest) ProtoMessage()

func (*ActivateSegmentRequest) ProtoReflect 

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

func (*ActivateSegmentRequest) Reset 

func (x *ActivateSegmentRequest) Reset()

func (*ActivateSegmentRequest) String 

func (x *ActivateSegmentRequest) String() string

type ActivateSegmentResponse 

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

func (*ActivateSegmentResponse) Descriptor deprecated 

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

Deprecated: Use ActivateSegmentResponse.ProtoReflect.Descriptor instead.

func (*ActivateSegmentResponse) ProtoMessage 

func (*ActivateSegmentResponse) ProtoMessage()

func (*ActivateSegmentResponse) ProtoReflect 

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

func (*ActivateSegmentResponse) Reset 

func (x *ActivateSegmentResponse) Reset()

func (*ActivateSegmentResponse) String 

func (x *ActivateSegmentResponse) String() string

type AppendToBlockRequest 

type AppendToBlockRequest struct {
	BlockId uint64                       `protobuf:"varint,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	Events  *cloudevents.CloudEventBatch `protobuf:"bytes,2,opt,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendToBlockRequest) Descriptor deprecated 

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

Deprecated: Use AppendToBlockRequest.ProtoReflect.Descriptor instead.

func (*AppendToBlockRequest) GetBlockId 

func (x *AppendToBlockRequest) GetBlockId() uint64

func (*AppendToBlockRequest) GetEvents 

func (x *AppendToBlockRequest) GetEvents() *cloudevents.CloudEventBatch

func (*AppendToBlockRequest) ProtoMessage 

func (*AppendToBlockRequest) ProtoMessage()

func (*AppendToBlockRequest) ProtoReflect 

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

func (*AppendToBlockRequest) Reset 

func (x *AppendToBlockRequest) Reset()

func (*AppendToBlockRequest) String 

func (x *AppendToBlockRequest) String() string

type AppendToBlockResponse 

type AppendToBlockResponse struct {
	Offsets []int64 `protobuf:"varint,1,rep,packed,name=offsets,proto3" json:"offsets,omitempty"`
	// contains filtered or unexported fields
}

func (*AppendToBlockResponse) Descriptor deprecated 

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

Deprecated: Use AppendToBlockResponse.ProtoReflect.Descriptor instead.

func (*AppendToBlockResponse) GetOffsets 

func (x *AppendToBlockResponse) GetOffsets() []int64

func (*AppendToBlockResponse) ProtoMessage 

func (*AppendToBlockResponse) ProtoMessage()

func (*AppendToBlockResponse) ProtoReflect 

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

func (*AppendToBlockResponse) Reset 

func (x *AppendToBlockResponse) Reset()

func (*AppendToBlockResponse) String 

func (x *AppendToBlockResponse) String() string

type CreateBlockRequest 

type CreateBlockRequest struct {
	Id   uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Size int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBlockRequest) Descriptor deprecated 

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

Deprecated: Use CreateBlockRequest.ProtoReflect.Descriptor instead.

func (*CreateBlockRequest) GetId 

func (x *CreateBlockRequest) GetId() uint64

func (*CreateBlockRequest) GetSize 

func (x *CreateBlockRequest) GetSize() int64

func (*CreateBlockRequest) ProtoMessage 

func (*CreateBlockRequest) ProtoMessage()

func (*CreateBlockRequest) ProtoReflect 

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

func (*CreateBlockRequest) Reset 

func (x *CreateBlockRequest) Reset()

func (*CreateBlockRequest) String 

func (x *CreateBlockRequest) String() string

type DescribeBlockRequest 

type DescribeBlockRequest struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeBlockRequest) Descriptor deprecated 

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

Deprecated: Use DescribeBlockRequest.ProtoReflect.Descriptor instead.

func (*DescribeBlockRequest) GetId 

func (x *DescribeBlockRequest) GetId() uint64

func (*DescribeBlockRequest) ProtoMessage 

func (*DescribeBlockRequest) ProtoMessage()

func (*DescribeBlockRequest) ProtoReflect 

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

func (*DescribeBlockRequest) Reset 

func (x *DescribeBlockRequest) Reset()

func (*DescribeBlockRequest) String 

func (x *DescribeBlockRequest) String() string

type DescribeBlockResponse 

type DescribeBlockResponse struct {
	Info *meta.SegmentHealthInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*DescribeBlockResponse) Descriptor deprecated 

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

Deprecated: Use DescribeBlockResponse.ProtoReflect.Descriptor instead.

func (*DescribeBlockResponse) GetInfo 

func (x *DescribeBlockResponse) GetInfo() *meta.SegmentHealthInfo

func (*DescribeBlockResponse) ProtoMessage 

func (*DescribeBlockResponse) ProtoMessage()

func (*DescribeBlockResponse) ProtoReflect 

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

func (*DescribeBlockResponse) Reset 

func (x *DescribeBlockResponse) Reset()

func (*DescribeBlockResponse) String 

func (x *DescribeBlockResponse) String() string

type InactivateSegmentRequest 

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

func (*InactivateSegmentRequest) Descriptor deprecated 

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

Deprecated: Use InactivateSegmentRequest.ProtoReflect.Descriptor instead.

func (*InactivateSegmentRequest) ProtoMessage 

func (*InactivateSegmentRequest) ProtoMessage()

func (*InactivateSegmentRequest) ProtoReflect 

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

func (*InactivateSegmentRequest) Reset 

func (x *InactivateSegmentRequest) Reset()

func (*InactivateSegmentRequest) String 

func (x *InactivateSegmentRequest) String() string

type InactivateSegmentResponse 

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

func (*InactivateSegmentResponse) Descriptor deprecated 

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

Deprecated: Use InactivateSegmentResponse.ProtoReflect.Descriptor instead.

func (*InactivateSegmentResponse) ProtoMessage 

func (*InactivateSegmentResponse) ProtoMessage()

func (*InactivateSegmentResponse) ProtoReflect 

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

func (*InactivateSegmentResponse) Reset 

func (x *InactivateSegmentResponse) Reset()

func (*InactivateSegmentResponse) String 

func (x *InactivateSegmentResponse) String() string

type LookupOffsetInBlockRequest 

type LookupOffsetInBlockRequest struct {
	BlockId uint64 `protobuf:"varint,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	Stime   int64  `protobuf:"varint,2,opt,name=stime,proto3" json:"stime,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupOffsetInBlockRequest) Descriptor deprecated 

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

Deprecated: Use LookupOffsetInBlockRequest.ProtoReflect.Descriptor instead.

func (*LookupOffsetInBlockRequest) GetBlockId 

func (x *LookupOffsetInBlockRequest) GetBlockId() uint64

func (*LookupOffsetInBlockRequest) GetStime 

func (x *LookupOffsetInBlockRequest) GetStime() int64

func (*LookupOffsetInBlockRequest) ProtoMessage 

func (*LookupOffsetInBlockRequest) ProtoMessage()

func (*LookupOffsetInBlockRequest) ProtoReflect 

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

func (*LookupOffsetInBlockRequest) Reset 

func (x *LookupOffsetInBlockRequest) Reset()

func (*LookupOffsetInBlockRequest) String 

func (x *LookupOffsetInBlockRequest) String() string

type LookupOffsetInBlockResponse 

type LookupOffsetInBlockResponse struct {
	Offset int64 `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*LookupOffsetInBlockResponse) Descriptor deprecated 

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

Deprecated: Use LookupOffsetInBlockResponse.ProtoReflect.Descriptor instead.

func (*LookupOffsetInBlockResponse) GetOffset 

func (x *LookupOffsetInBlockResponse) GetOffset() int64

func (*LookupOffsetInBlockResponse) ProtoMessage 

func (*LookupOffsetInBlockResponse) ProtoMessage()

func (*LookupOffsetInBlockResponse) ProtoReflect 

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

func (*LookupOffsetInBlockResponse) Reset 

func (x *LookupOffsetInBlockResponse) Reset()

func (*LookupOffsetInBlockResponse) String 

func (x *LookupOffsetInBlockResponse) String() string

type MockSegmentServerClient 

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

MockSegmentServerClient is a mock of SegmentServerClient interface.

func NewMockSegmentServerClient 

func NewMockSegmentServerClient(ctrl *gomock.Controller) *MockSegmentServerClient

NewMockSegmentServerClient creates a new mock instance.

func (*MockSegmentServerClient) ActivateSegment 

func (m *MockSegmentServerClient) ActivateSegment(ctx context.Context, in *ActivateSegmentRequest, opts ...grpc.CallOption) (*ActivateSegmentResponse, error)

ActivateSegment mocks base method.

func (*MockSegmentServerClient) AppendToBlock 

func (m *MockSegmentServerClient) AppendToBlock(ctx context.Context, in *AppendToBlockRequest, opts ...grpc.CallOption) (*AppendToBlockResponse, error)

AppendToBlock mocks base method.

func (*MockSegmentServerClient) CreateBlock 

func (m *MockSegmentServerClient) CreateBlock(ctx context.Context, in *CreateBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

CreateBlock mocks base method.

func (*MockSegmentServerClient) DescribeBlock 

func (m *MockSegmentServerClient) DescribeBlock(ctx context.Context, in *DescribeBlockRequest, opts ...grpc.CallOption) (*DescribeBlockResponse, error)

DescribeBlock mocks base method.

func (*MockSegmentServerClient) EXPECT 

func (m *MockSegmentServerClient) EXPECT() *MockSegmentServerClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSegmentServerClient) InactivateSegment 

func (m *MockSegmentServerClient) InactivateSegment(ctx context.Context, in *InactivateSegmentRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

InactivateSegment mocks base method.

func (*MockSegmentServerClient) LookupOffsetInBlock 

func (m *MockSegmentServerClient) LookupOffsetInBlock(ctx context.Context, in *LookupOffsetInBlockRequest, opts ...grpc.CallOption) (*LookupOffsetInBlockResponse, error)

LookupOffsetInBlock mocks base method.

func (*MockSegmentServerClient) ReadFromBlock 

func (m *MockSegmentServerClient) ReadFromBlock(ctx context.Context, in *ReadFromBlockRequest, opts ...grpc.CallOption) (*ReadFromBlockResponse, error)

ReadFromBlock mocks base method.

func (*MockSegmentServerClient) RemoveBlock 

func (m *MockSegmentServerClient) RemoveBlock(ctx context.Context, in *RemoveBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

RemoveBlock mocks base method.

func (*MockSegmentServerClient) Start 

func (m *MockSegmentServerClient) Start(ctx context.Context, in *StartSegmentServerRequest, opts ...grpc.CallOption) (*StartSegmentServerResponse, error)

Start mocks base method.

func (*MockSegmentServerClient) Status 

func (m *MockSegmentServerClient) Status(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*StatusResponse, error)

Status mocks base method.

func (*MockSegmentServerClient) Stop 

func (m *MockSegmentServerClient) Stop(ctx context.Context, in *StopSegmentServerRequest, opts ...grpc.CallOption) (*StopSegmentServerResponse, error)

Stop mocks base method.

type MockSegmentServerClientMockRecorder 

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

MockSegmentServerClientMockRecorder is the mock recorder for MockSegmentServerClient.

func (*MockSegmentServerClientMockRecorder) ActivateSegment 

func (mr *MockSegmentServerClientMockRecorder) ActivateSegment(ctx, in interface{}, opts ...interface{}) *gomock.Call

ActivateSegment indicates an expected call of ActivateSegment.

func (*MockSegmentServerClientMockRecorder) AppendToBlock 

func (mr *MockSegmentServerClientMockRecorder) AppendToBlock(ctx, in interface{}, opts ...interface{}) *gomock.Call

AppendToBlock indicates an expected call of AppendToBlock.

func (*MockSegmentServerClientMockRecorder) CreateBlock 

func (mr *MockSegmentServerClientMockRecorder) CreateBlock(ctx, in interface{}, opts ...interface{}) *gomock.Call

CreateBlock indicates an expected call of CreateBlock.

func (*MockSegmentServerClientMockRecorder) DescribeBlock 

func (mr *MockSegmentServerClientMockRecorder) DescribeBlock(ctx, in interface{}, opts ...interface{}) *gomock.Call

DescribeBlock indicates an expected call of DescribeBlock.

func (*MockSegmentServerClientMockRecorder) InactivateSegment 

func (mr *MockSegmentServerClientMockRecorder) InactivateSegment(ctx, in interface{}, opts ...interface{}) *gomock.Call

InactivateSegment indicates an expected call of InactivateSegment.

func (*MockSegmentServerClientMockRecorder) LookupOffsetInBlock 

func (mr *MockSegmentServerClientMockRecorder) LookupOffsetInBlock(ctx, in interface{}, opts ...interface{}) *gomock.Call

LookupOffsetInBlock indicates an expected call of LookupOffsetInBlock.

func (*MockSegmentServerClientMockRecorder) ReadFromBlock 

func (mr *MockSegmentServerClientMockRecorder) ReadFromBlock(ctx, in interface{}, opts ...interface{}) *gomock.Call

ReadFromBlock indicates an expected call of ReadFromBlock.

func (*MockSegmentServerClientMockRecorder) RemoveBlock 

func (mr *MockSegmentServerClientMockRecorder) RemoveBlock(ctx, in interface{}, opts ...interface{}) *gomock.Call

RemoveBlock indicates an expected call of RemoveBlock.

func (*MockSegmentServerClientMockRecorder) Start 

func (mr *MockSegmentServerClientMockRecorder) Start(ctx, in interface{}, opts ...interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockSegmentServerClientMockRecorder) Status 

func (mr *MockSegmentServerClientMockRecorder) Status(ctx, in interface{}, opts ...interface{}) *gomock.Call

Status indicates an expected call of Status.

func (*MockSegmentServerClientMockRecorder) Stop 

func (mr *MockSegmentServerClientMockRecorder) Stop(ctx, in interface{}, opts ...interface{}) *gomock.Call

Stop indicates an expected call of Stop.

type MockSegmentServerServer 

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

MockSegmentServerServer is a mock of SegmentServerServer interface.

func NewMockSegmentServerServer 

func NewMockSegmentServerServer(ctrl *gomock.Controller) *MockSegmentServerServer

NewMockSegmentServerServer creates a new mock instance.

func (*MockSegmentServerServer) ActivateSegment 

func (m *MockSegmentServerServer) ActivateSegment(ctx context.Context, in *ActivateSegmentRequest) (*ActivateSegmentResponse, error)

ActivateSegment mocks base method.

func (*MockSegmentServerServer) AppendToBlock 

func (m *MockSegmentServerServer) AppendToBlock(ctx context.Context, in *AppendToBlockRequest) (*AppendToBlockResponse, error)

AppendToBlock mocks base method.

func (*MockSegmentServerServer) CreateBlock 

func (m *MockSegmentServerServer) CreateBlock(ctx context.Context, in *CreateBlockRequest) (*emptypb.Empty, error)

CreateBlock mocks base method.

func (*MockSegmentServerServer) DescribeBlock 

func (m *MockSegmentServerServer) DescribeBlock(ctx context.Context, in *DescribeBlockRequest) (*DescribeBlockResponse, error)

DescribeBlock mocks base method.

func (*MockSegmentServerServer) EXPECT 

func (m *MockSegmentServerServer) EXPECT() *MockSegmentServerServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockSegmentServerServer) InactivateSegment 

func (m *MockSegmentServerServer) InactivateSegment(ctx context.Context, in *InactivateSegmentRequest) (*emptypb.Empty, error)

InactivateSegment mocks base method.

func (*MockSegmentServerServer) LookupOffsetInBlock 

func (m *MockSegmentServerServer) LookupOffsetInBlock(ctx context.Context, in *LookupOffsetInBlockRequest) (*LookupOffsetInBlockResponse, error)

LookupOffsetInBlock mocks base method.

func (*MockSegmentServerServer) ReadFromBlock 

func (m *MockSegmentServerServer) ReadFromBlock(ctx context.Context, in *ReadFromBlockRequest) (*ReadFromBlockResponse, error)

ReadFromBlock mocks base method.

func (*MockSegmentServerServer) RemoveBlock 

func (m *MockSegmentServerServer) RemoveBlock(ctx context.Context, in *RemoveBlockRequest) (*emptypb.Empty, error)

RemoveBlock mocks base method.

func (*MockSegmentServerServer) Start 

func (m *MockSegmentServerServer) Start(ctx context.Context, in *StartSegmentServerRequest) (*StartSegmentServerResponse, error)

Start mocks base method.

func (*MockSegmentServerServer) Status 

func (m *MockSegmentServerServer) Status(ctx context.Context, in *emptypb.Empty) (*StatusResponse, error)

Status mocks base method.

func (*MockSegmentServerServer) Stop 

func (m *MockSegmentServerServer) Stop(ctx context.Context, in *StopSegmentServerRequest) (*StopSegmentServerResponse, error)

Stop mocks base method.

type MockSegmentServerServerMockRecorder 

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

MockSegmentServerServerMockRecorder is the mock recorder for MockSegmentServerServer.

func (*MockSegmentServerServerMockRecorder) ActivateSegment 

func (mr *MockSegmentServerServerMockRecorder) ActivateSegment(ctx, in interface{}) *gomock.Call

ActivateSegment indicates an expected call of ActivateSegment.

func (*MockSegmentServerServerMockRecorder) AppendToBlock 

func (mr *MockSegmentServerServerMockRecorder) AppendToBlock(ctx, in interface{}) *gomock.Call

AppendToBlock indicates an expected call of AppendToBlock.

func (*MockSegmentServerServerMockRecorder) CreateBlock 

func (mr *MockSegmentServerServerMockRecorder) CreateBlock(ctx, in interface{}) *gomock.Call

CreateBlock indicates an expected call of CreateBlock.

func (*MockSegmentServerServerMockRecorder) DescribeBlock 

func (mr *MockSegmentServerServerMockRecorder) DescribeBlock(ctx, in interface{}) *gomock.Call

DescribeBlock indicates an expected call of DescribeBlock.

func (*MockSegmentServerServerMockRecorder) InactivateSegment 

func (mr *MockSegmentServerServerMockRecorder) InactivateSegment(ctx, in interface{}) *gomock.Call

InactivateSegment indicates an expected call of InactivateSegment.

func (*MockSegmentServerServerMockRecorder) LookupOffsetInBlock 

func (mr *MockSegmentServerServerMockRecorder) LookupOffsetInBlock(ctx, in interface{}) *gomock.Call

LookupOffsetInBlock indicates an expected call of LookupOffsetInBlock.

func (*MockSegmentServerServerMockRecorder) ReadFromBlock 

func (mr *MockSegmentServerServerMockRecorder) ReadFromBlock(ctx, in interface{}) *gomock.Call

ReadFromBlock indicates an expected call of ReadFromBlock.

func (*MockSegmentServerServerMockRecorder) RemoveBlock 

func (mr *MockSegmentServerServerMockRecorder) RemoveBlock(ctx, in interface{}) *gomock.Call

RemoveBlock indicates an expected call of RemoveBlock.

func (*MockSegmentServerServerMockRecorder) Start 

func (mr *MockSegmentServerServerMockRecorder) Start(ctx, in interface{}) *gomock.Call

Start indicates an expected call of Start.

func (*MockSegmentServerServerMockRecorder) Status 

func (mr *MockSegmentServerServerMockRecorder) Status(ctx, in interface{}) *gomock.Call

Status indicates an expected call of Status.

func (*MockSegmentServerServerMockRecorder) Stop 

func (mr *MockSegmentServerServerMockRecorder) Stop(ctx, in interface{}) *gomock.Call

Stop indicates an expected call of Stop.

type ReadFromBlockRequest 

type ReadFromBlockRequest struct {
	BlockId uint64 `protobuf:"varint,1,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
	Offset  int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Number  int64  `protobuf:"varint,3,opt,name=number,proto3" json:"number,omitempty"`
	// polling timeout in milliseconds, 0 is disable.
	PollingTimeout uint32 `protobuf:"varint,4,opt,name=polling_timeout,json=pollingTimeout,proto3" json:"polling_timeout,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadFromBlockRequest) Descriptor deprecated 

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

Deprecated: Use ReadFromBlockRequest.ProtoReflect.Descriptor instead.

func (*ReadFromBlockRequest) GetBlockId 

func (x *ReadFromBlockRequest) GetBlockId() uint64

func (*ReadFromBlockRequest) GetNumber 

func (x *ReadFromBlockRequest) GetNumber() int64

func (*ReadFromBlockRequest) GetOffset 

func (x *ReadFromBlockRequest) GetOffset() int64

func (*ReadFromBlockRequest) GetPollingTimeout 

func (x *ReadFromBlockRequest) GetPollingTimeout() uint32

func (*ReadFromBlockRequest) ProtoMessage 

func (*ReadFromBlockRequest) ProtoMessage()

func (*ReadFromBlockRequest) ProtoReflect 

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

func (*ReadFromBlockRequest) Reset 

func (x *ReadFromBlockRequest) Reset()

func (*ReadFromBlockRequest) String 

func (x *ReadFromBlockRequest) String() string

type ReadFromBlockResponse 

type ReadFromBlockResponse struct {
	Events *cloudevents.CloudEventBatch `protobuf:"bytes,1,opt,name=events,proto3" json:"events,omitempty"`
	// Don't use this now, just used to optimize cpu overhead of SegmentServer in
	// the future for backward compatibility
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadFromBlockResponse) Descriptor deprecated 

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

Deprecated: Use ReadFromBlockResponse.ProtoReflect.Descriptor instead.

func (*ReadFromBlockResponse) GetEvents 

func (x *ReadFromBlockResponse) GetEvents() *cloudevents.CloudEventBatch

func (*ReadFromBlockResponse) GetPayload 

func (x *ReadFromBlockResponse) GetPayload() []byte

func (*ReadFromBlockResponse) ProtoMessage 

func (*ReadFromBlockResponse) ProtoMessage()

func (*ReadFromBlockResponse) ProtoReflect 

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

func (*ReadFromBlockResponse) Reset 

func (x *ReadFromBlockResponse) Reset()

func (*ReadFromBlockResponse) String 

func (x *ReadFromBlockResponse) String() string

type RemoveBlockRequest 

type RemoveBlockRequest struct {
	Id uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveBlockRequest) Descriptor deprecated 

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

Deprecated: Use RemoveBlockRequest.ProtoReflect.Descriptor instead.

func (*RemoveBlockRequest) GetId 

func (x *RemoveBlockRequest) GetId() uint64

func (*RemoveBlockRequest) ProtoMessage 

func (*RemoveBlockRequest) ProtoMessage()

func (*RemoveBlockRequest) ProtoReflect 

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

func (*RemoveBlockRequest) Reset 

func (x *RemoveBlockRequest) Reset()

func (*RemoveBlockRequest) String 

func (x *RemoveBlockRequest) String() string

type SegmentServerClient 

type SegmentServerClient interface {
	Start(ctx context.Context, in *StartSegmentServerRequest, opts ...grpc.CallOption) (*StartSegmentServerResponse, error)
	Stop(ctx context.Context, in *StopSegmentServerRequest, opts ...grpc.CallOption) (*StopSegmentServerResponse, error)
	CreateBlock(ctx context.Context, in *CreateBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	RemoveBlock(ctx context.Context, in *RemoveBlockRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	DescribeBlock(ctx context.Context, in *DescribeBlockRequest, opts ...grpc.CallOption) (*DescribeBlockResponse, error)
	ActivateSegment(ctx context.Context, in *ActivateSegmentRequest, opts ...grpc.CallOption) (*ActivateSegmentResponse, error)
	InactivateSegment(ctx context.Context, in *InactivateSegmentRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
	AppendToBlock(ctx context.Context, in *AppendToBlockRequest, opts ...grpc.CallOption) (*AppendToBlockResponse, error)
	ReadFromBlock(ctx context.Context, in *ReadFromBlockRequest, opts ...grpc.CallOption) (*ReadFromBlockResponse, error)
	LookupOffsetInBlock(ctx context.Context, in *LookupOffsetInBlockRequest, opts ...grpc.CallOption) (*LookupOffsetInBlockResponse, error)
	Status(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*StatusResponse, error)
}

SegmentServerClient is the client API for SegmentServer 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 NewSegmentServerClient 

func NewSegmentServerClient(cc grpc.ClientConnInterface) SegmentServerClient

type SegmentServerServer 

type SegmentServerServer interface {
	Start(context.Context, *StartSegmentServerRequest) (*StartSegmentServerResponse, error)
	Stop(context.Context, *StopSegmentServerRequest) (*StopSegmentServerResponse, error)
	CreateBlock(context.Context, *CreateBlockRequest) (*emptypb.Empty, error)
	RemoveBlock(context.Context, *RemoveBlockRequest) (*emptypb.Empty, error)
	DescribeBlock(context.Context, *DescribeBlockRequest) (*DescribeBlockResponse, error)
	ActivateSegment(context.Context, *ActivateSegmentRequest) (*ActivateSegmentResponse, error)
	InactivateSegment(context.Context, *InactivateSegmentRequest) (*emptypb.Empty, error)
	AppendToBlock(context.Context, *AppendToBlockRequest) (*AppendToBlockResponse, error)
	ReadFromBlock(context.Context, *ReadFromBlockRequest) (*ReadFromBlockResponse, error)
	LookupOffsetInBlock(context.Context, *LookupOffsetInBlockRequest) (*LookupOffsetInBlockResponse, error)
	Status(context.Context, *emptypb.Empty) (*StatusResponse, error)
}

SegmentServerServer is the server API for SegmentServer service. All implementations should embed UnimplementedSegmentServerServer for forward compatibility

type StartSegmentServerRequest 

type StartSegmentServerRequest struct {
	Config *config.ServerConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*StartSegmentServerRequest) Descriptor deprecated 

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

Deprecated: Use StartSegmentServerRequest.ProtoReflect.Descriptor instead.

func (*StartSegmentServerRequest) GetConfig 

func (x *StartSegmentServerRequest) GetConfig() *config.ServerConfig

func (*StartSegmentServerRequest) ProtoMessage 

func (*StartSegmentServerRequest) ProtoMessage()

func (*StartSegmentServerRequest) ProtoReflect 

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

func (*StartSegmentServerRequest) Reset 

func (x *StartSegmentServerRequest) Reset()

func (*StartSegmentServerRequest) String 

func (x *StartSegmentServerRequest) String() string

type StartSegmentServerResponse 

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

func (*StartSegmentServerResponse) Descriptor deprecated 

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

Deprecated: Use StartSegmentServerResponse.ProtoReflect.Descriptor instead.

func (*StartSegmentServerResponse) ProtoMessage 

func (*StartSegmentServerResponse) ProtoMessage()

func (*StartSegmentServerResponse) ProtoReflect 

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

func (*StartSegmentServerResponse) Reset 

func (x *StartSegmentServerResponse) Reset()

func (*StartSegmentServerResponse) String 

func (x *StartSegmentServerResponse) String() string

type StatusResponse 

type StatusResponse struct {
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetStatus 

func (x *StatusResponse) GetStatus() string

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type StopSegmentServerRequest 

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

func (*StopSegmentServerRequest) Descriptor deprecated 

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

Deprecated: Use StopSegmentServerRequest.ProtoReflect.Descriptor instead.

func (*StopSegmentServerRequest) ProtoMessage 

func (*StopSegmentServerRequest) ProtoMessage()

func (*StopSegmentServerRequest) ProtoReflect 

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

func (*StopSegmentServerRequest) Reset 

func (x *StopSegmentServerRequest) Reset()

func (*StopSegmentServerRequest) String 

func (x *StopSegmentServerRequest) String() string

type StopSegmentServerResponse 

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

func (*StopSegmentServerResponse) Descriptor deprecated 

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

Deprecated: Use StopSegmentServerResponse.ProtoReflect.Descriptor instead.

func (*StopSegmentServerResponse) ProtoMessage 

func (*StopSegmentServerResponse) ProtoMessage()

func (*StopSegmentServerResponse) ProtoReflect 

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

func (*StopSegmentServerResponse) Reset 

func (x *StopSegmentServerResponse) Reset()

func (*StopSegmentServerResponse) String 

func (x *StopSegmentServerResponse) String() string

type UnimplementedSegmentServerServer 

type UnimplementedSegmentServerServer struct {
}

UnimplementedSegmentServerServer should be embedded to have forward compatible implementations.

func (UnimplementedSegmentServerServer) ActivateSegment 

func (UnimplementedSegmentServerServer) ActivateSegment(context.Context, *ActivateSegmentRequest) (*ActivateSegmentResponse, error)

func (UnimplementedSegmentServerServer) AppendToBlock 

func (UnimplementedSegmentServerServer) AppendToBlock(context.Context, *AppendToBlockRequest) (*AppendToBlockResponse, error)

func (UnimplementedSegmentServerServer) CreateBlock 

func (UnimplementedSegmentServerServer) CreateBlock(context.Context, *CreateBlockRequest) (*emptypb.Empty, error)

func (UnimplementedSegmentServerServer) DescribeBlock 

func (UnimplementedSegmentServerServer) DescribeBlock(context.Context, *DescribeBlockRequest) (*DescribeBlockResponse, error)

func (UnimplementedSegmentServerServer) InactivateSegment 

func (UnimplementedSegmentServerServer) InactivateSegment(context.Context, *InactivateSegmentRequest) (*emptypb.Empty, error)

func (UnimplementedSegmentServerServer) LookupOffsetInBlock 

func (UnimplementedSegmentServerServer) LookupOffsetInBlock(context.Context, *LookupOffsetInBlockRequest) (*LookupOffsetInBlockResponse, error)

func (UnimplementedSegmentServerServer) ReadFromBlock 

func (UnimplementedSegmentServerServer) ReadFromBlock(context.Context, *ReadFromBlockRequest) (*ReadFromBlockResponse, error)

func (UnimplementedSegmentServerServer) RemoveBlock 

func (UnimplementedSegmentServerServer) RemoveBlock(context.Context, *RemoveBlockRequest) (*emptypb.Empty, error)

func (UnimplementedSegmentServerServer) Start 

func (UnimplementedSegmentServerServer) Start(context.Context, *StartSegmentServerRequest) (*StartSegmentServerResponse, error)

func (UnimplementedSegmentServerServer) Status 

func (UnimplementedSegmentServerServer) Status(context.Context, *emptypb.Empty) (*StatusResponse, error)

func (UnimplementedSegmentServerServer) Stop 

func (UnimplementedSegmentServerServer) Stop(context.Context, *StopSegmentServerRequest) (*StopSegmentServerResponse, error)

type UnsafeSegmentServerServer 

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

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

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.