logtail

package
v1.2.2-20240715 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLogtail        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogtail          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupLogtail = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type ErrorResponse 

type ErrorResponse struct {
	Status               Status       `protobuf:"bytes,1,opt,name=status,proto3" json:"status"`
	Table                *api.TableID `protobuf:"bytes,2,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

ErrorResponse is the response to notify CN with error.

func (*ErrorResponse) Descriptor 

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

func (*ErrorResponse) GetStatus 

func (m *ErrorResponse) GetStatus() Status

func (*ErrorResponse) GetTable 

func (m *ErrorResponse) GetTable() *api.TableID

func (*ErrorResponse) Marshal 

func (m *ErrorResponse) Marshal() (dAtA []byte, err error)

func (*ErrorResponse) MarshalTo 

func (m *ErrorResponse) MarshalTo(dAtA []byte) (int, error)

func (*ErrorResponse) MarshalToSizedBuffer 

func (m *ErrorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ErrorResponse) ProtoMessage 

func (*ErrorResponse) ProtoMessage()

func (*ErrorResponse) ProtoSize 

func (m *ErrorResponse) ProtoSize() (n int)

func (*ErrorResponse) Reset 

func (m *ErrorResponse) Reset()

func (*ErrorResponse) String 

func (m *ErrorResponse) String() string

func (*ErrorResponse) Unmarshal 

func (m *ErrorResponse) Unmarshal(dAtA []byte) error

func (*ErrorResponse) XXX_DiscardUnknown 

func (m *ErrorResponse) XXX_DiscardUnknown()

func (*ErrorResponse) XXX_Marshal 

func (m *ErrorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ErrorResponse) XXX_Merge 

func (m *ErrorResponse) XXX_Merge(src proto.Message)

func (*ErrorResponse) XXX_Size 

func (m *ErrorResponse) XXX_Size() int

func (*ErrorResponse) XXX_Unmarshal 

func (m *ErrorResponse) XXX_Unmarshal(b []byte) error

type LogtailRequest 

type LogtailRequest struct {
	RequestId uint64 `protobuf:"varint,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are valid to be assigned to Request:
	//	*LogtailRequest_SubscribeTable
	//	*LogtailRequest_UnsubscribeTable
	Request              isLogtailRequest_Request `protobuf_oneof:"request"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

logtail stream request

func (*LogtailRequest) Descriptor 

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

func (*LogtailRequest) GetRequest 

func (m *LogtailRequest) GetRequest() isLogtailRequest_Request

func (*LogtailRequest) GetRequestId 

func (m *LogtailRequest) GetRequestId() uint64

func (*LogtailRequest) GetSubscribeTable 

func (m *LogtailRequest) GetSubscribeTable() *SubscribeRequest

func (*LogtailRequest) GetUnsubscribeTable 

func (m *LogtailRequest) GetUnsubscribeTable() *UnsubscribeRequest

func (*LogtailRequest) Marshal 

func (m *LogtailRequest) Marshal() (dAtA []byte, err error)

func (*LogtailRequest) MarshalTo 

func (m *LogtailRequest) MarshalTo(dAtA []byte) (int, error)

func (*LogtailRequest) MarshalToSizedBuffer 

func (m *LogtailRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogtailRequest) ProtoMessage 

func (*LogtailRequest) ProtoMessage()

func (*LogtailRequest) ProtoSize 

func (m *LogtailRequest) ProtoSize() (n int)

func (*LogtailRequest) Reset 

func (m *LogtailRequest) Reset()

func (*LogtailRequest) String 

func (m *LogtailRequest) String() string

func (*LogtailRequest) Unmarshal 

func (m *LogtailRequest) Unmarshal(dAtA []byte) error

func (*LogtailRequest) XXX_DiscardUnknown 

func (m *LogtailRequest) XXX_DiscardUnknown()

func (*LogtailRequest) XXX_Marshal 

func (m *LogtailRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogtailRequest) XXX_Merge 

func (m *LogtailRequest) XXX_Merge(src proto.Message)

func (*LogtailRequest) XXX_OneofWrappers 

func (*LogtailRequest) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*LogtailRequest) XXX_Size 

func (m *LogtailRequest) XXX_Size() int

func (*LogtailRequest) XXX_Unmarshal 

func (m *LogtailRequest) XXX_Unmarshal(b []byte) error

type LogtailRequest_SubscribeTable 

type LogtailRequest_SubscribeTable struct {
	SubscribeTable *SubscribeRequest `protobuf:"bytes,2,opt,name=subscribe_table,json=subscribeTable,proto3,oneof" json:"subscribe_table,omitempty"`
}

func (*LogtailRequest_SubscribeTable) MarshalTo 

func (m *LogtailRequest_SubscribeTable) MarshalTo(dAtA []byte) (int, error)

func (*LogtailRequest_SubscribeTable) MarshalToSizedBuffer 

func (m *LogtailRequest_SubscribeTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogtailRequest_SubscribeTable) ProtoSize 

func (m *LogtailRequest_SubscribeTable) ProtoSize() (n int)

type LogtailRequest_UnsubscribeTable 

type LogtailRequest_UnsubscribeTable struct {
	UnsubscribeTable *UnsubscribeRequest `protobuf:"bytes,3,opt,name=unsubscribe_table,json=unsubscribeTable,proto3,oneof" json:"unsubscribe_table,omitempty"`
}

func (*LogtailRequest_UnsubscribeTable) MarshalTo 

func (m *LogtailRequest_UnsubscribeTable) MarshalTo(dAtA []byte) (int, error)

func (*LogtailRequest_UnsubscribeTable) MarshalToSizedBuffer 

func (m *LogtailRequest_UnsubscribeTable) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogtailRequest_UnsubscribeTable) ProtoSize 

func (m *LogtailRequest_UnsubscribeTable) ProtoSize() (n int)

type LogtailResponse 

type LogtailResponse struct {
	ResponseId uint64 `protobuf:"varint,1,opt,name=response_id,json=responseId,proto3" json:"response_id,omitempty"`
	// Types that are valid to be assigned to Response:
	//	*LogtailResponse_SubscribeResponse
	//	*LogtailResponse_UnsubscribeResponse
	//	*LogtailResponse_UpdateResponse
	//	*LogtailResponse_Error
	Response             isLogtailResponse_Response `protobuf_oneof:"response"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

logtail stream response

func (*LogtailResponse) Descriptor 

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

func (*LogtailResponse) GetError 

func (m *LogtailResponse) GetError() *ErrorResponse

func (*LogtailResponse) GetResponse 

func (m *LogtailResponse) GetResponse() isLogtailResponse_Response

func (*LogtailResponse) GetResponseId 

func (m *LogtailResponse) GetResponseId() uint64

func (*LogtailResponse) GetSubscribeResponse 

func (m *LogtailResponse) GetSubscribeResponse() *SubscribeResponse

func (*LogtailResponse) GetUnsubscribeResponse 

func (m *LogtailResponse) GetUnsubscribeResponse() *UnSubscribeResponse

func (*LogtailResponse) GetUpdateResponse 

func (m *LogtailResponse) GetUpdateResponse() *UpdateResponse

func (*LogtailResponse) Marshal 

func (m *LogtailResponse) Marshal() (dAtA []byte, err error)

func (*LogtailResponse) MarshalTo 

func (m *LogtailResponse) MarshalTo(dAtA []byte) (int, error)

func (*LogtailResponse) MarshalToSizedBuffer 

func (m *LogtailResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogtailResponse) ProtoMessage 

func (*LogtailResponse) ProtoMessage()

func (*LogtailResponse) ProtoSize 

func (m *LogtailResponse) ProtoSize() (n int)

func (*LogtailResponse) Reset 

func (m *LogtailResponse) Reset()

func (*LogtailResponse) String 

func (m *LogtailResponse) String() string

func (*LogtailResponse) Unmarshal 

func (m *LogtailResponse) Unmarshal(dAtA []byte) error

func (*LogtailResponse) XXX_DiscardUnknown 

func (m *LogtailResponse) XXX_DiscardUnknown()

func (*LogtailResponse) XXX_Marshal 

func (m *LogtailResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogtailResponse) XXX_Merge 

func (m *LogtailResponse) XXX_Merge(src proto.Message)

func (*LogtailResponse) XXX_OneofWrappers 

func (*LogtailResponse) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*LogtailResponse) XXX_Size 

