store

type Batch[I any] struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type BatchConfig[I any] struct {
	Limit         uint32
	Store         Store[I]
	CommitTimeout time.Duration
	Log           logger
}

type Key struct {
	Name      string
	Compress  bool
	Extension string
	ItemCount int
}

type QueueStore[_ any] struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Store[I any] interface {
	Put(item I) (Key, error)
	PutMultiple(item []I) (Key, error)
	Get(key Key) (I, error)
	GetMultiple(key Key) ([]I, error)
	GetRaw(key Key) ([]byte, error)
	PutRaw(b []byte) (Key, error)
	Len() int
	List() []Key
	Del(key Key) error
	Open() error
	Delete() error
}

type Target interface {
	Name() string
	SendFromStore(key Key) error
}