store

Documentation

Index

• type DataInterface
• type FindQuery
  • func QueryFromRequest(r *http.Request) (*FindQuery, error)
• type IndexInterface
• type Stats
• type StoreInterface

Types

type DataInterface

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 FindQuery

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

func QueryFromRequest

func QueryFromRequest(r *http.Request) (*FindQuery, error)

type IndexInterface

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

type Stats map[string]string

type StoreInterface

type StoreInterface interface {
	IndexInterface
	DataInterface
}