func (m *LogtailResponse) XXX_Size() int

func (*LogtailResponse) XXX_Unmarshal 

func (m *LogtailResponse) XXX_Unmarshal(b []byte) error

type LogtailResponse_Error 

type LogtailResponse_Error struct {
	Error *ErrorResponse `protobuf:"bytes,5,opt,name=error,proto3,oneof" json:"error,omitempty"`
}

func (*LogtailResponse_Error) MarshalTo 

func (m *LogtailResponse_Error) MarshalTo(dAtA []byte) (int, error)

func (*LogtailResponse_Error) MarshalToSizedBuffer 

func (m *LogtailResponse_Error) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogtailResponse_Error) ProtoSize 

func (m *LogtailResponse_Error) ProtoSize() (n int)

type LogtailResponse_SubscribeResponse 

type LogtailResponse_SubscribeResponse struct {
	SubscribeResponse *SubscribeResponse `protobuf:"bytes,2,opt,name=subscribe_response,json=subscribeResponse,proto3,oneof" json:"subscribe_response,omitempty"`
}

func (*LogtailResponse_SubscribeResponse) MarshalTo 

func (m *LogtailResponse_SubscribeResponse) MarshalTo(dAtA []byte) (int, error)

func (*LogtailResponse_SubscribeResponse) MarshalToSizedBuffer 

