stream

type CompletionHook func(summary SessionSummary, events []*Event)

type Config struct {
	BufferSize     int
	ListenerBuffer int
	DropPolicy     DropPolicy
}

type Direction int

type DropPolicy int

type Event struct {
	Kind      Kind
	Direction Direction
	Timestamp time.Time
	Sequence  uint64

	Metadata map[string]string
	Payload  []byte

	SSE SSEMetadata
	WS  WSMetadata
}

type Kind int

type Listener struct {
	C        <-chan *Event
	Cancel   func()
	Snapshot Snapshot
}

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

type SSEMetadata struct {
	Name    string
	ID      string
	Comment string
	Retry   int
}

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

type SessionSummary struct {
	ID        string
	Kind      Kind
	State     State
	Err       error
	StartedAt time.Time
	EndedAt   time.Time
}

type Snapshot struct {
	Events []*Event
	State  State
	Err    error
}

type State int

type Stats struct {
	StartedAt   time.Time
	EndedAt     time.Time
	EventsTotal uint64
	BytesTotal  uint64
	Dropped     uint64
}

type WSMetadata struct {
	Opcode int
	Code   websocket.StatusCode
	Reason string
}