tunnel

package

Go to main page

Versions in this module

v1

v1.8.0-rc.1

Feb 28, 2023

v1.7.14

Jan 19, 2024

v1.7.13

Jan 18, 2024

v1.7.12

Jan 8, 2024

v1.7.11

Sep 20, 2023

v1.7.10

Aug 28, 2023

v1.7.9

Aug 2, 2023

v1.7.8

Jul 26, 2023

Changes in this version

type ChannelProcessor

+ SetFinished func(bool)

v1.7.7

Sep 20, 2022

Changes in this version

type ReadRecordResponse

+ MayMoreRecord *bool

v1.7.6

May 31, 2022

v1.7.5

May 26, 2022

Changes in this version

type PrimaryKeyColumn

+ func (p *PrimaryKeyColumn) String() string

type Record

+ OriginColumns []*RecordColumn

v1.7.4

Apr 21, 2022

Changes in this version

type CreateTunnelRequest

+ NeedAllTimeSeriesColumns bool

v1.7.3

Mar 15, 2022

Changes in this version

+ const TAG_ACTION_TYPE

+ const TAG_RECORD

+ const TAG_RECORD_COUNT

+ const TAG_RECORD_LENGTH

+ const TAG_VERSION

+ var ErrUnExpectBinaryRecordTag = errors.New("UnexpectBinaryRecordTag")

+ var ErrUnSupportRecordVersion = errors.New("UnSupportRecordVersion")

+ type AsyncProcessFactory struct

+ AlwaysCallBack bool

+ ChannelOpenFunc func(channelCtx *ChannelContext) error

+ CpInterval time.Duration

+ CustomValue interface{}

+ Logger *zap.Logger

+ NeedBinaryRecord bool

+ ProcessFunc func(channelCtx *ChannelContext, records []*Record) error

+ RecordPipePerChannel *int

+ ShutdownFunc func(channelCtx *ChannelContext)

+ SyncCloseResource bool

+ func (s *AsyncProcessFactory) NewProcessor(tunnelId, clientId, channelId string, checkpointer Checkpointer) (ChannelProcessor, error)

type ChannelContext

+ BinaryRecords []byte

+ IsStreamChannel bool

+ ParallelReleaseManager ParallelReleaseManager

+ Processor ChannelProcessor

+ RecordCount int

type ChannelProcessor

+ CommitToken func(token string) error

+ type ClientOption func(api *TunnelApi)

+ func SetCredentialsProvider(provider common.CredentialsProvider) ClientOption

+ type ParallelReleaseManager interface

+ Release func() bool

+ type ReadRecordRequest struct

+ ChannelId string

+ ClientId string

+ NeedBinaryRecord bool

+ Token string

+ TunnelId string

+ type ReadRecordResponse struct

+ BinaryRecords []byte

+ NextToken string

+ RecordCount int

+ Records []*Record

+ Size int

type Record

+ func UnSerializeBatchBinaryRecordFromBytes(data []byte) (record []*Record, err error)

+ func UnSerializeBinaryRecordFromBytes(r *bytes.Reader) (*Record, error)

type SimpleProcessFactory

+ AlwaysCallBack bool

+ ChannelOpenFunc func(channelCtx *ChannelContext) error

+ NeedBinaryRecord bool

+ RecordPipePerChannel *int

+ SyncCloseResource bool

type TunnelWorkerConfig

+ MaxChannelParallel int

+ NeedManualRelease bool

+ SyncReadRecords bool

v1.7.1

Nov 2, 2021

v1.7.0

Oct 27, 2021

Changes in this version

type DefaultTunnelClient

+ func (c *DefaultTunnelClient) GetRpoByOffset(req *GetRpoRequest) (*GetRpoResponse, error)

type GetRpoResponse

+ TunnelId string

type MockTunnelMetaApi

+ func (m *MockTunnelMetaApi) GetRpoByOffset(req *GetRpoRequest) (*GetRpoResponse, error)

type MockTunnelMetaApiMockRecorder

+ func (mr *MockTunnelMetaApiMockRecorder) GetRpoByOffset(req interface{}) *gomock.Call

type TunnelApi

+ func NewTunnelApiWithExternalHeader(endpoint, instanceName, accessKeyId, accessKeySecret, token string, ...) *TunnelApi

+ func (api *TunnelApi) GetRpoByOffset(req *GetRpoRequest) (*GetRpoResponse, error)

type TunnelClient

+ func NewTunnelClientWithConfigAndExternalHeader(endpoint, instanceName, accessId, accessKey, token string, conf *TunnelConfig, ...) TunnelClient

+ func NewTunnelClientWithExternalHeader(endpoint, instanceName, accessId, accessKey, token string, ...) TunnelClient

type TunnelMetaApi

+ GetRpoByOffset func(req *GetRpoRequest) (resp *GetRpoResponse, err error)

v1.6.0

Feb 26, 2021

Changes in this version

+ var PipeChannelSize = 1

type ChannelContext

+ func NewChannelContext(tunnelId, clientId, channelId string, customValue interface{}) *ChannelContext

type ChannelProcessor

+ Error func() bool

+ Finished func() bool

type MocktunnelDataApi

+ func (m *MocktunnelDataApi) ReadRecords(tunnelId, clientId, channelId, token string) ([]*Record, string, string, int, error)

type MocktunnelDataApiMockRecorder

+ func (mr *MocktunnelDataApiMockRecorder) ReadRecords(tunnelId, clientId, channelId, token interface{}) *gomock.Call

type SequenceInfo

+ func ParseSerializedSeqInfo(hexedSeqStr string) (*SequenceInfo, error)

+ func (si *SequenceInfo) Serialization() string

type TunnelApi

+ func (api *TunnelApi) Checkpoint(tunnelId, clientId string, channelId string, token string, ...) error

+ func (api *TunnelApi) GetCheckpoint(tunnelId, clientId string, channelId string) (string, int64, error)

+ func (api *TunnelApi) ReadRecords(tunnelId, clientId string, channelId string, token string) ([]*Record, string, string, int, error)

+ func (api *TunnelApi) ReadRows(tunnelId, clientId string, channelId string, token string) ([]*protocol.Record, string, string, int, error)

v1.5.0

Dec 25, 2019

Changes in this version

+ const ErrCodeClientError

+ const ErrCodeParamInvalid

+ const ErrCodePermissionDenied

+ const ErrCodeResourceGone

+ const ErrCodeSequenceNotMatch

+ const ErrCodeServerUnavailable

+ const ErrCodeTunnelExist

+ const ErrCodeTunnelExpired

+ var DaemonRandomRetryMs = 10000

+ var DefaultBackoffConfig = ChannelBackoffConfig

+ var DefaultChannelSize = 10

+ var DefaultCheckpointInterval = 10 * time.Second

+ var DefaultHeartbeatInterval = 30 * time.Second

+ var DefaultHeartbeatTimeout = 300 * time.Second

+ var DefaultLogConfig = zap.Config

+ var DefaultSyncer = zapcore.AddSync(&lumberjack.Logger{ ... })

+ var DefaultTunnelConfig = &TunnelConfig

+ func ExponentialBackoff(interval, maxInterval, maxElapsed time.Duration, multiplier, jitter float64) *backoff.ExponentialBackOff

+ func ParseRequestToken(token string) (*protocol.TokenContentV2, error)

+ func ReplaceLogCore(ws zapcore.WriteSyncer, conf zap.Config) zap.Option

+ func StreamRecordSequenceLess(a, b *SequenceInfo) bool

+ type ActionType int

+ const AT_Delete

+ const AT_Put

+ const AT_Update

+ func ParseActionType(pbType *protocol.ActionType) (ActionType, error)

+ func (t ActionType) String() string

+ type BatchGetStatusReq struct

+ func NewBatchGetStatusReq() *BatchGetStatusReq

+ type ChannelBackoffConfig struct

+ MaxDelay time.Duration

+ type ChannelConn interface

+ Close func()

+ Closed func() bool

+ NotifyStatus func(channel *ChannelStatus)

+ type ChannelContext struct

+ ChannelId string

+ ClientId string

+ CustomValue interface{}

+ NextToken string

+ TraceId string

+ TunnelId string

+ func (c *ChannelContext) String() string

+ type ChannelDialer interface

+ ChannelDial func(tunnelId, clientId, channelId, token string, p ChannelProcessor, ...) ChannelConn

+ type ChannelInfo struct

+ ChannelId string

+ ChannelRPO int64

+ ChannelStatus string

+ ChannelType string

+ ClientId string

+ type ChannelProcessor interface

+ Process func(records []*Record, nextToken, traceId string) error

+ Shutdown func()

+ type ChannelProcessorFactory interface

+ NewProcessor func(tunnelId, clientId, channelId string, checkpointer Checkpointer) ChannelProcessor

+ type ChannelStatus struct

+ ChannelId string

+ Status protocol.ChannelStatus

+ Version int64

+ func ToChannelStatus(c *protocol.Channel) *ChannelStatus

+ func (c *ChannelStatus) ToPbChannel() *protocol.Channel

+ type ChannelType string

+ const ChannelType_BaseData

+ const ChannelType_Stream

+ type Checkpointer interface

+ Checkpoint func(token string) error

+ type CreateTunnelRequest struct

+ StreamTunnelConfig *StreamTunnelConfig

+ TableName string

+ TunnelName string

+ Type TunnelType

+ type CreateTunnelResponse struct

+ TunnelId string

+ type DefaultTunnelClient struct

+ func (c *DefaultTunnelClient) CreateTunnel(req *CreateTunnelRequest) (*CreateTunnelResponse, error)

+ func (c *DefaultTunnelClient) DeleteTunnel(req *DeleteTunnelRequest) (*DeleteTunnelResponse, error)

+ func (c *DefaultTunnelClient) DescribeTunnel(req *DescribeTunnelRequest) (*DescribeTunnelResponse, error)

+ func (c *DefaultTunnelClient) GetRpo(req *GetRpoRequest) (*GetRpoResponse, error)

+ func (c *DefaultTunnelClient) ListTunnel(req *ListTunnelRequest) (*ListTunnelResponse, error)

+ func (c *DefaultTunnelClient) NewTunnelWorker(tunnelId string, workerConfig *TunnelWorkerConfig) (TunnelWorker, error)

+ func (c *DefaultTunnelClient) Schedule(req *ScheduleRequest) (*ScheduleResponse, error)

+ type DeleteTunnelRequest struct

+ TableName string

+ TunnelName string

+ type DeleteTunnelResponse struct

+ type DescribeTunnelRequest struct

+ TableName string

+ TunnelName string

+ type DescribeTunnelResponse struct

+ Channels []*ChannelInfo

+ Tunnel *TunnelInfo

+ TunnelRPO int64

+ type GetRpoRequest struct

+ TunnelId string

+ type GetRpoResponse struct

+ RpoInfos map[string]map[string]*RpoLatency

+ TunnelRpoInfos map[string]*TunnelRpoLatency

+ type ListTunnelRequest struct

+ TableName string

+ type ListTunnelResponse struct

+ Tunnels []*TunnelInfo

+ type MockTunnelMetaApi struct

+ func NewMockTunnelMetaApi(ctrl *gomock.Controller) *MockTunnelMetaApi

+ func (m *MockTunnelMetaApi) CreateTunnel(req *CreateTunnelRequest) (*CreateTunnelResponse, error)

+ func (m *MockTunnelMetaApi) DeleteTunnel(req *DeleteTunnelRequest) (*DeleteTunnelResponse, error)

+ func (m *MockTunnelMetaApi) DescribeTunnel(req *DescribeTunnelRequest) (*DescribeTunnelResponse, error)

+ func (m *MockTunnelMetaApi) EXPECT() *MockTunnelMetaApiMockRecorder

+ func (m *MockTunnelMetaApi) GetRpo(req *GetRpoRequest) (*GetRpoResponse, error)

+ func (m *MockTunnelMetaApi) ListTunnel(req *ListTunnelRequest) (*ListTunnelResponse, error)

+ func (m *MockTunnelMetaApi) NewTunnelWorker(tunnelId string, workerConfig *TunnelWorkerConfig) (TunnelWorker, error)

+ func (m *MockTunnelMetaApi) Schedule(req *ScheduleRequest) (*ScheduleResponse, error)

+ type MockTunnelMetaApiMockRecorder struct

+ func (mr *MockTunnelMetaApiMockRecorder) CreateTunnel(req interface{}) *gomock.Call

+ func (mr *MockTunnelMetaApiMockRecorder) DeleteTunnel(req interface{}) *gomock.Call

