protocol

package
Version: 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL