packet

package
v0.0.0-...-f553f25 Latest Latest
Warning

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

 Go to latest Published: Apr 17, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCanalProtocol        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCanalProtocol          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCanalProtocol = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Compression_name = map[int32]string{
	0: "COMPRESSIONCOMPATIBLEPROTO2",
	1: "NONE",
	2: "ZLIB",
	3: "GZIP",
	4: "LZF",
}
View Source 
var Compression_value = map[string]int32{
	"COMPRESSIONCOMPATIBLEPROTO2": 0,
	"NONE":                        1,
	"ZLIB":                        2,
	"GZIP":                        3,
	"LZF":                         4,
}
View Source 
var PacketType_name = map[int32]string{
	0:  "PACKAGETYPECOMPATIBLEPROTO2",
	1:  "HANDSHAKE",
	2:  "CLIENTAUTHENTICATION",
	3:  "ACK",
	4:  "SUBSCRIPTION",
	5:  "UNSUBSCRIPTION",
	6:  "GET",
	7:  "MESSAGES",
	8:  "CLIENTACK",
	9:  "SHUTDOWN",
	10: "DUMP",
	11: "HEARTBEAT",
	12: "CLIENTROLLBACK",
}
View Source 
var PacketType_value = map[string]int32{
	"PACKAGETYPECOMPATIBLEPROTO2": 0,
	"HANDSHAKE":                   1,
	"CLIENTAUTHENTICATION":        2,
	"ACK":                         3,
	"SUBSCRIPTION":                4,
	"UNSUBSCRIPTION":              5,
	"GET":                         6,
	"MESSAGES":                    7,
	"CLIENTACK":                   8,
	"SHUTDOWN":                    9,
	"DUMP":                        10,
	"HEARTBEAT":                   11,
	"CLIENTROLLBACK":              12,
}

Functions

This section is empty.

Types

type Ack 

