protocol

package
v1.7.7 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2022 License: Apache-2.0 Imports: 7 Imported by: 1

Documentation

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 StartOffsetFlag_name = map[int32]string{
	0: "LATEST",
	1: "EARLIEST",
}
View Source 
var StartOffsetFlag_value = map[string]int32{
	"LATEST":   0,
	"EARLIEST": 1,
}
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_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `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

func (*Channel) XXX_DiscardUnknown 

func (m *Channel) XXX_DiscardUnknown()

func (*Channel) XXX_Marshal 

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

func (*Channel) XXX_Merge 

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

func (*Channel) XXX_Size 

func (m *Channel) XXX_Size() int

func (*Channel) XXX_Unmarshal 

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

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"`
	ChannelCount         *int64   `protobuf:"varint,6,opt,name=channel_count" json:"channel_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ChannelInfo) Descriptor 

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

func (*ChannelInfo) GetChannelCount 

func (m *ChannelInfo) GetChannelCount() int64

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

func (*ChannelInfo) XXX_DiscardUnknown 

func (m *ChannelInfo) XXX_DiscardUnknown()

func (*ChannelInfo) XXX_Marshal 

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

func (*ChannelInfo) XXX_Merge 

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

func (*ChannelInfo) XXX_Size 

func (m *ChannelInfo) XXX_Size() int

func (*ChannelInfo) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*CheckpointRequest) XXX_DiscardUnknown 

func (m *CheckpointRequest) XXX_DiscardUnknown()

func (*CheckpointRequest) XXX_Marshal 

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

func (*CheckpointRequest) XXX_Merge 

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

func (*CheckpointRequest) XXX_Size 

func (m *CheckpointRequest) XXX_Size() int

func (*CheckpointRequest) XXX_Unmarshal 

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

type CheckpointResponse 

type CheckpointResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*CheckpointResponse) XXX_DiscardUnknown 

func (m *CheckpointResponse) XXX_DiscardUnknown()

func (*CheckpointResponse) XXX_Marshal 

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

func (*CheckpointResponse) XXX_Merge 

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

func (*CheckpointResponse) XXX_Size 

func (m *CheckpointResponse) XXX_Size() int

func (*CheckpointResponse) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*ClientConfig) XXX_DiscardUnknown 

func (m *ClientConfig) XXX_DiscardUnknown()

func (*ClientConfig) XXX_Marshal 

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

func (*ClientConfig) XXX_Merge 

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

func (*ClientConfig) XXX_Size 

func (m *ClientConfig) XXX_Size() int

func (*ClientConfig) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `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

func (*ConnectRequest) XXX_DiscardUnknown 

func (m *ConnectRequest) XXX_DiscardUnknown()

func (*ConnectRequest) XXX_Marshal 

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

func (*ConnectRequest) XXX_Merge 

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

func (*ConnectRequest) XXX_Size 

func (m *ConnectRequest) XXX_Size() int

func (*ConnectRequest) XXX_Unmarshal 

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

type ConnectResponse 

