store

Documentation

Index

• type BinlogRedisStore
  • func NewBinlogRedisStore(key string) *BinlogRedisStore
  • func (b *BinlogRedisStore) Pos() (string, uint32, error)
  • func (b *BinlogRedisStore) Save(file string, pos uint32) error
• type MongoPos
• type MongoPosInterface
• type MysqlPosInterface
• type StreamRedisStore
  • func NewStreamRedisStore(key string) *StreamRedisStore
  • func (s *StreamRedisStore) Pos() (string, error)
  • func (s *StreamRedisStore) Save(token string) error
• type SyncerPos
• type SyncerPosInterface
• type SyncerPosMgoStore
  • func NewSyncerPosMgoStore(coll *mongo.Collection, key string, timeout time.Duration) *SyncerPosMgoStore
  • func (s *SyncerPosMgoStore) Pos() (*SyncerPos, error)
  • func (s *SyncerPosMgoStore) Save(pos interface{}, unix ...int64) error

Types

type BinlogRedisStore

type BinlogRedisStore struct {
	// contains filtered or unexported fields
}

func NewBinlogRedisStore

func NewBinlogRedisStore(key string) *BinlogRedisStore

func (*BinlogRedisStore) Pos

func (b *BinlogRedisStore) Pos() (string, uint32, error)

func (*BinlogRedisStore) Save

func (b *BinlogRedisStore) Save(file string, pos uint32) error

type MongoPos

type MongoPos struct {
	Value   string
	Version int64
}

type MongoPosInterface

type MongoPosInterface interface {
	Pos() (string, error)
	Save(string) error
}

type MysqlPosInterface

type MysqlPosInterface interface {
	Pos() (string, uint32, error)
	Save(string, uint32) error
}

type StreamRedisStore

type StreamRedisStore struct {
	// contains filtered or unexported fields
}

func NewStreamRedisStore

func NewStreamRedisStore(key string) *StreamRedisStore

func (*StreamRedisStore) Pos

func (s *StreamRedisStore) Pos() (string, error)

func (*StreamRedisStore) Save

func (s *StreamRedisStore) Save(token string) error

type SyncerPos

type SyncerPos struct {
	SyncStartTimestamp int64
	SyncEndTimestamp   int64
	Pos                int64
	LastSyncTime       int64
}

type SyncerPosInterface

type SyncerPosInterface interface {
	Pos() (*SyncerPos, error)
	Save(interface{}, ...int64) error
}

type SyncerPosMgoStore

type SyncerPosMgoStore struct {
	PosKey  string
	Timeout time.Duration
	// contains filtered or unexported fields
}

func NewSyncerPosMgoStore

func NewSyncerPosMgoStore(coll *mongo.Collection, key string,
	timeout time.Duration) *SyncerPosMgoStore

func (*SyncerPosMgoStore) Pos

func (s *SyncerPosMgoStore) Pos() (*SyncerPos, error)

func (*SyncerPosMgoStore) Save

func (s *SyncerPosMgoStore) Save(pos interface{}, unix ...int64) error