storage

type BoxedInt64 struct{ V int64 }

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

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

type Storage interface {
	Encode(data interface{}) ([]byte, error)
	Load(data interface{}) error
	Write(buf []byte) error
}

type TailNode map[string]*BoxedInt64

type Tailer struct {
	Instances map[string]TailNode
}

type Tracker interface {
	Update(instKey string, childKey string, childVal int64)
	LoadTailers()
	Remove(key string)
	RegisterInstance(instKey string)
	InitializeChildNode(instKey string, childkey string, offSet int64)
	Commit() error
	StartSubmissionTimer(persistInterval time.Duration)
	IsInstanceRegistered(instKey string) bool
	IsChildNodeInitialized(instKey string, childkey string) bool
	GetFileCachedOffset(instkey string, fname string) int64

	CleanUp(validIds map[string]bool)
	// contains filtered or unexported methods
}