Versions in this module Expand all Collapse all v0 v0.1.0 Jul 28, 2026 Changes in this version + func DecodeContentEncoding(body []byte, encoding string) []byte + func Save(w io.Writer, flows []*Flow) error + func SaveFile(path string, flows []*Flow) error + type Direction int + const ClientToServer + const ServerToClient + func (d Direction) String() string + type Event struct + Flow *Flow + Kind EventKind + type EventKind int + const FlowAdded + const FlowUpdated + type Flow struct + ClientAddr string + Err error + Flagged bool + ID string + Messages []*Message + Protocol Protocol + Request *Message + Response *Message + SNI string + Secure bool + ServerAddr string + StartedAt time.Time + Status Status + func Load(r io.Reader) ([]*Flow, error) + func LoadFile(path string) ([]*Flow, error) + func NewFlow(client, server string) *Flow + func (f *Flow) AddMessage(m *Message) + func (f *Flow) Title() string + type Injector interface + Inject func(dir Direction, opcode byte, payload []byte) error + type Message struct + Body []byte + Direction Direction + Headers map[string][]string + Meta map[string]string + Raw []byte + Summary string + Timestamp time.Time + type Protocol string + const ProtoGRPC + const ProtoHTTP1 + const ProtoHTTP2 + const ProtoRawTCP + const ProtoUnknown + const ProtoWebSocket + type SessionRegistrar interface + RegisterSession func(flowID string, inj Injector) + UnregisterSession func(flowID string) + type Status int + const StatusActive + const StatusComplete + const StatusError + const StatusPending + func (s Status) String() string + type Store struct + func NewStore() *Store + func (s *Store) Add(f *Flow) + func (s *Store) Get(id string) (*Flow, bool) + func (s *Store) List() []*Flow + func (s *Store) Subscribe() <-chan Event + func (s *Store) Touch(f *Flow)
Go to main page