store

type DataInterface interface {
	StorePackets(context.Context, []*models.Packet) error
	GetPackets(context.Context, []string, *FindQuery) ([]*models.Packet, error)
	DataKeys(context.Context) ([]string, error)
	GetStats() (*Stats, error)
}

type DirectDataInterface interface {
	GetPacketsByAddress(context.Context, net.IP, *FindQuery) ([]*models.Packet, error)
}

type FindQuery struct {
	From     time.Time
	To       time.Time
	MaxCount int
}

type IndexInterface interface {
	IndexPackets(context.Context, []*models.Packet) error
	IndexKeys(context.Context) ([]string, error)
	FindPacketsByAddress(context.Context, net.IP) ([]string, error)
	GetStats() (*Stats, error)
}

type Stats map[string]string

type StoreInterface interface {
	IndexInterface
	DataInterface
}