tunnel

package

Go to main page

Versions in this module

v5

v5.0.6

Jul 30, 2020

v5.0.5

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)

v5.0.3

Jul 30, 2020

v5.0.2

Jan 20, 2020

v5.0.1

Jan 16, 2020

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

Other modules containing this package

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

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