protocol

package
v4.1.2+incompatible Latest Latest
Warning

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

 Go to latest Published: Jan 16, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

Package protocol is a generated protocol buffer package.

It is generated from these files: 

tunnelservice.proto

It has these top-level messages: 

Error
Tunnel
CreateTunnelRequest
CreateTunnelResponse
DeleteTunnelRequest
DeleteTunnelResponse
ListTunnelRequest
TunnelInfo
ListTunnelResponse
DescribeTunnelRequest
ChannelInfo
DescribeTunnelResponse
GetRpoRequest
GetRpoResponse
ClientConfig
ConnectRequest
ConnectResponse
Channel
HeartbeatRequest
HeartbeatResponse
ShutdownRequest
ShutdownResponse
LockChannelRequest
LockChannelResponse
UnlockChannelRequest
UnlockChannelResponse
GetCheckpointRequest
GetCheckpointResponse
CheckpointRequest
CheckpointResponse
ReadRecordsRequest
Record
ReadRecordsResponse
Token
TokenContent
TokenContentV2

Index

Constants

View Source 
const (
	HEADER = 0x75

	// tag type
	TAG_ROW_PK             = 0x1
	TAG_ROW_DATA           = 0x2
	TAG_CELL               = 0x3
	TAG_CELL_NAME          = 0x4
	TAG_CELL_VALUE         = 0x5
	TAG_CELL_TYPE          = 0x6
	TAG_CELL_TIMESTAMP     = 0x7
	TAG_DELETE_ROW_MARKER  = 0x8
	TAG_ROW_CHECKSUM       = 0x9
	TAG_CELL_CHECKSUM      = 0x0A
	TAG_EXTENSION          = 0x0B
	TAG_SEQ_INFO           = 0x0C
	TAG_SEQ_INFO_EPOCH     = 0x0D
	TAG_SEQ_INFO_TS        = 0x0E
	TAG_SEQ_INFO_ROW_INDEX = 0x0F

	// cell op type
	DELETE_ALL_VERSION = 0x1
	DELETE_ONE_VERSION = 0x3

	// variant type
	VT_INTEGER = 0x0
	VT_DOUBLE  = 0x1
	VT_BOOLEAN = 0x2
	VT_STRING  = 0x3

	//public final static byte VT_NULL = 0x6;
	VT_BLOB           = 0x7
	VT_INF_MIN        = 0x9
	VT_INF_MAX        = 0xa
	VT_AUTO_INCREMENT = 0xb

	LITTLE_ENDIAN_32_SIZE = 4
	LITTLE_ENDIAN_64_SIZE = 8
)

Variables

View Source 
var ActionType_name = map[int32]string{
	1: "PUT_ROW",
	2: "UPDATE_ROW",
	3: "DELETE_ROW",
}
View Source 
var ActionType_value = map[string]int32{
	"PUT_ROW":    1,
	"UPDATE_ROW": 2,
	"DELETE_ROW": 3,
}
View Source 
var ChannelStatus_name = map[int32]string{
	1: "OPEN",
	2: "CLOSING",
	3: "CLOSE",
	4: "TERMINATED",
}
View Source 
var ChannelStatus_value = map[string]int32{
	"OPEN":       1,
	"CLOSING":    2,
	"CLOSE":      3,
	"TERMINATED": 4,
}
View Source 
var TunnelType_name = map[int32]string{
	1: "BaseData",
	2: "Stream",
	3: "BaseAndStream",
}
View Source 
var TunnelType_value = map[string]int32{
	"BaseData":      1,
	"Stream":        2,
	"BaseAndStream": 3,
}

Functions

This section is empty.

Types

type ActionType 

type ActionType int32
const (
	ActionType_PUT_ROW    ActionType = 1
	ActionType_UPDATE_ROW ActionType = 2
	ActionType_DELETE_ROW ActionType = 3
)

func (ActionType) Enum 

func (x ActionType) Enum() *ActionType

func (ActionType) EnumDescriptor 

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

func (ActionType) String 

func (x ActionType) String() string

func (*ActionType) UnmarshalJSON 

func (x *ActionType) UnmarshalJSON(data []byte) error

type Channel 