type ConnectResponse struct {
	ClientId             *string  `protobuf:"bytes,1,req,name=client_id" json:"client_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*ConnectResponse) XXX_DiscardUnknown 

func (m *ConnectResponse) XXX_DiscardUnknown()

func (*ConnectResponse) XXX_Marshal 

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

func (*ConnectResponse) XXX_Merge 

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

func (*ConnectResponse) XXX_Size 

func (m *ConnectResponse) XXX_Size() int

func (*ConnectResponse) XXX_Unmarshal 

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

type CreateTunnelRequest 

type CreateTunnelRequest struct {
	Tunnel               *Tunnel  `protobuf:"bytes,1,req,name=tunnel" json:"tunnel,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*CreateTunnelRequest) XXX_DiscardUnknown 

func (m *CreateTunnelRequest) XXX_DiscardUnknown()

func (*CreateTunnelRequest) XXX_Marshal 

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

func (*CreateTunnelRequest) XXX_Merge 

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

func (*CreateTunnelRequest) XXX_Size 

func (m *CreateTunnelRequest) XXX_Size() int

func (*CreateTunnelRequest) XXX_Unmarshal 

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

type CreateTunnelResponse 

type CreateTunnelResponse struct {
	TunnelId             *string  `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*CreateTunnelResponse) XXX_DiscardUnknown 

func (m *CreateTunnelResponse) XXX_DiscardUnknown()

func (*CreateTunnelResponse) XXX_Marshal 

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

func (*CreateTunnelResponse) XXX_Merge 

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

func (*CreateTunnelResponse) XXX_Size 

func (m *CreateTunnelResponse) XXX_Size() int

func (*CreateTunnelResponse) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*DeleteTunnelRequest) XXX_DiscardUnknown 

func (m *DeleteTunnelRequest) XXX_DiscardUnknown()

func (*DeleteTunnelRequest) XXX_Marshal 

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

func (*DeleteTunnelRequest) XXX_Merge 

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

func (*DeleteTunnelRequest) XXX_Size 

func (m *DeleteTunnelRequest) XXX_Size() int

func (*DeleteTunnelRequest) XXX_Unmarshal 

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

type DeleteTunnelResponse 

type DeleteTunnelResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*DeleteTunnelResponse) XXX_DiscardUnknown 

func (m *DeleteTunnelResponse) XXX_DiscardUnknown()

func (*DeleteTunnelResponse) XXX_Marshal 

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

func (*DeleteTunnelResponse) XXX_Merge 

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

func (*DeleteTunnelResponse) XXX_Size 

func (m *DeleteTunnelResponse) XXX_Size() int

func (*DeleteTunnelResponse) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*DescribeTunnelRequest) XXX_DiscardUnknown 

func (m *DescribeTunnelRequest) XXX_DiscardUnknown()

func (*DescribeTunnelRequest) XXX_Marshal 

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

func (*DescribeTunnelRequest) XXX_Merge 

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

func (*DescribeTunnelRequest) XXX_Size 

func (m *DescribeTunnelRequest) XXX_Size() int

func (*DescribeTunnelRequest) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `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

func (*DescribeTunnelResponse) XXX_DiscardUnknown 

func (m *DescribeTunnelResponse) XXX_DiscardUnknown()

func (*DescribeTunnelResponse) XXX_Marshal 

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

func (*DescribeTunnelResponse) XXX_Merge 

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

func (*DescribeTunnelResponse) XXX_Size 

func (m *DescribeTunnelResponse) XXX_Size() int

func (*DescribeTunnelResponse) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*Error) XXX_DiscardUnknown 

func (m *Error) XXX_DiscardUnknown()

func (*Error) XXX_Marshal 

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

func (*Error) XXX_Merge 

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

func (*Error) XXX_Size 

func (m *Error) XXX_Size() int

func (*Error) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*GetCheckpointRequest) XXX_DiscardUnknown 

func (m *GetCheckpointRequest) XXX_DiscardUnknown()

func (*GetCheckpointRequest) XXX_Marshal 

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

func (*GetCheckpointRequest) XXX_Merge 

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

func (*GetCheckpointRequest) XXX_Size 

func (m *GetCheckpointRequest) XXX_Size() int

func (*GetCheckpointRequest) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*GetCheckpointResponse) XXX_DiscardUnknown 

func (m *GetCheckpointResponse) XXX_DiscardUnknown()

func (*GetCheckpointResponse) XXX_Marshal 

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

func (*GetCheckpointResponse) XXX_Merge 

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

func (*GetCheckpointResponse) XXX_Size 

func (m *GetCheckpointResponse) XXX_Size() int

func (*GetCheckpointResponse) XXX_Unmarshal 

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

type GetRpoRequest 

