redischeckpointer

Documentation

Index

• type Checkpointer
  • func New(opt *Options) (*Checkpointer, error)
  • func (r *Checkpointer) Begin() error
  • func (r *Checkpointer) DoneC() chan<- k.Record
  • func (r *Checkpointer) End()
  • func (r *Checkpointer) GetStartSequence(shardID string) string
  • func (r *Checkpointer) RunCheckpointer()
  • func (r *Checkpointer) Sync()
• type Error
  • func (e *Error) Error() string
  • func (e *Error) Origin() error
  • func (e *Error) Severity() string
• type Options

Types

type Checkpointer

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

func New

func New(opt *Options) (*Checkpointer, error)

func (*Checkpointer) Begin

func (r *Checkpointer) Begin() error

func (*Checkpointer) DoneC

func (r *Checkpointer) DoneC() chan<- k.Record

func (*Checkpointer) End

func (r *Checkpointer) End()

func (*Checkpointer) GetStartSequence

func (r *Checkpointer) GetStartSequence(shardID string) string

func (*Checkpointer) RunCheckpointer

func (r *Checkpointer) RunCheckpointer()

func (*Checkpointer) Sync

func (r *Checkpointer) Sync()

type Error

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

func (*Error) Error

func (e *Error) Error() string

func (*Error) Origin

func (e *Error) Origin() error

func (*Error) Severity

func (e *Error) Severity() string

type Options

type Options struct {
	ReadOnly    bool
	SavePeriod  time.Duration
	RedisPool   *redis.Pool
	RedisPrefix string
	ErrHandler  func(k.Error)
}