func (m *LogtailResponse_SubscribeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogtailResponse_SubscribeResponse) ProtoSize 

func (m *LogtailResponse_SubscribeResponse) ProtoSize() (n int)

type LogtailResponse_UnsubscribeResponse 

type LogtailResponse_UnsubscribeResponse struct {
	UnsubscribeResponse *UnSubscribeResponse `protobuf:"bytes,3,opt,name=unsubscribe_response,json=unsubscribeResponse,proto3,oneof" json:"unsubscribe_response,omitempty"`
}

func (*LogtailResponse_UnsubscribeResponse) MarshalTo 

func (m *LogtailResponse_UnsubscribeResponse) MarshalTo(dAtA []byte) (int, error)

func (*LogtailResponse_UnsubscribeResponse) MarshalToSizedBuffer 

func (m *LogtailResponse_UnsubscribeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogtailResponse_UnsubscribeResponse) ProtoSize 

func (m *LogtailResponse_UnsubscribeResponse) ProtoSize() (n int)

type LogtailResponse_UpdateResponse 

type LogtailResponse_UpdateResponse struct {
	UpdateResponse *UpdateResponse `protobuf:"bytes,4,opt,name=update_response,json=updateResponse,proto3,oneof" json:"update_response,omitempty"`
}

func (*LogtailResponse_UpdateResponse) MarshalTo 

func (m *LogtailResponse_UpdateResponse) MarshalTo(dAtA []byte) (int, error)

func (*LogtailResponse_UpdateResponse) MarshalToSizedBuffer 

func (m *LogtailResponse_UpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogtailResponse_UpdateResponse) ProtoSize 

func (m *LogtailResponse_UpdateResponse) ProtoSize() (n int)

type MessageSegment 

