inmemdatastore

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

type AvroFileWriterConfig struct {
	Id         int
	AvroSchema string
	OutputDir  string
}

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

type Config struct {
	NumDatastoreShards      int
	PersistenceChan         PersistenceChan
	PersistanceChanBuffSize int
	Persisters              Persisters
	// The top-level key in the map[string]interface{} records that will be stored in the
	// InMemoryDataStore.  This is required for the Put method to process a new record.
	RecordTimestampKey string
}

type Datastore struct {
	Id        uint64
	Data      map[string]interface{}
	NumReads  int64
	NumWrites int64
	// contains filtered or unexported fields
}

type Datastores map[uint64]*Datastore

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

type NoopSerializer struct{}

type PersistenceChan chan map[string]interface{}

type Persister struct {
	Serializer
	Writer
	// contains filtered or unexported fields
}

type PersisterConfig struct {
	Id         int
	Serializer Serializer
	Writer     Writer
	InputChan  PersistenceChan
}

type Persisters map[int]*Persister

type Serializer interface {
	Serialize(map[string]interface{}) (interface{}, error)
}

type Writer interface {
	Write(interface{}) error
	Shutdown()
}