type Channel struct {
	ChannelId        *string        `protobuf:"bytes,1,req,name=channel_id" json:"channel_id,omitempty"`
	Version          *int64         `protobuf:"varint,2,req,name=version" json:"version,omitempty"`
	Status           *ChannelStatus `protobuf:"varint,3,req,name=status,enum=protocol.ChannelStatus" json:"status,omitempty"`
	Detail           []byte         `protobuf:"bytes,4,opt,name=detail" json:"detail,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*Channel) Descriptor 

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

func (*Channel) GetChannelId 

func (m *Channel) GetChannelId() string

func (*Channel) GetDetail 

func (m *Channel) GetDetail() []byte

func (*Channel) GetStatus 

func (m *Channel) GetStatus() ChannelStatus

func (*Channel) GetVersion 

func (m *Channel) GetVersion() int64

func (*Channel) ProtoMessage 

func (*Channel) ProtoMessage()

func (*Channel) Reset 

func (m *Channel) Reset()

func (*Channel) String 

func (m *Channel) String() string

type ChannelInfo 

type ChannelInfo struct {
	ChannelId        *string `protobuf:"bytes,1,req,name=channel_id" json:"channel_id,omitempty"`
	ChannelType      *string `protobuf:"bytes,2,opt,name=channel_type" json:"channel_type,omitempty"`
	ChannelStatus    *string `protobuf:"bytes,3,opt,name=channel_status" json:"channel_status,omitempty"`
	ClientId         *string `protobuf:"bytes,4,opt,name=client_id" json:"client_id,omitempty"`
	ChannelRpo       *int64  `protobuf:"varint,5,opt,name=channel_rpo" json:"channel_rpo,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ChannelInfo) Descriptor 

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

func (*ChannelInfo) GetChannelId 

func (m *ChannelInfo) GetChannelId() string

func (*ChannelInfo) GetChannelRpo 

func (m *ChannelInfo) GetChannelRpo() int64

func (*ChannelInfo) GetChannelStatus 

func (m *ChannelInfo) GetChannelStatus() string

func (*ChannelInfo) GetChannelType 

func (m *ChannelInfo) GetChannelType() string

func (*ChannelInfo) GetClientId 

func (m *ChannelInfo) GetClientId() string

func (*ChannelInfo) ProtoMessage 

func (*ChannelInfo) ProtoMessage()

func (*ChannelInfo) Reset 

func (m *ChannelInfo) Reset()

func (*ChannelInfo) String 

func (m *ChannelInfo) String() string

type ChannelStatus 

type ChannelStatus int32
const (
	ChannelStatus_OPEN       ChannelStatus = 1
	ChannelStatus_CLOSING    ChannelStatus = 2
	ChannelStatus_CLOSE      ChannelStatus = 3
	ChannelStatus_TERMINATED ChannelStatus = 4
)

func (ChannelStatus) Enum 

func (x ChannelStatus) Enum() *ChannelStatus

func (ChannelStatus) EnumDescriptor 

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

func (ChannelStatus) String 

func (x ChannelStatus) String() string

func (*ChannelStatus) UnmarshalJSON 

func (x *ChannelStatus) UnmarshalJSON(data []byte) error

type CheckpointRequest 

type CheckpointRequest struct {
	TunnelId         *string `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	ClientId         *string `protobuf:"bytes,2,req,name=client_id" json:"client_id,omitempty"`
	ChannelId        *string `protobuf:"bytes,3,req,name=channel_id" json:"channel_id,omitempty"`
	Checkpoint       *string `protobuf:"bytes,4,req,name=checkpoint" json:"checkpoint,omitempty"`
	SequenceNumber   *int64  `protobuf:"varint,5,req,name=sequence_number" json:"sequence_number,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CheckpointRequest) Descriptor 

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

func (*CheckpointRequest) GetChannelId 

func (m *CheckpointRequest) GetChannelId() string

func (*CheckpointRequest) GetCheckpoint 

func (m *CheckpointRequest) GetCheckpoint() string

func (*CheckpointRequest) GetClientId 

func (m *CheckpointRequest) GetClientId() string

func (*CheckpointRequest) GetSequenceNumber 

func (m *CheckpointRequest) GetSequenceNumber() int64

func (*CheckpointRequest) GetTunnelId 

func (m *CheckpointRequest) GetTunnelId() string

func (*CheckpointRequest) ProtoMessage 

func (*CheckpointRequest) ProtoMessage()

func (*CheckpointRequest) Reset 

func (m *CheckpointRequest) Reset()

func (*CheckpointRequest) String 

func (m *CheckpointRequest) String() string

type CheckpointResponse 

type CheckpointResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*CheckpointResponse) Descriptor 

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

func (*CheckpointResponse) ProtoMessage 

func (*CheckpointResponse) ProtoMessage()

func (*CheckpointResponse) Reset 

func (m *CheckpointResponse) Reset()

func (*CheckpointResponse) String 

func (m *CheckpointResponse) String() string

type ClientConfig 

type ClientConfig struct {
	Timeout          *int64  `protobuf:"varint,1,opt,name=timeout" json:"timeout,omitempty"`
	ClientTag        *string `protobuf:"bytes,2,opt,name=client_tag" json:"client_tag,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ClientConfig) Descriptor 

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

func (*ClientConfig) GetClientTag 

func (m *ClientConfig) GetClientTag() string

func (*ClientConfig) GetTimeout 

func (m *ClientConfig) GetTimeout() int64

func (*ClientConfig) ProtoMessage 

func (*ClientConfig) ProtoMessage()

func (*ClientConfig) Reset 

func (m *ClientConfig) Reset()

func (*ClientConfig) String 

func (m *ClientConfig) String() string

type ColumnType 

type ColumnType int32
const (
	ColumnType_STRING  ColumnType = 1
	ColumnType_INTEGER ColumnType = 2
	ColumnType_BOOLEAN ColumnType = 3
	ColumnType_DOUBLE  ColumnType = 4
	ColumnType_BINARY  ColumnType = 5
	ColumnType_MIN     ColumnType = 6
	ColumnType_MAX     ColumnType = 7
)

type ColumnValue 

type ColumnValue struct {
	Type  ColumnType
	Value interface{}
}

type ConnectRequest 

type ConnectRequest struct {
	TunnelId         *string       `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	ClientConfig     *ClientConfig `protobuf:"bytes,2,opt,name=client_config" json:"client_config,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ConnectRequest) Descriptor 

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

func (*ConnectRequest) GetClientConfig 

func (m *ConnectRequest) GetClientConfig() *ClientConfig

func (*ConnectRequest) GetTunnelId 

func (m *ConnectRequest) GetTunnelId() string

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) Reset 

func (m *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (m *ConnectRequest) String() string

type ConnectResponse 

type ConnectResponse struct {
	ClientId         *string `protobuf:"bytes,1,req,name=client_id" json:"client_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ConnectResponse) Descriptor 

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

func (*ConnectResponse) GetClientId 

func (m *ConnectResponse) GetClientId() string

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) Reset 

func (m *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (m *ConnectResponse) String() string

type CreateTunnelRequest 

type CreateTunnelRequest struct {
	Tunnel           *Tunnel `protobuf:"bytes,1,req,name=tunnel" json:"tunnel,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateTunnelRequest) Descriptor 

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

func (*CreateTunnelRequest) GetTunnel 

func (m *CreateTunnelRequest) GetTunnel() *Tunnel

func (*CreateTunnelRequest) ProtoMessage 

func (*CreateTunnelRequest) ProtoMessage()

func (*CreateTunnelRequest) Reset 

func (m *CreateTunnelRequest) Reset()

func (*CreateTunnelRequest) String 

func (m *CreateTunnelRequest) String() string

type CreateTunnelResponse 

type CreateTunnelResponse struct {
	TunnelId         *string `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*CreateTunnelResponse) Descriptor 

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

func (*CreateTunnelResponse) GetTunnelId 

func (m *CreateTunnelResponse) GetTunnelId() string

func (*CreateTunnelResponse) ProtoMessage 

func (*CreateTunnelResponse) ProtoMessage()

func (*CreateTunnelResponse) Reset 

func (m *CreateTunnelResponse) Reset()

func (*CreateTunnelResponse) String 

func (m *CreateTunnelResponse) String() string

type DeleteTunnelRequest 

type DeleteTunnelRequest struct {
	TableName        *string `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	TunnelName       *string `protobuf:"bytes,2,req,name=tunnel_name" json:"tunnel_name,omitempty"`
	TunnelId         *string `protobuf:"bytes,3,opt,name=tunnel_id" json:"tunnel_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DeleteTunnelRequest) Descriptor 

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

func (*DeleteTunnelRequest) GetTableName 

func (m *DeleteTunnelRequest) GetTableName() string

func (*DeleteTunnelRequest) GetTunnelId 

func (m *DeleteTunnelRequest) GetTunnelId() string

func (*DeleteTunnelRequest) GetTunnelName 

func (m *DeleteTunnelRequest) GetTunnelName() string

func (*DeleteTunnelRequest) ProtoMessage 

func (*DeleteTunnelRequest) ProtoMessage()

func (*DeleteTunnelRequest) Reset 

func (m *DeleteTunnelRequest) Reset()

func (*DeleteTunnelRequest) String 

func (m *DeleteTunnelRequest) String() string

type DeleteTunnelResponse 

type DeleteTunnelResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*DeleteTunnelResponse) Descriptor 

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

func (*DeleteTunnelResponse) ProtoMessage 

func (*DeleteTunnelResponse) ProtoMessage()

func (*DeleteTunnelResponse) Reset 

func (m *DeleteTunnelResponse) Reset()

func (*DeleteTunnelResponse) String 

func (m *DeleteTunnelResponse) String() string

type DescribeTunnelRequest 

type DescribeTunnelRequest struct {
	TableName        *string `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	TunnelName       *string `protobuf:"bytes,2,req,name=tunnel_name" json:"tunnel_name,omitempty"`
	TunnelId         *string `protobuf:"bytes,3,opt,name=tunnel_id" json:"tunnel_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*DescribeTunnelRequest) Descriptor 

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

func (*DescribeTunnelRequest) GetTableName 

func (m *DescribeTunnelRequest) GetTableName() string

func (*DescribeTunnelRequest) GetTunnelId 

func (m *DescribeTunnelRequest) GetTunnelId() string

func (*DescribeTunnelRequest) GetTunnelName 

func (m *DescribeTunnelRequest) GetTunnelName() string

func (*DescribeTunnelRequest) ProtoMessage 

func (*DescribeTunnelRequest) ProtoMessage()

func (*DescribeTunnelRequest) Reset 

func (m *DescribeTunnelRequest) Reset()

func (*DescribeTunnelRequest) String 

func (m *DescribeTunnelRequest) String() string

type DescribeTunnelResponse 

type DescribeTunnelResponse struct {
	Tunnel           *TunnelInfo    `protobuf:"bytes,1,req,name=tunnel" json:"tunnel,omitempty"`
	Channels         []*ChannelInfo `protobuf:"bytes,2,rep,name=channels" json:"channels,omitempty"`
	TunnelRpo        *int64         `protobuf:"varint,3,opt,name=tunnel_rpo" json:"tunnel_rpo,omitempty"`
	XXX_unrecognized []byte         `json:"-"`
}

func (*DescribeTunnelResponse) Descriptor 

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

func (*DescribeTunnelResponse) GetChannels 

func (m *DescribeTunnelResponse) GetChannels() []*ChannelInfo

func (*DescribeTunnelResponse) GetTunnel 

func (m *DescribeTunnelResponse) GetTunnel() *TunnelInfo

func (*DescribeTunnelResponse) GetTunnelRpo 

func (m *DescribeTunnelResponse) GetTunnelRpo() int64

func (*DescribeTunnelResponse) ProtoMessage 

func (*DescribeTunnelResponse) ProtoMessage()

func (*DescribeTunnelResponse) Reset 

func (m *DescribeTunnelResponse) Reset()

func (*DescribeTunnelResponse) String 

func (m *DescribeTunnelResponse) String() string

type Error 

type Error struct {
	Code             *string `protobuf:"bytes,1,req,name=code" json:"code,omitempty"`
	Message          *string `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	TunnelId         *string `protobuf:"bytes,3,opt,name=tunnel_id" json:"tunnel_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*Error) Descriptor 

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

func (*Error) GetCode 

func (m *Error) GetCode() string

func (*Error) GetMessage 

func (m *Error) GetMessage() string

func (*Error) GetTunnelId 

func (m *Error) GetTunnelId() string

func (*Error) ProtoMessage 

func (*Error) ProtoMessage()

func (*Error) Reset 

func (m *Error) Reset()

func (*Error) String 

func (m *Error) String() string

type GetCheckpointRequest 

type GetCheckpointRequest struct {
	TunnelId         *string `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	ClientId         *string `protobuf:"bytes,2,req,name=client_id" json:"client_id,omitempty"`
	ChannelId        *string `protobuf:"bytes,3,req,name=channel_id" json:"channel_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetCheckpointRequest) Descriptor 

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

func (*GetCheckpointRequest) GetChannelId 

func (m *GetCheckpointRequest) GetChannelId() string

func (*GetCheckpointRequest) GetClientId 

func (m *GetCheckpointRequest) GetClientId() string

func (*GetCheckpointRequest) GetTunnelId 

func (m *GetCheckpointRequest) GetTunnelId() string

func (*GetCheckpointRequest) ProtoMessage 

func (*GetCheckpointRequest) ProtoMessage()

func (*GetCheckpointRequest) Reset 

func (m *GetCheckpointRequest) Reset()

func (*GetCheckpointRequest) String 

func (m *GetCheckpointRequest) String() string

type GetCheckpointResponse 

type GetCheckpointResponse struct {
	Checkpoint       *string `protobuf:"bytes,1,req,name=checkpoint" json:"checkpoint,omitempty"`
	SequenceNumber   *int64  `protobuf:"varint,2,req,name=sequence_number" json:"sequence_number,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetCheckpointResponse) Descriptor 

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

func (*GetCheckpointResponse) GetCheckpoint 

func (m *GetCheckpointResponse) GetCheckpoint() string

func (*GetCheckpointResponse) GetSequenceNumber 

func (m *GetCheckpointResponse) GetSequenceNumber() int64

func (*GetCheckpointResponse) ProtoMessage 

func (*GetCheckpointResponse) ProtoMessage()

func (*GetCheckpointResponse) Reset 

func (m *GetCheckpointResponse) Reset()

func (*GetCheckpointResponse) String 

func (m *GetCheckpointResponse) String() string

type GetRpoRequest 

type GetRpoRequest struct {
	TunnelId         *string `protobuf:"bytes,1,opt,name=tunnel_id" json:"tunnel_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*GetRpoRequest) Descriptor 

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

func (*GetRpoRequest) GetTunnelId 

func (m *GetRpoRequest) GetTunnelId() string

func (*GetRpoRequest) ProtoMessage 

func (*GetRpoRequest) ProtoMessage()

func (*GetRpoRequest) Reset 

func (m *GetRpoRequest) Reset()

func (*GetRpoRequest) String 

func (m *GetRpoRequest) String() string

type GetRpoResponse 

type GetRpoResponse struct {
	RpoInfos         []byte `protobuf:"bytes,1,opt,name=rpo_infos" json:"rpo_infos,omitempty"`
	TunnelRpoInfos   []byte `protobuf:"bytes,2,opt,name=tunnel_rpo_infos" json:"tunnel_rpo_infos,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*GetRpoResponse) Descriptor 

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

func (*GetRpoResponse) GetRpoInfos 

func (m *GetRpoResponse) GetRpoInfos() []byte

func (*GetRpoResponse) GetTunnelRpoInfos 

func (m *GetRpoResponse) GetTunnelRpoInfos() []byte

func (*GetRpoResponse) ProtoMessage 

func (*GetRpoResponse) ProtoMessage()

func (*GetRpoResponse) Reset 

func (m *GetRpoResponse) Reset()

func (*GetRpoResponse) String 

func (m *GetRpoResponse) String() string

type HeartbeatRequest 

type HeartbeatRequest struct {
	TunnelId         *string    `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	ClientId         *string    `protobuf:"bytes,2,req,name=client_id" json:"client_id,omitempty"`
	Channels         []*Channel `protobuf:"bytes,3,rep,name=channels" json:"channels,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*HeartbeatRequest) Descriptor 

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

func (*HeartbeatRequest) GetChannels 

func (m *HeartbeatRequest) GetChannels() []*Channel

func (*HeartbeatRequest) GetClientId 

func (m *HeartbeatRequest) GetClientId() string

func (*HeartbeatRequest) GetTunnelId 

func (m *HeartbeatRequest) GetTunnelId() string

func (*HeartbeatRequest) ProtoMessage 

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) Reset 

func (m *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String 

func (m *HeartbeatRequest) String() string

type HeartbeatResponse 

type HeartbeatResponse struct {
	Channels         []*Channel `protobuf:"bytes,1,rep,name=channels" json:"channels,omitempty"`
	XXX_unrecognized []byte     `json:"-"`
}

func (*HeartbeatResponse) Descriptor 

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

func (*HeartbeatResponse) GetChannels 

func (m *HeartbeatResponse) GetChannels() []*Channel

func (*HeartbeatResponse) ProtoMessage 

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) Reset 

func (m *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String 

func (m *HeartbeatResponse) String() string

type ListTunnelRequest 

type ListTunnelRequest struct {
	TableName        *string `protobuf:"bytes,1,opt,name=table_name" json:"table_name,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ListTunnelRequest) Descriptor 

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

func (*ListTunnelRequest) GetTableName 

func (m *ListTunnelRequest) GetTableName() string

func (*ListTunnelRequest) ProtoMessage 

func (*ListTunnelRequest) ProtoMessage()

func (*ListTunnelRequest) Reset 

func (m *ListTunnelRequest) Reset()

func (*ListTunnelRequest) String 

func (m *ListTunnelRequest) String() string

type ListTunnelResponse 

type ListTunnelResponse struct {
	Tunnels          []*TunnelInfo `protobuf:"bytes,1,rep,name=tunnels" json:"tunnels,omitempty"`
	XXX_unrecognized []byte        `json:"-"`
}

func (*ListTunnelResponse) Descriptor 

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

func (*ListTunnelResponse) GetTunnels 

func (m *ListTunnelResponse) GetTunnels() []*TunnelInfo

func (*ListTunnelResponse) ProtoMessage 

func (*ListTunnelResponse) ProtoMessage()

func (*ListTunnelResponse) Reset 

func (m *ListTunnelResponse) Reset()

func (*ListTunnelResponse) String 

func (m *ListTunnelResponse) String() string

type LockChannelRequest 

type LockChannelRequest struct {
	TunnelId         *string `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	ClientId         *string `protobuf:"bytes,2,req,name=client_id" json:"client_id,omitempty"`
	ChannelId        *string `protobuf:"bytes,3,req,name=channel_id" json:"channel_id,omitempty"`
	LockId           *string `protobuf:"bytes,4,req,name=lock_id" json:"lock_id,omitempty"`
	Timeout          *int64  `protobuf:"varint,5,req,name=timeout" json:"timeout,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*LockChannelRequest) Descriptor 

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

func (*LockChannelRequest) GetChannelId 

func (m *LockChannelRequest) GetChannelId() string

func (*LockChannelRequest) GetClientId 

func (m *LockChannelRequest) GetClientId() string

func (*LockChannelRequest) GetLockId 

func (m *LockChannelRequest) GetLockId() string

func (*LockChannelRequest) GetTimeout 

func (m *LockChannelRequest) GetTimeout() int64

func (*LockChannelRequest) GetTunnelId 

func (m *LockChannelRequest) GetTunnelId() string

func (*LockChannelRequest) ProtoMessage 

func (*LockChannelRequest) ProtoMessage()

func (*LockChannelRequest) Reset 

func (m *LockChannelRequest) Reset()

func (*LockChannelRequest) String 

func (m *LockChannelRequest) String() string

type LockChannelResponse 

type LockChannelResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*LockChannelResponse) Descriptor 

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

func (*LockChannelResponse) ProtoMessage 

func (*LockChannelResponse) ProtoMessage()

func (*LockChannelResponse) Reset 

func (m *LockChannelResponse) Reset()

func (*LockChannelResponse) String 

func (m *LockChannelResponse) String() string

type PlainBufferCell 

type PlainBufferCell struct {
	CellName         []byte
	CellValue        *ColumnValue
	CellTimestamp    int64
	CellType         byte
	IgnoreValue      bool
	HasCellTimestamp bool
	HasCellType      bool
}

type PlainBufferRow 

type PlainBufferRow struct {
	PrimaryKey      []*PlainBufferCell
	Cells           []*PlainBufferCell
	HasDeleteMarker bool
	Extension       *tablestore.RecordSequenceInfo // optional
}

func ReadRowsWithHeader 

func ReadRowsWithHeader(r *bytes.Reader) (rows []*PlainBufferRow, err error)

type ReadRecordsRequest 

type ReadRecordsRequest struct {
	TunnelId         *string `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	ClientId         *string `protobuf:"bytes,2,req,name=client_id" json:"client_id,omitempty"`
	ChannelId        *string `protobuf:"bytes,3,req,name=channel_id" json:"channel_id,omitempty"`
	Token            *string `protobuf:"bytes,4,req,name=token" json:"token,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ReadRecordsRequest) Descriptor 

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

func (*ReadRecordsRequest) GetChannelId 

func (m *ReadRecordsRequest) GetChannelId() string

func (*ReadRecordsRequest) GetClientId 

func (m *ReadRecordsRequest) GetClientId() string

func (*ReadRecordsRequest) GetToken 

func (m *ReadRecordsRequest) GetToken() string

func (*ReadRecordsRequest) GetTunnelId 

func (m *ReadRecordsRequest) GetTunnelId() string

func (*ReadRecordsRequest) ProtoMessage 

func (*ReadRecordsRequest) ProtoMessage()

func (*ReadRecordsRequest) Reset 

func (m *ReadRecordsRequest) Reset()

func (*ReadRecordsRequest) String 

func (m *ReadRecordsRequest) String() string

type ReadRecordsResponse 

type ReadRecordsResponse struct {
	Records          []*Record `protobuf:"bytes,1,rep,name=records" json:"records,omitempty"`
	NextToken        *string   `protobuf:"bytes,2,req,name=next_token" json:"next_token,omitempty"`
	XXX_unrecognized []byte    `json:"-"`
}

func (*ReadRecordsResponse) Descriptor 

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

func (*ReadRecordsResponse) GetNextToken 

func (m *ReadRecordsResponse) GetNextToken() string

func (*ReadRecordsResponse) GetRecords 

func (m *ReadRecordsResponse) GetRecords() []*Record

func (*ReadRecordsResponse) ProtoMessage 

func (*ReadRecordsResponse) ProtoMessage()

func (*ReadRecordsResponse) Reset 

func (m *ReadRecordsResponse) Reset()

func (*ReadRecordsResponse) String 

func (m *ReadRecordsResponse) String() string

type Record 

type Record struct {
	ActionType       *ActionType `protobuf:"varint,1,req,name=action_type,enum=protocol.ActionType" json:"action_type,omitempty"`
	Record           []byte      `protobuf:"bytes,2,req,name=record" json:"record,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Record) Descriptor 

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

func (*Record) GetActionType 

func (m *Record) GetActionType() ActionType

func (*Record) GetRecord 

func (m *Record) GetRecord() []byte

func (*Record) ProtoMessage 

func (*Record) ProtoMessage()

func (*Record) Reset 

func (m *Record) Reset()

func (*Record) String 

func (m *Record) String() string

type ShutdownRequest 

type ShutdownRequest struct {
	TunnelId         *string `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	ClientId         *string `protobuf:"bytes,2,req,name=client_id" json:"client_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*ShutdownRequest) Descriptor 

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

func (*ShutdownRequest) GetClientId 

func (m *ShutdownRequest) GetClientId() string

func (*ShutdownRequest) GetTunnelId 

func (m *ShutdownRequest) GetTunnelId() string

func (*ShutdownRequest) ProtoMessage 

func (*ShutdownRequest) ProtoMessage()

func (*ShutdownRequest) Reset 

func (m *ShutdownRequest) Reset()

func (*ShutdownRequest) String 

func (m *ShutdownRequest) String() string

type ShutdownResponse 

type ShutdownResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*ShutdownResponse) Descriptor 

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

func (*ShutdownResponse) ProtoMessage 

func (*ShutdownResponse) ProtoMessage()

func (*ShutdownResponse) Reset 

func (m *ShutdownResponse) Reset()

func (*ShutdownResponse) String 

func (m *ShutdownResponse) String() string

type Token 

type Token struct {
	Version          *int64 `protobuf:"varint,1,req,name=version" json:"version,omitempty"`
	Content          []byte `protobuf:"bytes,2,req,name=content" json:"content,omitempty"`
	XXX_unrecognized []byte `json:"-"`
}

func (*Token) Descriptor 

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

func (*Token) GetContent 

func (m *Token) GetContent() []byte

func (*Token) GetVersion 

func (m *Token) GetVersion() int64

func (*Token) ProtoMessage 

func (*Token) ProtoMessage()

func (*Token) Reset 

func (m *Token) Reset()

func (*Token) String 

func (m *Token) String() string

type TokenContent 

type TokenContent struct {
	PrimaryKey       []byte  `protobuf:"bytes,1,opt,name=primary_key" json:"primary_key,omitempty"`
	Iterator         *string `protobuf:"bytes,2,opt,name=iterator" json:"iterator,omitempty"`
	Timestamp        *int64  `protobuf:"varint,3,opt,name=timestamp" json:"timestamp,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TokenContent) Descriptor 

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

func (*TokenContent) GetIterator 

func (m *TokenContent) GetIterator() string

func (*TokenContent) GetPrimaryKey 

func (m *TokenContent) GetPrimaryKey() []byte

func (*TokenContent) GetTimestamp 

func (m *TokenContent) GetTimestamp() int64

func (*TokenContent) ProtoMessage 

func (*TokenContent) ProtoMessage()

func (*TokenContent) Reset 

func (m *TokenContent) Reset()

func (*TokenContent) String 

func (m *TokenContent) String() string

type TokenContentV2 

type TokenContentV2 struct {
	PrimaryKey       []byte  `protobuf:"bytes,1,opt,name=primary_key" json:"primary_key,omitempty"`
	Iterator         *string `protobuf:"bytes,2,opt,name=iterator" json:"iterator,omitempty"`
	Timestamp        *int64  `protobuf:"varint,3,opt,name=timestamp" json:"timestamp,omitempty"`
	TotalCount       *int64  `protobuf:"varint,4,opt,name=total_count" json:"total_count,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TokenContentV2) Descriptor 

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

func (*TokenContentV2) GetIterator 

func (m *TokenContentV2) GetIterator() string

func (*TokenContentV2) GetPrimaryKey 

func (m *TokenContentV2) GetPrimaryKey() []byte

func (*TokenContentV2) GetTimestamp 

func (m *TokenContentV2) GetTimestamp() int64

func (*TokenContentV2) GetTotalCount 

func (m *TokenContentV2) GetTotalCount() int64

func (*TokenContentV2) ProtoMessage 

func (*TokenContentV2) ProtoMessage()

func (*TokenContentV2) Reset 

func (m *TokenContentV2) Reset()

func (*TokenContentV2) String 

func (m *TokenContentV2) String() string

type Tunnel 

type Tunnel struct {
	TableName        *string     `protobuf:"bytes,1,req,name=table_name" json:"table_name,omitempty"`
	TunnelName       *string     `protobuf:"bytes,3,req,name=tunnel_name" json:"tunnel_name,omitempty"`
	TunnelType       *TunnelType `protobuf:"varint,4,req,name=tunnel_type,enum=protocol.TunnelType" json:"tunnel_type,omitempty"`
	XXX_unrecognized []byte      `json:"-"`
}

func (*Tunnel) Descriptor 

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

func (*Tunnel) GetTableName 

func (m *Tunnel) GetTableName() string

func (*Tunnel) GetTunnelName 

func (m *Tunnel) GetTunnelName() string

func (*Tunnel) GetTunnelType 

func (m *Tunnel) GetTunnelType() TunnelType

func (*Tunnel) ProtoMessage 

func (*Tunnel) ProtoMessage()

func (*Tunnel) Reset 

func (m *Tunnel) Reset()

func (*Tunnel) String 

func (m *Tunnel) String() string

type TunnelInfo 

type TunnelInfo struct {
	TunnelId         *string `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	TunnelType       *string `protobuf:"bytes,2,req,name=tunnel_type" json:"tunnel_type,omitempty"`
	TableName        *string `protobuf:"bytes,3,req,name=table_name" json:"table_name,omitempty"`
	InstanceName     *string `protobuf:"bytes,4,req,name=instance_name" json:"instance_name,omitempty"`
	StreamId         *string `protobuf:"bytes,5,req,name=stream_id" json:"stream_id,omitempty"`
	Stage            *string `protobuf:"bytes,6,req,name=stage" json:"stage,omitempty"`
	Expired          *bool   `protobuf:"varint,7,opt,name=expired" json:"expired,omitempty"`
	TunnelName       *string `protobuf:"bytes,8,opt,name=tunnel_name" json:"tunnel_name,omitempty"`
	Public           *bool   `protobuf:"varint,9,opt,name=public" json:"public,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*TunnelInfo) Descriptor 

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

func (*TunnelInfo) GetExpired 

func (m *TunnelInfo) GetExpired() bool

func (*TunnelInfo) GetInstanceName 

func (m *TunnelInfo) GetInstanceName() string

func (*TunnelInfo) GetPublic 

func (m *TunnelInfo) GetPublic() bool

func (*TunnelInfo) GetStage 

func (m *TunnelInfo) GetStage() string

func (*TunnelInfo) GetStreamId 

func (m *TunnelInfo) GetStreamId() string

func (*TunnelInfo) GetTableName 

func (m *TunnelInfo) GetTableName() string

func (*TunnelInfo) GetTunnelId 

func (m *TunnelInfo) GetTunnelId() string

func (*TunnelInfo) GetTunnelName 

func (m *TunnelInfo) GetTunnelName() string

func (*TunnelInfo) GetTunnelType 

func (m *TunnelInfo) GetTunnelType() string

func (*TunnelInfo) ProtoMessage 

func (*TunnelInfo) ProtoMessage()

func (*TunnelInfo) Reset 

func (m *TunnelInfo) Reset()

func (*TunnelInfo) String 

func (m *TunnelInfo) String() string

type TunnelType 

type TunnelType int32
const (
	TunnelType_BaseData      TunnelType = 1
	TunnelType_Stream        TunnelType = 2
	TunnelType_BaseAndStream TunnelType = 3
)

func (TunnelType) Enum 

func (x TunnelType) Enum() *TunnelType

func (TunnelType) EnumDescriptor 

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

func (TunnelType) String 

func (x TunnelType) String() string

func (*TunnelType) UnmarshalJSON 

func (x *TunnelType) UnmarshalJSON(data []byte) error

type UnlockChannelRequest 

type UnlockChannelRequest struct {
	TunnelId         *string `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	ClientId         *string `protobuf:"bytes,2,req,name=client_id" json:"client_id,omitempty"`
	ChannelId        *string `protobuf:"bytes,3,req,name=channel_id" json:"channel_id,omitempty"`
	LockId           *string `protobuf:"bytes,4,req,name=lock_id" json:"lock_id,omitempty"`
	XXX_unrecognized []byte  `json:"-"`
}

func (*UnlockChannelRequest) Descriptor 

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

func (*UnlockChannelRequest) GetChannelId 

func (m *UnlockChannelRequest) GetChannelId() string

func (*UnlockChannelRequest) GetClientId 

func (m *UnlockChannelRequest) GetClientId() string

func (*UnlockChannelRequest) GetLockId 

func (m *UnlockChannelRequest) GetLockId() string

func (*UnlockChannelRequest) GetTunnelId 

func (m *UnlockChannelRequest) GetTunnelId() string

func (*UnlockChannelRequest) ProtoMessage 

func (*UnlockChannelRequest) ProtoMessage()

func (*UnlockChannelRequest) Reset 

func (m *UnlockChannelRequest) Reset()

func (*UnlockChannelRequest) String 

func (m *UnlockChannelRequest) String() string

type UnlockChannelResponse 

type UnlockChannelResponse struct {
	XXX_unrecognized []byte `json:"-"`
}

func (*UnlockChannelResponse) Descriptor 

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

func (*UnlockChannelResponse) ProtoMessage 

func (*UnlockChannelResponse) ProtoMessage()

func (*UnlockChannelResponse) Reset 

func (m *UnlockChannelResponse) Reset()

func (*UnlockChannelResponse) String 

func (m *UnlockChannelResponse) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.