type MessageSegment struct {
	StreamID             uint64   `protobuf:"varint,1,opt,name=StreamID,proto3" json:"StreamID,omitempty"`
	MessageSize          int32    `protobuf:"varint,2,opt,name=MessageSize,proto3" json:"MessageSize,omitempty"`
	Sequence             int32    `protobuf:"varint,3,opt,name=Sequence,proto3" json:"Sequence,omitempty"`
	MaxSequence          int32    `protobuf:"varint,4,opt,name=MaxSequence,proto3" json:"MaxSequence,omitempty"`
	Payload              []byte   `protobuf:"bytes,5,opt,name=Payload,proto3" json:"Payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

message segment

func (*MessageSegment) Descriptor 

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

func (*MessageSegment) GetMaxSequence 

func (m *MessageSegment) GetMaxSequence() int32

func (*MessageSegment) GetMessageSize 

func (m *MessageSegment) GetMessageSize() int32

func (*MessageSegment) GetPayload 

func (m *MessageSegment) GetPayload() []byte

func (*MessageSegment) GetSequence 

func (m *MessageSegment) GetSequence() int32

func (*MessageSegment) GetStreamID 

func (m *MessageSegment) GetStreamID() uint64

func (*MessageSegment) Marshal 

func (m *MessageSegment) Marshal() (dAtA []byte, err error)

func (*MessageSegment) MarshalTo 

func (m *MessageSegment) MarshalTo(dAtA []byte) (int, error)

func (*MessageSegment) MarshalToSizedBuffer 

func (m *MessageSegment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MessageSegment) ProtoMessage 

func (*MessageSegment) ProtoMessage()

func (*MessageSegment) ProtoSize 

func (m *MessageSegment) ProtoSize() (n int)

func (*MessageSegment) Reset 

func (m *MessageSegment) Reset()

func (*MessageSegment) String 

func (m *MessageSegment) String() string

func (*MessageSegment) Unmarshal 

func (m *MessageSegment) Unmarshal(dAtA []byte) error

func (*MessageSegment) XXX_DiscardUnknown 

func (m *MessageSegment) XXX_DiscardUnknown()

func (*MessageSegment) XXX_Marshal 

func (m *MessageSegment) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageSegment) XXX_Merge 

func (m *MessageSegment) XXX_Merge(src proto.Message)

func (*MessageSegment) XXX_Size 

func (m *MessageSegment) XXX_Size() int

func (*MessageSegment) XXX_Unmarshal 

func (m *MessageSegment) XXX_Unmarshal(b []byte) error

type Status 

type Status struct {
	// error code from moerr package
	Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// error message
	Message              string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Status describes error details.

func (*Status) Descriptor 

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

func (*Status) GetCode 

func (m *Status) GetCode() uint32

func (*Status) GetMessage 

func (m *Status) GetMessage() string

func (*Status) Marshal 

func (m *Status) Marshal() (dAtA []byte, err error)

func (*Status) MarshalTo 

func (m *Status) MarshalTo(dAtA []byte) (int, error)

func (*Status) MarshalToSizedBuffer 

func (m *Status) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoSize 

func (m *Status) ProtoSize() (n int)

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) String 

func (m *Status) String() string

func (*Status) Unmarshal 

func (m *Status) Unmarshal(dAtA []byte) error

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

func (m *Status) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Status) XXX_Merge 

func (m *Status) XXX_Merge(src proto.Message)

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

func (m *Status) XXX_Unmarshal(b []byte) error

type SubscribeRequest 

type SubscribeRequest struct {
	Table                *api.TableID `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

SubscribeRequest is the request for subscription.

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetTable 

func (m *SubscribeRequest) GetTable() *api.TableID

func (*SubscribeRequest) Marshal 

func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)

func (*SubscribeRequest) MarshalTo 

func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeRequest) MarshalToSizedBuffer 

func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoSize 

func (m *SubscribeRequest) ProtoSize() (n int)

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) Unmarshal 

func (m *SubscribeRequest) Unmarshal(dAtA []byte) error

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

func (m *SubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeRequest) XXX_Merge 

func (m *SubscribeRequest) XXX_Merge(src proto.Message)

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

func (m *SubscribeRequest) XXX_Unmarshal(b []byte) error

type SubscribeResponse 

