snapshot

Documentation

Index

• Variables
• func FilterRow(input string, table string, params *config.TableParams) string
• func ForceIndex(params *config.TableParams) string
• type Reader
  • func Start(input string, svc string, cluster string, dbs string, table string, ...) (Reader, error)
• type ReaderConstructor

Variables

var Plugins map[string]ReaderConstructor

Plugins contains registered snapshot reader plugins

Functions

func FilterRow

func FilterRow(input string, table string, params *config.TableParams) string

FilterRow returns the Filter query based for specified input

func ForceIndex

func ForceIndex(params *config.TableParams) string

ForceIndex returns the FORCE INDEX clause

Types

type Reader

type Reader interface {
	//End uninitializes snapshot reader
	End()

	//Pop pops record fetched by FetchNext
	//returns: primary key, partition key and encoded message
	Pop() (string, string, []byte, error)

	//FetchNext fetches the record from the source and encodes using encoder provided when reader created
	//This is a blocking method
	FetchNext() bool
}

Reader is our contract for snapshot reader

func Start

func Start(input string, svc string, cluster string, dbs string, table string, params *config.TableParams, enc encoder.Encoder, m *metrics.Snapshot) (Reader, error)

Start constructs new snapshot reader of specified type

type ReaderConstructor

type ReaderConstructor func(string, string, string, string, *config.TableParams, encoder.Encoder, *metrics.Snapshot) (Reader, error)

ReaderConstructor initializes logger plugin