type GetRpoRequest struct {
	TunnelId             *string  `protobuf:"bytes,1,opt,name=tunnel_id" json:"tunnel_id,omitempty"`
	Limit                *int32   `protobuf:"varint,2,opt,name=limit" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRpoRequest) Descriptor 

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

func (*GetRpoRequest) GetLimit added in v1.7.0 

func (m *GetRpoRequest) GetLimit() int32

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

func (*GetRpoRequest) XXX_DiscardUnknown 

func (m *GetRpoRequest) XXX_DiscardUnknown()

func (*GetRpoRequest) XXX_Marshal 

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

func (*GetRpoRequest) XXX_Merge 

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

func (*GetRpoRequest) XXX_Size 

func (m *GetRpoRequest) XXX_Size() int

func (*GetRpoRequest) XXX_Unmarshal 

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

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"`
	TunnelId             *string  `protobuf:"bytes,3,opt,name=tunnel_id" json:"tunnel_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetRpoResponse) Descriptor 

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

func (*GetRpoResponse) GetRpoInfos 

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

func (*GetRpoResponse) GetTunnelId added in v1.7.0 

func (m *GetRpoResponse) GetTunnelId() string

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

func (*GetRpoResponse) XXX_DiscardUnknown 

func (m *GetRpoResponse) XXX_DiscardUnknown()

func (*GetRpoResponse) XXX_Marshal 

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

func (*GetRpoResponse) XXX_Merge 

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

func (*GetRpoResponse) XXX_Size 

func (m *GetRpoResponse) XXX_Size() int

func (*GetRpoResponse) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `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

func (*HeartbeatRequest) XXX_DiscardUnknown 

func (m *HeartbeatRequest) XXX_DiscardUnknown()

func (*HeartbeatRequest) XXX_Marshal 

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

func (*HeartbeatRequest) XXX_Merge 

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

func (*HeartbeatRequest) XXX_Size 

func (m *HeartbeatRequest) XXX_Size() int

func (*HeartbeatRequest) XXX_Unmarshal 

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

type HeartbeatResponse 

type HeartbeatResponse struct {
	Channels             []*Channel `protobuf:"bytes,1,rep,name=channels" json:"channels,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `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

func (*HeartbeatResponse) XXX_DiscardUnknown 

func (m *HeartbeatResponse) XXX_DiscardUnknown()

func (*HeartbeatResponse) XXX_Marshal 

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

func (*HeartbeatResponse) XXX_Merge 

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

func (*HeartbeatResponse) XXX_Size 

func (m *HeartbeatResponse) XXX_Size() int

func (*HeartbeatResponse) XXX_Unmarshal 

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

type ListTunnelRequest 

type ListTunnelRequest struct {
	TableName            *string  `protobuf:"bytes,1,opt,name=table_name" json:"table_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*ListTunnelRequest) XXX_DiscardUnknown 

func (m *ListTunnelRequest) XXX_DiscardUnknown()

func (*ListTunnelRequest) XXX_Marshal 

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

func (*ListTunnelRequest) XXX_Merge 

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

func (*ListTunnelRequest) XXX_Size 

func (m *ListTunnelRequest) XXX_Size() int

func (*ListTunnelRequest) XXX_Unmarshal 

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

type ListTunnelResponse 

type ListTunnelResponse struct {
	Tunnels              []*TunnelInfo `protobuf:"bytes,1,rep,name=tunnels" json:"tunnels,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `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

func (*ListTunnelResponse) XXX_DiscardUnknown 

func (m *ListTunnelResponse) XXX_DiscardUnknown()

func (*ListTunnelResponse) XXX_Marshal 

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

func (*ListTunnelResponse) XXX_Merge 

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

func (*ListTunnelResponse) XXX_Size 

func (m *ListTunnelResponse) XXX_Size() int

func (*ListTunnelResponse) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*LockChannelRequest) XXX_DiscardUnknown 

func (m *LockChannelRequest) XXX_DiscardUnknown()

func (*LockChannelRequest) XXX_Marshal 

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

func (*LockChannelRequest) XXX_Merge 

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

func (*LockChannelRequest) XXX_Size 

func (m *LockChannelRequest) XXX_Size() int

func (*LockChannelRequest) XXX_Unmarshal 

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

type LockChannelResponse 

type LockChannelResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*LockChannelResponse) XXX_DiscardUnknown 

func (m *LockChannelResponse) XXX_DiscardUnknown()

func (*LockChannelResponse) XXX_Marshal 

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

func (*LockChannelResponse) XXX_Merge 

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

func (*LockChannelResponse) XXX_Size 

func (m *LockChannelResponse) XXX_Size() int

func (*LockChannelResponse) XXX_Unmarshal 

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

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       *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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*ReadRecordsRequest) XXX_DiscardUnknown 