type SubscribeResponse struct {
	Logtail              TableLogtail `protobuf:"bytes,1,opt,name=logtail,proto3" json:"logtail"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

SubscribeResponse is the response for subscription

It contains total logtail for the newly subscribed table.

func (*SubscribeResponse) Descriptor 

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

func (*SubscribeResponse) GetLogtail 

func (m *SubscribeResponse) GetLogtail() TableLogtail

func (*SubscribeResponse) Marshal 

func (m *SubscribeResponse) Marshal() (dAtA []byte, err error)

func (*SubscribeResponse) MarshalTo 

func (m *SubscribeResponse) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeResponse) MarshalToSizedBuffer 

func (m *SubscribeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoSize 

func (m *SubscribeResponse) ProtoSize() (n int)

func (*SubscribeResponse) Reset 

func (m *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (m *SubscribeResponse) String() string

func (*SubscribeResponse) Unmarshal 

func (m *SubscribeResponse) Unmarshal(dAtA []byte) error

func (*SubscribeResponse) XXX_DiscardUnknown 

func (m *SubscribeResponse) XXX_DiscardUnknown()

func (*SubscribeResponse) XXX_Marshal 

func (m *SubscribeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SubscribeResponse) XXX_Merge 

func (m *SubscribeResponse) XXX_Merge(src proto.Message)

func (*SubscribeResponse) XXX_Size 

func (m *SubscribeResponse) XXX_Size() int

func (*SubscribeResponse) XXX_Unmarshal 

func (m *SubscribeResponse) XXX_Unmarshal(b []byte) error

type TableLogtail 

type TableLogtail struct {
	CkpLocation          string               `protobuf:"bytes,1,opt,name=ckp_location,json=ckpLocation,proto3" json:"ckp_location,omitempty"`
	Ts                   *timestamp.Timestamp `protobuf:"bytes,2,opt,name=ts,proto3" json:"ts,omitempty"`
	Table                *api.TableID         `protobuf:"bytes,3,opt,name=table,proto3" json:"table,omitempty"`
	Commands             []api.Entry          `protobuf:"bytes,4,rep,name=commands,proto3" json:"commands"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

TableLogtail describes total or additional logtail for a table.

func (*TableLogtail) Descriptor 

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

func (*TableLogtail) GetCkpLocation 

func (m *TableLogtail) GetCkpLocation() string

func (*TableLogtail) GetCommands 

func (m *TableLogtail) GetCommands() []api.Entry

func (*TableLogtail) GetTable 

func (m *TableLogtail) GetTable() *api.TableID

func (*TableLogtail) GetTs 

func (m *TableLogtail) GetTs() *timestamp.Timestamp

func (*TableLogtail) Marshal 

func (m *TableLogtail) Marshal() (dAtA []byte, err error)

func (*TableLogtail) MarshalTo 

func (m *TableLogtail) MarshalTo(dAtA []byte) (int, error)

func (*TableLogtail) MarshalToSizedBuffer 

func (m *TableLogtail) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TableLogtail) ProtoMessage 

func (*TableLogtail) ProtoMessage()

func (*TableLogtail) ProtoSize 

func (m *TableLogtail) ProtoSize() (n int)

func (*TableLogtail) Reset 

func (m *TableLogtail) Reset()

func (*TableLogtail) String 

func (m *TableLogtail) String() string

func (*TableLogtail) Unmarshal 

func (m *TableLogtail) Unmarshal(dAtA []byte) error

func (*TableLogtail) XXX_DiscardUnknown 

func (m *TableLogtail) XXX_DiscardUnknown()

func (*TableLogtail) XXX_Marshal 

func (m *TableLogtail) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableLogtail) XXX_Merge 

func (m *TableLogtail) XXX_Merge(src proto.Message)

func (*TableLogtail) XXX_Size 

func (m *TableLogtail) XXX_Size() int

func (*TableLogtail) XXX_Unmarshal 

func (m *TableLogtail) XXX_Unmarshal(b []byte) error

type UnSubscribeResponse 