+ func (mr *MockTunnelMetaApiMockRecorder) DescribeTunnel(req interface{}) *gomock.Call

+ func (mr *MockTunnelMetaApiMockRecorder) GetRpo(req interface{}) *gomock.Call

+ func (mr *MockTunnelMetaApiMockRecorder) ListTunnel(req interface{}) *gomock.Call

+ func (mr *MockTunnelMetaApiMockRecorder) NewTunnelWorker(tunnelId, workerConfig interface{}) *gomock.Call

+ func (mr *MockTunnelMetaApiMockRecorder) Schedule(req interface{}) *gomock.Call

+ type MockTunnelWorker struct

+ func NewMockTunnelWorker(ctrl *gomock.Controller) *MockTunnelWorker

+ func (m *MockTunnelWorker) ConnectAndWorking() error

+ func (m *MockTunnelWorker) EXPECT() *MockTunnelWorkerMockRecorder

+ func (m *MockTunnelWorker) Shutdown()

+ type MockTunnelWorkerMockRecorder struct

+ func (mr *MockTunnelWorkerMockRecorder) ConnectAndWorking() *gomock.Call

+ func (mr *MockTunnelWorkerMockRecorder) Shutdown() *gomock.Call

+ type MocktunnelDataApi struct

+ func NewMocktunnelDataApi(ctrl *gomock.Controller) *MocktunnelDataApi

+ func (m *MocktunnelDataApi) EXPECT() *MocktunnelDataApiMockRecorder

+ type MocktunnelDataApiMockRecorder struct

+ type PrimaryKey struct

+ PrimaryKeys []*PrimaryKeyColumn

+ type PrimaryKeyColumn struct

+ ColumnName string

+ Value interface{}

+ type Record struct

+ Columns []*RecordColumn

+ PrimaryKey *PrimaryKey

+ SequenceInfo *SequenceInfo

+ Timestamp int64

+ Type ActionType

+ func DeserializeRecordFromRawBytes(data []byte, actionType ActionType) (*Record, error)

+ func (r *Record) String() string

+ type RecordColumn struct

+ Name *string

+ Timestamp *int64

+ Type RecordColumnType

+ Value interface{}

+ func (c *RecordColumn) String() string

+ type RecordColumnType int

+ const RCT_DeleteAllVersions

+ const RCT_DeleteOneVersion

+ const RCT_Put

+ type ResponseInfo struct

+ RequestId string

+ type RpoLatency struct

+ AccessTime int64

+ ChannelTyp ChannelType

+ RpoTime int64

+ Status string

+ TotalCount int64

+ type ScheduleChannel struct

+ ChannelId string

+ ChannelStatus protocol.ChannelStatus

+ func OpenChannel(channelId string) *ScheduleChannel

+ func ResumeChannel(channelId string) *ScheduleChannel

+ func SuspendChannel(channelId string) *ScheduleChannel

+ func TerminateChannel(channelId string) *ScheduleChannel

+ type ScheduleRequest struct

+ Channels []*ScheduleChannel

+ TunnelId string

+ type ScheduleResponse struct

+ type SequenceInfo struct

+ Epoch int32

+ RowIndex int32

+ Timestamp int64

+ type SimpleProcessFactory struct

+ CpInterval time.Duration

+ CustomValue interface{}

+ Logger *zap.Logger

+ ProcessFunc func(channelCtx *ChannelContext, records []*Record) error

+ ShutdownFunc func(channelCtx *ChannelContext)

+ func (s *SimpleProcessFactory) NewProcessor(tunnelId, clientId, channelId string, checkpointer Checkpointer) ChannelProcessor

+ type StreamTunnelConfig struct

+ EndOffset uint64

+ Flag protocol.StartOffsetFlag

+ StartOffset uint64

+ type TunnelApi struct

+ func NewTunnelApi(endpoint, instanceName, accessKeyId, accessKeySecret string, ...) *TunnelApi

+ func NewTunnelApiWithToken(endpoint, instanceName, accessKeyId, accessKeySecret, token string, ...) *TunnelApi

+ func (api *TunnelApi) CreateTunnel(req *CreateTunnelRequest) (*CreateTunnelResponse, error)

+ func (api *TunnelApi) DeleteTunnel(req *DeleteTunnelRequest) (*DeleteTunnelResponse, error)

+ func (api *TunnelApi) DescribeTunnel(req *DescribeTunnelRequest) (*DescribeTunnelResponse, error)

+ func (api *TunnelApi) GetRpo(req *GetRpoRequest) (*GetRpoResponse, error)

+ func (api *TunnelApi) ListTunnel(req *ListTunnelRequest) (*ListTunnelResponse, error)

+ func (api *TunnelApi) Schedule(req *ScheduleRequest) (*ScheduleResponse, error)

+ type TunnelClient interface

+ NewTunnelWorker func(tunnelId string, workerConfig *TunnelWorkerConfig) (TunnelWorker, error)

+ func NewTunnelClient(endpoint, instanceName, accessId, accessKey string) TunnelClient

+ func NewTunnelClientWithConfig(endpoint, instanceName, accessId, accessKey string, conf *TunnelConfig) TunnelClient

+ func NewTunnelClientWithToken(endpoint, instanceName, accessId, accessKey, token string, conf *TunnelConfig) TunnelClient

+ type TunnelConfig struct

+ MaxRetryElapsedTime time.Duration

+ RequestTimeout time.Duration

+ Transport http.RoundTripper

+ type TunnelError struct

+ Code string

+ Message string

+ RequestId string

+ TunnelId string

+ func (te *TunnelError) Error() string

+ func (te *TunnelError) Temporary() bool

+ type TunnelInfo struct

+ CreateTime time.Time

+ Expired bool

+ InstanceName string

+ Stage string

+ StreamId string

+ StreamTunnelConfig *StreamTunnelConfig

+ TableName string

+ TunnelId string

+ TunnelName string

+ TunnelType string

+ type TunnelMetaApi interface

+ CreateTunnel func(req *CreateTunnelRequest) (resp *CreateTunnelResponse, err error)

+ DeleteTunnel func(req *DeleteTunnelRequest) (resp *DeleteTunnelResponse, err error)

+ DescribeTunnel func(req *DescribeTunnelRequest) (resp *DescribeTunnelResponse, err error)

+ GetRpo func(req *GetRpoRequest) (resp *GetRpoResponse, err error)

+ ListTunnel func(req *ListTunnelRequest) (resp *ListTunnelResponse, err error)

+ Schedule func(req *ScheduleRequest) (resp *ScheduleResponse, err error)

+ type TunnelRpoLatency struct

+ AccessTime int64

+ RpoTime int64

+ Status string

+ TotalCount int64

+ type TunnelStateMachine struct

+ func NewTunnelStateMachine(tunnelId, clientId string, dialer ChannelDialer, ...) *TunnelStateMachine

+ func (s *TunnelStateMachine) BatchGetStatus(req *BatchGetStatusReq) ([]*protocol.Channel, error)

+ func (s *TunnelStateMachine) BatchUpdateStatus(batchChannels []*protocol.Channel)

+ func (s *TunnelStateMachine) Close()

+ func (s *TunnelStateMachine) UpdateStatus(channel *ChannelStatus)

+ type TunnelType string

+ const FinishTag

+ const TunnelTypeBaseData

+ const TunnelTypeBaseStream

+ const TunnelTypeStream

+ type TunnelWorker interface

+ ConnectAndWorking func() error

+ Shutdown func()

+ type TunnelWorkerConfig struct

+ BackoffConfig *ChannelBackoffConfig

+ ChannelDialer ChannelDialer

+ HeartbeatInterval time.Duration

+ HeartbeatTimeout time.Duration

+ LogConfig *zap.Config

+ LogWriteSyncer zapcore.WriteSyncer

+ ProcessorFactory ChannelProcessorFactory

+ type TunnelWorkerDaemon struct

+ func NewTunnelDaemon(c TunnelClient, id string, conf *TunnelWorkerConfig) *TunnelWorkerDaemon

+ func (d *TunnelWorkerDaemon) Close()

+ func (d *TunnelWorkerDaemon) Run() error

Incompatible versions in this module

v4.1.3+incompatible

Jul 10, 2019

v4.1.2+incompatible

Jan 16, 2019

Other modules containing this package

github.com/aliyun/aliyun-tablestore-go-sdk/v5

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL