handlers

Documentation

Index

• func GetPostionFile() (string, error)
• type PositionHandler
  • func NewPostionHandler(posFileName string) (*PositionHandler, error)
  • func (position *PositionHandler) ReadPositionfromFile(v interface{}) error
  • func (position *PositionHandler) WritePostiontoFile(v interface{}) (bool, error)

Functions

func GetPostionFile

func GetPostionFile() (string, error)

GetPostionFile is used to get position file path

Types

type PositionHandler

type PositionHandler struct {
	PostionFilePath string
	// contains filtered or unexported fields
}

PositionHandler holds the position of read events from flat file

func NewPostionHandler

func NewPostionHandler(posFileName string) (*PositionHandler, error)

NewPostionHandler create new position handler object

func (*PositionHandler) ReadPositionfromFile

func (position *PositionHandler) ReadPositionfromFile(v interface{}) error

ReadPositionfromFile read position of events from where next read will start

func (*PositionHandler) WritePostiontoFile

func (position *PositionHandler) WritePostiontoFile(v interface{}) (bool, error)

WritePostiontoFile write position of current read events.