type Ack struct {
	//[default = 0]
	//
	// Types that are valid to be assigned to ErrorCodePresent:
	//	*Ack_ErrorCode
	ErrorCodePresent     isAck_ErrorCodePresent `protobuf_oneof:"error_code_present"`
	ErrorMessage         string                 `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*Ack) Descriptor 

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

func (*Ack) GetErrorCode 

func (m *Ack) GetErrorCode() int32

func (*Ack) GetErrorCodePresent 

func (m *Ack) GetErrorCodePresent() isAck_ErrorCodePresent

func (*Ack) GetErrorMessage 

func (m *Ack) GetErrorMessage() string

func (*Ack) Marshal 

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

func (*Ack) MarshalTo 

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

func (*Ack) MarshalToSizedBuffer 

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

func (*Ack) ProtoMessage 

func (*Ack) ProtoMessage()

func (*Ack) Reset 

func (m *Ack) Reset()

func (*Ack) Size 

func (m *Ack) Size() (n int)

func (*Ack) String 

func (m *Ack) String() string

func (*Ack) Unmarshal 

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

func (*Ack) XXX_DiscardUnknown 

func (m *Ack) XXX_DiscardUnknown()

func (*Ack) XXX_Marshal 

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

func (*Ack) XXX_Merge 

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

func (*Ack) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Ack) XXX_Size 

func (m *Ack) XXX_Size() int

func (*Ack) XXX_Unmarshal 

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

type Ack_ErrorCode 

type Ack_ErrorCode struct {
	ErrorCode int32 `protobuf:"varint,1,opt,name=error_code,json=errorCode,proto3,oneof" json:"error_code,omitempty"`
}

func (*Ack_ErrorCode) MarshalTo 

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

func (*Ack_ErrorCode) MarshalToSizedBuffer 

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

func (*Ack_ErrorCode) Size 

func (m *Ack_ErrorCode) Size() (n int)

type ClientAck 

type ClientAck struct {
	Destination          string   `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId             string   `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	BatchId              int64    `protobuf:"varint,3,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientAck) Descriptor 

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

func (*ClientAck) GetBatchId 

func (m *ClientAck) GetBatchId() int64

func (*ClientAck) GetClientId 

func (m *ClientAck) GetClientId() string

func (*ClientAck) GetDestination 

func (m *ClientAck) GetDestination() string

func (*ClientAck) Marshal 

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

func (*ClientAck) MarshalTo 

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

func (*ClientAck) MarshalToSizedBuffer 

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

func (*ClientAck) ProtoMessage 

func (*ClientAck) ProtoMessage()

func (*ClientAck) Reset 

func (m *ClientAck) Reset()

func (*ClientAck) Size 

func (m *ClientAck) Size() (n int)

func (*ClientAck) String 

func (m *ClientAck) String() string

func (*ClientAck) Unmarshal 

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

func (*ClientAck) XXX_DiscardUnknown 

func (m *ClientAck) XXX_DiscardUnknown()

func (*ClientAck) XXX_Marshal 

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

func (*ClientAck) XXX_Merge 

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

func (*ClientAck) XXX_Size 

func (m *ClientAck) XXX_Size() int

func (*ClientAck) XXX_Unmarshal 

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

type ClientAuth 

type ClientAuth struct {
	Username string `protobuf:"bytes,1,opt,name=username,proto3" json:"username,omitempty"`
	Password []byte `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// [default = 0]
	//
	// Types that are valid to be assigned to NetReadTimeoutPresent:
	//	*ClientAuth_NetReadTimeout
	NetReadTimeoutPresent isClientAuth_NetReadTimeoutPresent `protobuf_oneof:"net_read_timeout_present"`
	// [default = 0];
	//
	// Types that are valid to be assigned to NetWriteTimeoutPresent:
	//	*ClientAuth_NetWriteTimeout
	NetWriteTimeoutPresent isClientAuth_NetWriteTimeoutPresent `protobuf_oneof:"net_write_timeout_present"`
	Destination            string                              `protobuf:"bytes,5,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId               string                              `protobuf:"bytes,6,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Filter                 string                              `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	StartTimestamp         int64                               `protobuf:"varint,8,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral   struct{}                            `json:"-"`
	XXX_unrecognized       []byte                              `json:"-"`
	XXX_sizecache          int32                               `json:"-"`
}

client authentication

func (*ClientAuth) Descriptor 

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

func (*ClientAuth) GetClientId 

func (m *ClientAuth) GetClientId() string

func (*ClientAuth) GetDestination 

func (m *ClientAuth) GetDestination() string

func (*ClientAuth) GetFilter 

func (m *ClientAuth) GetFilter() string

func (*ClientAuth) GetNetReadTimeout 

func (m *ClientAuth) GetNetReadTimeout() int32

func (*ClientAuth) GetNetReadTimeoutPresent 

func (m *ClientAuth) GetNetReadTimeoutPresent() isClientAuth_NetReadTimeoutPresent

func (*ClientAuth) GetNetWriteTimeout 

func (m *ClientAuth) GetNetWriteTimeout() int32

func (*ClientAuth) GetNetWriteTimeoutPresent 

func (m *ClientAuth) GetNetWriteTimeoutPresent() isClientAuth_NetWriteTimeoutPresent

func (*ClientAuth) GetPassword 

func (m *ClientAuth) GetPassword() []byte

func (*ClientAuth) GetStartTimestamp 

func (m *ClientAuth) GetStartTimestamp() int64

func (*ClientAuth) GetUsername 

func (m *ClientAuth) GetUsername() string

func (*ClientAuth) Marshal 

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

func (*ClientAuth) MarshalTo 

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

func (*ClientAuth) MarshalToSizedBuffer 

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

func (*ClientAuth) ProtoMessage 

func (*ClientAuth) ProtoMessage()

func (*ClientAuth) Reset 

func (m *ClientAuth) Reset()

func (*ClientAuth) Size 

func (m *ClientAuth) Size() (n int)

func (*ClientAuth) String 

func (m *ClientAuth) String() string

func (*ClientAuth) Unmarshal 

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

func (*ClientAuth) XXX_DiscardUnknown 

func (m *ClientAuth) XXX_DiscardUnknown()

func (*ClientAuth) XXX_Marshal 

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

func (*ClientAuth) XXX_Merge 

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

func (*ClientAuth) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ClientAuth) XXX_Size 

func (m *ClientAuth) XXX_Size() int

func (*ClientAuth) XXX_Unmarshal 

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

type ClientAuth_NetReadTimeout 