func (m *ReadRecordsRequest) XXX_DiscardUnknown()

func (*ReadRecordsRequest) XXX_Marshal 

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

func (*ReadRecordsRequest) XXX_Merge 

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

func (*ReadRecordsRequest) XXX_Size 

func (m *ReadRecordsRequest) XXX_Size() int

func (*ReadRecordsRequest) XXX_Unmarshal 

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

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"`
	MayMoreRecord        *bool     `protobuf:"varint,3,opt,name=may_more_record" json:"may_more_record,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*ReadRecordsResponse) Descriptor 

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

func (*ReadRecordsResponse) GetMayMoreRecord added in v1.7.7 

func (m *ReadRecordsResponse) GetMayMoreRecord() bool

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

func (*ReadRecordsResponse) XXX_DiscardUnknown 

func (m *ReadRecordsResponse) XXX_DiscardUnknown()

func (*ReadRecordsResponse) XXX_Marshal 

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

func (*ReadRecordsResponse) XXX_Merge 

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

func (*ReadRecordsResponse) XXX_Size 

func (m *ReadRecordsResponse) XXX_Size() int

func (*ReadRecordsResponse) XXX_Unmarshal 

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

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"`
	OriginRecord         []byte      `protobuf:"bytes,3,opt,name=origin_record" json:"origin_record,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Record) Descriptor 

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

func (*Record) GetActionType 

func (m *Record) GetActionType() ActionType

func (*Record) GetOriginRecord added in v1.7.5 

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

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

func (*Record) XXX_DiscardUnknown 

func (m *Record) XXX_DiscardUnknown()

func (*Record) XXX_Marshal 

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

func (*Record) XXX_Merge 

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

func (*Record) XXX_Size 

func (m *Record) XXX_Size() int

func (*Record) XXX_Unmarshal 

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

type RecordSequenceInfo added in v1.7.3 

type RecordSequenceInfo struct {
	Epoch     int32
	Timestamp int64
	RowIndex  int32
}

func (*RecordSequenceInfo) String added in v1.7.3 

func (this *RecordSequenceInfo) String() string

type ScheduleRequest 

type ScheduleRequest struct {
	TunnelId             *string    `protobuf:"bytes,1,req,name=tunnel_id" json:"tunnel_id,omitempty"`
	Channels             []*Channel `protobuf:"bytes,3,rep,name=channels" json:"channels,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ScheduleRequest) Descriptor 

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

func (*ScheduleRequest) GetChannels 

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

func (*ScheduleRequest) GetTunnelId 

func (m *ScheduleRequest) GetTunnelId() string

func (*ScheduleRequest) ProtoMessage 

func (*ScheduleRequest) ProtoMessage()

func (*ScheduleRequest) Reset 

func (m *ScheduleRequest) Reset()

func (*ScheduleRequest) String 

func (m *ScheduleRequest) String() string

func (*ScheduleRequest) XXX_DiscardUnknown 

func (m *ScheduleRequest) XXX_DiscardUnknown()

func (*ScheduleRequest) XXX_Marshal 

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

func (*ScheduleRequest) XXX_Merge 

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

func (*ScheduleRequest) XXX_Size 

func (m *ScheduleRequest) XXX_Size() int

func (*ScheduleRequest) XXX_Unmarshal 

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

type ScheduleResponse 

type ScheduleResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ScheduleResponse) Descriptor 

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

func (*ScheduleResponse) ProtoMessage 

func (*ScheduleResponse) ProtoMessage()

func (*ScheduleResponse) Reset 

func (m *ScheduleResponse) Reset()

func (*ScheduleResponse) String 

func (m *ScheduleResponse) String() string

func (*ScheduleResponse) XXX_DiscardUnknown 

func (m *ScheduleResponse) XXX_DiscardUnknown()

func (*ScheduleResponse) XXX_Marshal 

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

func (*ScheduleResponse) XXX_Merge 

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

func (*ScheduleResponse) XXX_Size 

func (m *ScheduleResponse) XXX_Size() int

func (*ScheduleResponse) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*ShutdownRequest) XXX_DiscardUnknown 

func (m *ShutdownRequest) XXX_DiscardUnknown()

func (*ShutdownRequest) XXX_Marshal 

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

func (*ShutdownRequest) XXX_Merge 

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

func (*ShutdownRequest) XXX_Size 

func (m *ShutdownRequest) XXX_Size() int

func (*ShutdownRequest) XXX_Unmarshal 

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

type ShutdownResponse 

type ShutdownResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*ShutdownResponse) XXX_DiscardUnknown 

func (m *ShutdownResponse) XXX_DiscardUnknown()

func (*ShutdownResponse) XXX_Marshal 

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

func (*ShutdownResponse) XXX_Merge 

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

func (*ShutdownResponse) XXX_Size 

func (m *ShutdownResponse) XXX_Size() int

func (*ShutdownResponse) XXX_Unmarshal 

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

type StartOffsetFlag 

type StartOffsetFlag int32
const (
	StartOffsetFlag_LATEST   StartOffsetFlag = 0
	StartOffsetFlag_EARLIEST StartOffsetFlag = 1
)

func (StartOffsetFlag) Enum 

func (x StartOffsetFlag) Enum() *StartOffsetFlag

func (StartOffsetFlag) EnumDescriptor 

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

func (StartOffsetFlag) String 

func (x StartOffsetFlag) String() string

func (*StartOffsetFlag) UnmarshalJSON 

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

type StreamTunnelConfig 

type StreamTunnelConfig struct {
	Flag                 *StartOffsetFlag `protobuf:"varint,1,opt,name=flag,enum=protocol.StartOffsetFlag" json:"flag,omitempty"`
	StartOffset          *uint64          `protobuf:"varint,2,opt,name=startOffset" json:"startOffset,omitempty"`
	EndOffset            *uint64          `protobuf:"varint,3,opt,name=endOffset" json:"endOffset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*StreamTunnelConfig) Descriptor 

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

func (*StreamTunnelConfig) GetEndOffset 

func (m *StreamTunnelConfig) GetEndOffset() uint64

func (*StreamTunnelConfig) GetFlag 

func (m *StreamTunnelConfig) GetFlag() StartOffsetFlag

func (*StreamTunnelConfig) GetStartOffset 

func (m *StreamTunnelConfig) GetStartOffset() uint64

func (*StreamTunnelConfig) ProtoMessage 

func (*StreamTunnelConfig) ProtoMessage()

func (*StreamTunnelConfig) Reset 

func (m *StreamTunnelConfig) Reset()

func (*StreamTunnelConfig) String 

func (m *StreamTunnelConfig) String() string

func (*StreamTunnelConfig) XXX_DiscardUnknown 

func (m *StreamTunnelConfig) XXX_DiscardUnknown()

func (*StreamTunnelConfig) XXX_Marshal 

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

func (*StreamTunnelConfig) XXX_Merge 

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

func (*StreamTunnelConfig) XXX_Size 

func (m *StreamTunnelConfig) XXX_Size() int

func (*StreamTunnelConfig) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*Token) XXX_DiscardUnknown 

func (m *Token) XXX_DiscardUnknown()

func (*Token) XXX_Marshal 

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

func (*Token) XXX_Merge 

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

func (*Token) XXX_Size 

func (m *Token) XXX_Size() int

func (*Token) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*TokenContent) XXX_DiscardUnknown 

func (m *TokenContent) XXX_DiscardUnknown()

func (*TokenContent) XXX_Marshal 

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

func (*TokenContent) XXX_Merge 

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

func (*TokenContent) XXX_Size 

func (m *TokenContent) XXX_Size() int

func (*TokenContent) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*TokenContentV2) XXX_DiscardUnknown 

func (m *TokenContentV2) XXX_DiscardUnknown()

func (*TokenContentV2) XXX_Marshal 

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

func (*TokenContentV2) XXX_Merge 

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

func (*TokenContentV2) XXX_Size 

func (m *TokenContentV2) XXX_Size() int

func (*TokenContentV2) XXX_Unmarshal 

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

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"`
	StreamTunnelConfig       *StreamTunnelConfig `protobuf:"bytes,5,opt,name=stream_tunnel_config" json:"stream_tunnel_config,omitempty"`
	NeedAllTimeSeriesColumns *bool               `protobuf:"varint,6,opt,name=need_all_time_series_columns" json:"need_all_time_series_columns,omitempty"`
	XXX_NoUnkeyedLiteral     struct{}            `json:"-"`
	XXX_unrecognized         []byte              `json:"-"`
	XXX_sizecache            int32               `json:"-"`
}

func (*Tunnel) Descriptor 

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

func (*Tunnel) GetNeedAllTimeSeriesColumns added in v1.7.4 

func (m *Tunnel) GetNeedAllTimeSeriesColumns() bool

func (*Tunnel) GetStreamTunnelConfig 

func (m *Tunnel) GetStreamTunnelConfig() *StreamTunnelConfig

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

func (*Tunnel) XXX_DiscardUnknown 

func (m *Tunnel) XXX_DiscardUnknown()

func (*Tunnel) XXX_Marshal 

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

func (*Tunnel) XXX_Merge 

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

func (*Tunnel) XXX_Size 

func (m *Tunnel) XXX_Size() int

func (*Tunnel) XXX_Unmarshal 

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

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"`
	StreamTunnelConfig   *StreamTunnelConfig `protobuf:"bytes,10,opt,name=stream_tunnel_config" json:"stream_tunnel_config,omitempty"`
	CreateTime           *int64              `protobuf:"varint,11,opt,name=create_time" json:"create_time,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*TunnelInfo) Descriptor 

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

func (*TunnelInfo) GetCreateTime 

func (m *TunnelInfo) GetCreateTime() int64

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) GetStreamTunnelConfig 

func (m *TunnelInfo) GetStreamTunnelConfig() *StreamTunnelConfig

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

func (*TunnelInfo) XXX_DiscardUnknown 

func (m *TunnelInfo) XXX_DiscardUnknown()

func (*TunnelInfo) XXX_Marshal 

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

func (*TunnelInfo) XXX_Merge 

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

func (*TunnelInfo) XXX_Size 

func (m *TunnelInfo) XXX_Size() int

func (*TunnelInfo) XXX_Unmarshal 

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

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_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*UnlockChannelRequest) XXX_DiscardUnknown 

func (m *UnlockChannelRequest) XXX_DiscardUnknown()

func (*UnlockChannelRequest) XXX_Marshal 

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

func (*UnlockChannelRequest) XXX_Merge 

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

func (*UnlockChannelRequest) XXX_Size 

func (m *UnlockChannelRequest) XXX_Size() int

func (*UnlockChannelRequest) XXX_Unmarshal 

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

type UnlockChannelResponse 

type UnlockChannelResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `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

func (*UnlockChannelResponse) XXX_DiscardUnknown 

func (m *UnlockChannelResponse) XXX_DiscardUnknown()

func (*UnlockChannelResponse) XXX_Marshal 

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

func (*UnlockChannelResponse) XXX_Merge 

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

func (*UnlockChannelResponse) XXX_Size 

func (m *UnlockChannelResponse) XXX_Size() int

func (*UnlockChannelResponse) XXX_Unmarshal 

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