storage

Documentation

Index

• type AssembleObjectStorage
• type AssembleStorage
  • func NewAssembleStorage(capStorage *CaptureStorage) (*AssembleStorage, error)
  • func (s *AssembleStorage) Register(t assemble.AssembleType, storage AssembleObjectStorage) error
• type CaptureStorage
  • func NewCaptureStorage(path string) (*CaptureStorage, error)
• type LayerStorage
• type PacketStorage
  • func NewPacketStorage(capStorage *CaptureStorage) (*PacketStorage, error)
  • func (s *PacketStorage) Close() error
  • func (s *PacketStorage) Register(t gopacket.LayerType, storage LayerStorage) error
  • func (s *PacketStorage) Store(ctx context.Context, packet container.Packet) error

Types

type AssembleObjectStorage

type AssembleObjectStorage interface {
	Init(db *sqlx.DB, base string) error
	Store(ctx context.Context, asm container.Assembly) error
}

type AssembleStorage

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

func NewAssembleStorage

func NewAssembleStorage(capStorage *CaptureStorage) (*AssembleStorage, error)

func (*AssembleStorage) Register

func (s *AssembleStorage) Register(t assemble.AssembleType, storage AssembleObjectStorage) error

type CaptureStorage

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

func NewCaptureStorage

func NewCaptureStorage(path string) (*CaptureStorage, error)

type LayerStorage

type LayerStorage interface {
	Init(db *sqlx.DB) error
	Store(ctx context.Context, packet container.Packet) error
}

type PacketStorage

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

func NewPacketStorage

func NewPacketStorage(capStorage *CaptureStorage) (*PacketStorage, error)

func (*PacketStorage) Close

func (s *PacketStorage) Close() error

func (*PacketStorage) Register

func (s *PacketStorage) Register(t gopacket.LayerType, storage LayerStorage) error

func (*PacketStorage) Store

func (s *PacketStorage) Store(ctx context.Context, packet container.Packet) error