type ClientAuth_NetReadTimeout struct {
	NetReadTimeout int32 `protobuf:"varint,3,opt,name=net_read_timeout,json=netReadTimeout,proto3,oneof" json:"net_read_timeout,omitempty"`
}

func (*ClientAuth_NetReadTimeout) MarshalTo 

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

func (*ClientAuth_NetReadTimeout) MarshalToSizedBuffer 

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

func (*ClientAuth_NetReadTimeout) Size 

func (m *ClientAuth_NetReadTimeout) Size() (n int)

type ClientAuth_NetWriteTimeout 

type ClientAuth_NetWriteTimeout struct {
	NetWriteTimeout int32 `protobuf:"varint,4,opt,name=net_write_timeout,json=netWriteTimeout,proto3,oneof" json:"net_write_timeout,omitempty"`
}

func (*ClientAuth_NetWriteTimeout) MarshalTo 

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

func (*ClientAuth_NetWriteTimeout) MarshalToSizedBuffer 

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

func (*ClientAuth_NetWriteTimeout) Size 

func (m *ClientAuth_NetWriteTimeout) Size() (n int)

type ClientRollback 

type ClientRollback struct {
	Destination          string   `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId             string   `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	BatchId              int64    `protobuf:"varint,3,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClientRollback) Descriptor 

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

func (*ClientRollback) GetBatchId 

func (m *ClientRollback) GetBatchId() int64

func (*ClientRollback) GetClientId 

func (m *ClientRollback) GetClientId() string

func (*ClientRollback) GetDestination 

func (m *ClientRollback) GetDestination() string

func (*ClientRollback) Marshal 

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

func (*ClientRollback) MarshalTo 

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

func (*ClientRollback) MarshalToSizedBuffer 

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

func (*ClientRollback) ProtoMessage 

func (*ClientRollback) ProtoMessage()

func (*ClientRollback) Reset 

func (m *ClientRollback) Reset()

func (*ClientRollback) Size 

func (m *ClientRollback) Size() (n int)

func (*ClientRollback) String 

func (m *ClientRollback) String() string

func (*ClientRollback) Unmarshal 

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

func (*ClientRollback) XXX_DiscardUnknown 

func (m *ClientRollback) XXX_DiscardUnknown()

func (*ClientRollback) XXX_Marshal 

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

func (*ClientRollback) XXX_Merge 

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

func (*ClientRollback) XXX_Size 

func (m *ClientRollback) XXX_Size() int

func (*ClientRollback) XXX_Unmarshal 

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

type Compression 

type Compression int32
const (
	Compression_COMPRESSIONCOMPATIBLEPROTO2 Compression = 0
	Compression_NONE                        Compression = 1
	Compression_ZLIB                        Compression = 2
	Compression_GZIP                        Compression = 3
	Compression_LZF                         Compression = 4
)

func (Compression) EnumDescriptor 

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

func (Compression) String 

func (x Compression) String() string

type Dump 

type Dump struct {
	Journal  string `protobuf:"bytes,1,opt,name=journal,proto3" json:"journal,omitempty"`
	Position int64  `protobuf:"varint,2,opt,name=position,proto3" json:"position,omitempty"`
	// [default = 0]
	//
	// Types that are valid to be assigned to TimestampPresent:
	//	*Dump_Timestamp
	TimestampPresent     isDump_TimestampPresent `protobuf_oneof:"timestamp_present"`
	XXX_NoUnkeyedLiteral struct{}                `json:"-"`
	XXX_unrecognized     []byte                  `json:"-"`
	XXX_sizecache        int32                   `json:"-"`
}

TBD when new packets are required

func (*Dump) Descriptor 

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

func (*Dump) GetJournal 

func (m *Dump) GetJournal() string

func (*Dump) GetPosition 

func (m *Dump) GetPosition() int64

func (*Dump) GetTimestamp 

func (m *Dump) GetTimestamp() int64

func (*Dump) GetTimestampPresent 

func (m *Dump) GetTimestampPresent() isDump_TimestampPresent

func (*Dump) Marshal 

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

func (*Dump) MarshalTo 

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

func (*Dump) MarshalToSizedBuffer 

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

func (*Dump) ProtoMessage 

func (*Dump) ProtoMessage()

func (*Dump) Reset 

func (m *Dump) Reset()

func (*Dump) Size 

func (m *Dump) Size() (n int)

func (*Dump) String 

func (m *Dump) String() string

func (*Dump) Unmarshal 

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

func (*Dump) XXX_DiscardUnknown 

func (m *Dump) XXX_DiscardUnknown()

func (*Dump) XXX_Marshal 

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

func (*Dump) XXX_Merge 

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

func (*Dump) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Dump) XXX_Size 

func (m *Dump) XXX_Size() int

func (*Dump) XXX_Unmarshal 

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

type Dump_Timestamp 

type Dump_Timestamp struct {
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3,oneof" json:"timestamp,omitempty"`
}

func (*Dump_Timestamp) MarshalTo 

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

func (*Dump_Timestamp) MarshalToSizedBuffer 

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

func (*Dump_Timestamp) Size 

func (m *Dump_Timestamp) Size() (n int)

type Get 

type Get struct {
	Destination string `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId    string `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	FetchSize   int32  `protobuf:"varint,3,opt,name=fetch_size,json=fetchSize,proto3" json:"fetch_size,omitempty"`
	//[default = -1]
	//
	// Types that are valid to be assigned to TimeoutPresent:
	//	*Get_Timeout
	TimeoutPresent isGet_TimeoutPresent `protobuf_oneof:"timeout_present"`
	//[default = 2]
	//
	// Types that are valid to be assigned to UnitPresent:
	//	*Get_Unit
	UnitPresent isGet_UnitPresent `protobuf_oneof:"unit_present"`
	//[default = false]
	//
	// Types that are valid to be assigned to AutoAckPresent:
	//	*Get_AutoAck
	AutoAckPresent       isGet_AutoAckPresent `protobuf_oneof:"auto_ack_present"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

PullRequest

func (*Get) Descriptor 

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

func (*Get) GetAutoAck 

func (m *Get) GetAutoAck() bool

func (*Get) GetAutoAckPresent 

func (m *Get) GetAutoAckPresent() isGet_AutoAckPresent

func (*Get) GetClientId 

func (m *Get) GetClientId() string

func (*Get) GetDestination 

func (m *Get) GetDestination() string

func (*Get) GetFetchSize 

func (m *Get) GetFetchSize() int32

func (*Get) GetTimeout 

func (m *Get) GetTimeout() int64

func (*Get) GetTimeoutPresent 

func (m *Get) GetTimeoutPresent() isGet_TimeoutPresent

func (*Get) GetUnit 

func (m *Get) GetUnit() int32

func (*Get) GetUnitPresent 

func (m *Get) GetUnitPresent() isGet_UnitPresent

func (*Get) Marshal 

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

func (*Get) MarshalTo 

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

func (*Get) MarshalToSizedBuffer 

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

func (*Get) ProtoMessage 

func (*Get) ProtoMessage()

func (*Get) Reset 

func (m *Get) Reset()

func (*Get) Size 

func (m *Get) Size() (n int)

func (*Get) String 

func (m *Get) String() string

func (*Get) Unmarshal 

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

func (*Get) XXX_DiscardUnknown 

func (m *Get) XXX_DiscardUnknown()

func (*Get) XXX_Marshal 

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

func (*Get) XXX_Merge 

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

func (*Get) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Get) XXX_Size 

func (m *Get) XXX_Size() int

func (*Get) XXX_Unmarshal 

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

type Get_AutoAck 

type Get_AutoAck struct {
	AutoAck bool `protobuf:"varint,6,opt,name=auto_ack,json=autoAck,proto3,oneof" json:"auto_ack,omitempty"`
}

func (*Get_AutoAck) MarshalTo 

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

func (*Get_AutoAck) MarshalToSizedBuffer 

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

func (*Get_AutoAck) Size 

func (m *Get_AutoAck) Size() (n int)

type Get_Timeout 

type Get_Timeout struct {
	Timeout int64 `protobuf:"varint,4,opt,name=timeout,proto3,oneof" json:"timeout,omitempty"`
}

func (*Get_Timeout) MarshalTo 

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

func (*Get_Timeout) MarshalToSizedBuffer 

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

func (*Get_Timeout) Size 

func (m *Get_Timeout) Size() (n int)

type Get_Unit 

type Get_Unit struct {
	Unit int32 `protobuf:"varint,5,opt,name=unit,proto3,oneof" json:"unit,omitempty"`
}

func (*Get_Unit) MarshalTo 

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

func (*Get_Unit) MarshalToSizedBuffer 

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

func (*Get_Unit) Size 

func (m *Get_Unit) Size() (n int)

type Handshake 

type Handshake struct {
	//  [default = "utf8"];
	//
	// Types that are valid to be assigned to CommunicationEncodingPresent:
	//	*Handshake_CommunicationEncoding
	CommunicationEncodingPresent isHandshake_CommunicationEncodingPresent `protobuf_oneof:"communication_encoding_present"`
	Seeds                        []byte                                   `protobuf:"bytes,2,opt,name=seeds,proto3" json:"seeds,omitempty"`
	SupportedCompressions        Compression                              `` /* 182-byte string literal not displayed */
	XXX_NoUnkeyedLiteral         struct{}                                 `json:"-"`
	XXX_unrecognized             []byte                                   `json:"-"`
	XXX_sizecache                int32                                    `json:"-"`
}

func (*Handshake) Descriptor 

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

func (*Handshake) GetCommunicationEncoding 

func (m *Handshake) GetCommunicationEncoding() string

func (*Handshake) GetCommunicationEncodingPresent 

func (m *Handshake) GetCommunicationEncodingPresent() isHandshake_CommunicationEncodingPresent

func (*Handshake) GetSeeds 

func (m *Handshake) GetSeeds() []byte

func (*Handshake) GetSupportedCompressions 

func (m *Handshake) GetSupportedCompressions() Compression

func (*Handshake) Marshal 

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

func (*Handshake) MarshalTo 

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

func (*Handshake) MarshalToSizedBuffer 

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

func (*Handshake) ProtoMessage 

func (*Handshake) ProtoMessage()

func (*Handshake) Reset 

func (m *Handshake) Reset()

func (*Handshake) Size 

func (m *Handshake) Size() (n int)

func (*Handshake) String 

func (m *Handshake) String() string

func (*Handshake) Unmarshal 

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

func (*Handshake) XXX_DiscardUnknown 

func (m *Handshake) XXX_DiscardUnknown()

func (*Handshake) XXX_Marshal 

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

func (*Handshake) XXX_Merge 

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

func (*Handshake) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Handshake) XXX_Size 

func (m *Handshake) XXX_Size() int

func (*Handshake) XXX_Unmarshal 

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

type Handshake_CommunicationEncoding 

type Handshake_CommunicationEncoding struct {
	CommunicationEncoding string `` /* 130-byte string literal not displayed */
}

func (*Handshake_CommunicationEncoding) MarshalTo 

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

func (*Handshake_CommunicationEncoding) MarshalToSizedBuffer 

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

func (*Handshake_CommunicationEncoding) Size 

func (m *Handshake_CommunicationEncoding) Size() (n int)

type HeartBeat 

type HeartBeat struct {
	SendTimestamp        int64    `protobuf:"varint,1,opt,name=send_timestamp,json=sendTimestamp,proto3" json:"send_timestamp,omitempty"`
	StartTimestamp       int64    `protobuf:"varint,2,opt,name=start_timestamp,json=startTimestamp,proto3" json:"start_timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HeartBeat) Descriptor 

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

func (*HeartBeat) GetSendTimestamp 

func (m *HeartBeat) GetSendTimestamp() int64

func (*HeartBeat) GetStartTimestamp 

func (m *HeartBeat) GetStartTimestamp() int64

func (*HeartBeat) Marshal 

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

func (*HeartBeat) MarshalTo 

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

func (*HeartBeat) MarshalToSizedBuffer 

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

func (*HeartBeat) ProtoMessage 

func (*HeartBeat) ProtoMessage()

func (*HeartBeat) Reset 

func (m *HeartBeat) Reset()

func (*HeartBeat) Size 

func (m *HeartBeat) Size() (n int)

func (*HeartBeat) String 

func (m *HeartBeat) String() string

func (*HeartBeat) Unmarshal 

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

func (*HeartBeat) XXX_DiscardUnknown 

func (m *HeartBeat) XXX_DiscardUnknown()

func (*HeartBeat) XXX_Marshal 

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

func (*HeartBeat) XXX_Merge 

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

func (*HeartBeat) XXX_Size 

func (m *HeartBeat) XXX_Size() int

func (*HeartBeat) XXX_Unmarshal 

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

type Messages 

type Messages struct {
	BatchId              int64    `protobuf:"varint,1,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	Messages             [][]byte `protobuf:"bytes,2,rep,name=messages,proto3" json:"messages,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Messages) Descriptor 

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

func (*Messages) GetBatchId 

func (m *Messages) GetBatchId() int64

func (*Messages) GetMessages 

func (m *Messages) GetMessages() [][]byte

func (*Messages) Marshal 

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

func (*Messages) MarshalTo 

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

func (*Messages) MarshalToSizedBuffer 

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

func (*Messages) ProtoMessage 

func (*Messages) ProtoMessage()

func (*Messages) Reset 

func (m *Messages) Reset()

func (*Messages) Size 

func (m *Messages) Size() (n int)

func (*Messages) String 

func (m *Messages) String() string

func (*Messages) Unmarshal 

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

func (*Messages) XXX_DiscardUnknown 

func (m *Messages) XXX_DiscardUnknown()

func (*Messages) XXX_Marshal 

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

func (*Messages) XXX_Merge 

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

func (*Messages) XXX_Size 

func (m *Messages) XXX_Size() int

func (*Messages) XXX_Unmarshal 

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

type Packet 

type Packet struct {
	//[default = 17];
	//
	// Types that are valid to be assigned to MagicNumberPresent:
	//	*Packet_MagicNumber
	MagicNumberPresent isPacket_MagicNumberPresent `protobuf_oneof:"magic_number_present"`
	//[default = 1];
	//
	// Types that are valid to be assigned to VersionPresent:
	//	*Packet_Version
	VersionPresent isPacket_VersionPresent `protobuf_oneof:"version_present"`
	Type           PacketType              `protobuf:"varint,3,opt,name=type,proto3,enum=com.alibaba.otter.canal.protocol.packet.PacketType" json:"type,omitempty"`
	//[default = NONE];
	//
	// Types that are valid to be assigned to CompressionPresent:
	//	*Packet_Compression
	CompressionPresent   isPacket_CompressionPresent `protobuf_oneof:"compression_present"`
	Body                 []byte                      `protobuf:"bytes,5,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

func (*Packet) Descriptor 

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

func (*Packet) GetBody 

func (m *Packet) GetBody() []byte

func (*Packet) GetCompression 

func (m *Packet) GetCompression() Compression

func (*Packet) GetCompressionPresent 

func (m *Packet) GetCompressionPresent() isPacket_CompressionPresent

func (*Packet) GetMagicNumber 

func (m *Packet) GetMagicNumber() int32

func (*Packet) GetMagicNumberPresent 

func (m *Packet) GetMagicNumberPresent() isPacket_MagicNumberPresent

func (*Packet) GetType 

func (m *Packet) GetType() PacketType

func (*Packet) GetVersion 

func (m *Packet) GetVersion() int32

func (*Packet) GetVersionPresent 

func (m *Packet) GetVersionPresent() isPacket_VersionPresent

func (*Packet) Marshal 

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

func (*Packet) MarshalTo 

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

func (*Packet) MarshalToSizedBuffer 

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

func (*Packet) ProtoMessage 

func (*Packet) ProtoMessage()

func (*Packet) Reset 

func (m *Packet) Reset()

func (*Packet) Size 

func (m *Packet) Size() (n int)

func (*Packet) String 

func (m *Packet) String() string

func (*Packet) Unmarshal 

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

func (*Packet) XXX_DiscardUnknown 

func (m *Packet) XXX_DiscardUnknown()

func (*Packet) XXX_Marshal 

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

func (*Packet) XXX_Merge 

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

func (*Packet) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Packet) XXX_Size 

func (m *Packet) XXX_Size() int

func (*Packet) XXX_Unmarshal 

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

type PacketType 

type PacketType int32
const (
	//compatible
	PacketType_PACKAGETYPECOMPATIBLEPROTO2 PacketType = 0
	PacketType_HANDSHAKE                   PacketType = 1
	PacketType_CLIENTAUTHENTICATION        PacketType = 2
	PacketType_ACK                         PacketType = 3
	PacketType_SUBSCRIPTION                PacketType = 4
	PacketType_UNSUBSCRIPTION              PacketType = 5
	PacketType_GET                         PacketType = 6
	PacketType_MESSAGES                    PacketType = 7
	PacketType_CLIENTACK                   PacketType = 8
	// management part
	PacketType_SHUTDOWN PacketType = 9
	// integration
	PacketType_DUMP           PacketType = 10
	PacketType_HEARTBEAT      PacketType = 11
	PacketType_CLIENTROLLBACK PacketType = 12
)

func (PacketType) EnumDescriptor 

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

func (PacketType) String 

func (x PacketType) String() string

type Packet_Compression 

type Packet_Compression struct {
	Compression Compression `` /* 139-byte string literal not displayed */
}

func (*Packet_Compression) MarshalTo 

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

func (*Packet_Compression) MarshalToSizedBuffer 

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

func (*Packet_Compression) Size 

func (m *Packet_Compression) Size() (n int)

type Packet_MagicNumber 

type Packet_MagicNumber struct {
	MagicNumber int32 `protobuf:"varint,1,opt,name=magic_number,json=magicNumber,proto3,oneof" json:"magic_number,omitempty"`
}

func (*Packet_MagicNumber) MarshalTo 

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

func (*Packet_MagicNumber) MarshalToSizedBuffer 

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

func (*Packet_MagicNumber) Size 

func (m *Packet_MagicNumber) Size() (n int)

type Packet_Version 

type Packet_Version struct {
	Version int32 `protobuf:"varint,2,opt,name=version,proto3,oneof" json:"version,omitempty"`
}

func (*Packet_Version) MarshalTo 

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

func (*Packet_Version) MarshalToSizedBuffer 

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

func (*Packet_Version) Size 

func (m *Packet_Version) Size() (n int)

type Sub 

type Sub struct {
	Destination          string   `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId             string   `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Filter               string   `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

subscription

func (*Sub) Descriptor 

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

func (*Sub) GetClientId 

func (m *Sub) GetClientId() string

func (*Sub) GetDestination 

func (m *Sub) GetDestination() string

func (*Sub) GetFilter 

func (m *Sub) GetFilter() string

func (*Sub) Marshal 

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

func (*Sub) MarshalTo 

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

func (*Sub) MarshalToSizedBuffer 

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

func (*Sub) ProtoMessage 

func (*Sub) ProtoMessage()

func (*Sub) Reset 

func (m *Sub) Reset()

func (*Sub) Size 

func (m *Sub) Size() (n int)

func (*Sub) String 

func (m *Sub) String() string

func (*Sub) Unmarshal 

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

func (*Sub) XXX_DiscardUnknown 

func (m *Sub) XXX_DiscardUnknown()

func (*Sub) XXX_Marshal 

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

func (*Sub) XXX_Merge 

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

func (*Sub) XXX_Size 

func (m *Sub) XXX_Size() int

func (*Sub) XXX_Unmarshal 

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

type Unsub 

type Unsub struct {
	Destination          string   `protobuf:"bytes,1,opt,name=destination,proto3" json:"destination,omitempty"`
	ClientId             string   `protobuf:"bytes,2,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Filter               string   `protobuf:"bytes,7,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Unsubscription

func (*Unsub) Descriptor 

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

func (*Unsub) GetClientId 

func (m *Unsub) GetClientId() string

func (*Unsub) GetDestination 

func (m *Unsub) GetDestination() string

func (*Unsub) GetFilter 

func (m *Unsub) GetFilter() string

func (*Unsub) Marshal 

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

func (*Unsub) MarshalTo 

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

func (*Unsub) MarshalToSizedBuffer 

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

func (*Unsub) ProtoMessage 

func (*Unsub) ProtoMessage()

func (*Unsub) Reset 

func (m *Unsub) Reset()

func (*Unsub) Size 

func (m *Unsub) Size() (n int)

func (*Unsub) String 

func (m *Unsub) String() string

func (*Unsub) Unmarshal 

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

func (*Unsub) XXX_DiscardUnknown 

func (m *Unsub) XXX_DiscardUnknown()

func (*Unsub) XXX_Marshal 

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

func (*Unsub) XXX_Merge 

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

func (*Unsub) XXX_Size 

func (m *Unsub) XXX_Size() int

func (*Unsub) XXX_Unmarshal 

func (m *Unsub) 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.