type UnSubscribeResponse struct {
	Table                *api.TableID `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

UnSubscribeResponse is the response for unsubscription

func (*UnSubscribeResponse) Descriptor 

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

func (*UnSubscribeResponse) GetTable 

func (m *UnSubscribeResponse) GetTable() *api.TableID

func (*UnSubscribeResponse) Marshal 

func (m *UnSubscribeResponse) Marshal() (dAtA []byte, err error)

func (*UnSubscribeResponse) MarshalTo 

func (m *UnSubscribeResponse) MarshalTo(dAtA []byte) (int, error)

func (*UnSubscribeResponse) MarshalToSizedBuffer 

func (m *UnSubscribeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnSubscribeResponse) ProtoMessage 

func (*UnSubscribeResponse) ProtoMessage()

func (*UnSubscribeResponse) ProtoSize 

func (m *UnSubscribeResponse) ProtoSize() (n int)

func (*UnSubscribeResponse) Reset 

func (m *UnSubscribeResponse) Reset()

func (*UnSubscribeResponse) String 

func (m *UnSubscribeResponse) String() string

func (*UnSubscribeResponse) Unmarshal 

func (m *UnSubscribeResponse) Unmarshal(dAtA []byte) error

func (*UnSubscribeResponse) XXX_DiscardUnknown 

func (m *UnSubscribeResponse) XXX_DiscardUnknown()

func (*UnSubscribeResponse) XXX_Marshal 

func (m *UnSubscribeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnSubscribeResponse) XXX_Merge 

func (m *UnSubscribeResponse) XXX_Merge(src proto.Message)

func (*UnSubscribeResponse) XXX_Size 

func (m *UnSubscribeResponse) XXX_Size() int

func (*UnSubscribeResponse) XXX_Unmarshal 

func (m *UnSubscribeResponse) XXX_Unmarshal(b []byte) error

type UnsubscribeRequest 

type UnsubscribeRequest struct {
	Table                *api.TableID `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

UnsubscribeRequest is the request for unsubscription.

func (*UnsubscribeRequest) Descriptor 

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

func (*UnsubscribeRequest) GetTable 

func (m *UnsubscribeRequest) GetTable() *api.TableID

func (*UnsubscribeRequest) Marshal 

func (m *UnsubscribeRequest) Marshal() (dAtA []byte, err error)

func (*UnsubscribeRequest) MarshalTo 

func (m *UnsubscribeRequest) MarshalTo(dAtA []byte) (int, error)

func (*UnsubscribeRequest) MarshalToSizedBuffer 

func (m *UnsubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UnsubscribeRequest) ProtoMessage 

func (*UnsubscribeRequest) ProtoMessage()

func (*UnsubscribeRequest) ProtoSize 

func (m *UnsubscribeRequest) ProtoSize() (n int)

func (*UnsubscribeRequest) Reset 

func (m *UnsubscribeRequest) Reset()

func (*UnsubscribeRequest) String 

func (m *UnsubscribeRequest) String() string

func (*UnsubscribeRequest) Unmarshal 

func (m *UnsubscribeRequest) Unmarshal(dAtA []byte) error

func (*UnsubscribeRequest) XXX_DiscardUnknown 

func (m *UnsubscribeRequest) XXX_DiscardUnknown()

func (*UnsubscribeRequest) XXX_Marshal 

func (m *UnsubscribeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UnsubscribeRequest) XXX_Merge 

func (m *UnsubscribeRequest) XXX_Merge(src proto.Message)

func (*UnsubscribeRequest) XXX_Size 

func (m *UnsubscribeRequest) XXX_Size() int

func (*UnsubscribeRequest) XXX_Unmarshal 

func (m *UnsubscribeRequest) XXX_Unmarshal(b []byte) error

type UpdateResponse 

type UpdateResponse struct {
	From                 *timestamp.Timestamp `protobuf:"bytes,1,opt,name=From,proto3" json:"From,omitempty"`
	To                   *timestamp.Timestamp `protobuf:"bytes,2,opt,name=To,proto3" json:"To,omitempty"`
	LogtailList          []TableLogtail       `protobuf:"bytes,3,rep,name=logtail_list,json=logtailList,proto3" json:"logtail_list"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

UpdateResponse is the response for additional logtail

It contains additional logtail for all subscribed tables. The range of duration is (From, to].

func (*UpdateResponse) Descriptor 

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

func (*UpdateResponse) GetFrom 

func (m *UpdateResponse) GetFrom() *timestamp.Timestamp

func (*UpdateResponse) GetLogtailList 

func (m *UpdateResponse) GetLogtailList() []TableLogtail

func (*UpdateResponse) GetTo 

func (m *UpdateResponse) GetTo() *timestamp.Timestamp

func (*UpdateResponse) Marshal 

func (m *UpdateResponse) Marshal() (dAtA []byte, err error)

func (*UpdateResponse) MarshalTo 

func (m *UpdateResponse) MarshalTo(dAtA []byte) (int, error)

func (*UpdateResponse) MarshalToSizedBuffer 

func (m *UpdateResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*UpdateResponse) ProtoMessage 

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoSize 

func (m *UpdateResponse) ProtoSize() (n int)

func (*UpdateResponse) Reset 

func (m *UpdateResponse) Reset()

func (*UpdateResponse) String 

func (m *UpdateResponse) String() string

func (*UpdateResponse) Unmarshal 

func (m *UpdateResponse) Unmarshal(dAtA []byte) error

func (*UpdateResponse) XXX_DiscardUnknown 

func (m *UpdateResponse) XXX_DiscardUnknown()

func (*UpdateResponse) XXX_Marshal 

func (m *UpdateResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UpdateResponse) XXX_Merge 

func (m *UpdateResponse) XXX_Merge(src proto.Message)

func (*UpdateResponse) XXX_Size 

func (m *UpdateResponse) XXX_Size() int

func (*UpdateResponse) XXX_Unmarshal 

func (m *UpdateResponse) XXX_Unmarshal(b []byte) error

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.