token

type Manager ¶

type Manager interface {
	Get() (bson.Raw, error)
	Set(bson.Raw) error
	Close()
}

Manager interface can be used to customize how to get and update latest resume token.

func NewRedisManager(uri string, key string) (Manager, error)

type RedisManager ¶

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

RedisManager store the latest resume token into redis.

The token is stored as a string in extended json format. For details about extended json, see https://docs.mongodb.com/manual/reference/mongodb-extended-json/.

func (r *RedisManager) Close()

func (r *RedisManager) Get() (bson.Raw, error)

func (r *RedisManager) Set(b bson.Raw) error