serveroption

type CiliumDaemon interface {
	DebugEnabled() bool
}

type OnDecodedFlow interface {
	OnDecodedFlow(context.Context, *pb.Flow) (stop, error)
}

type OnDecodedFlowFunc func(context.Context, *pb.Flow) (stop, error)

type OnMonitorEvent interface {
	OnMonitorEvent(context.Context, *pb.Payload) (stop, error)
}

type OnMonitorEventFunc func(context.Context, *pb.Payload) (stop, error)

type OnServerInit interface {
	OnServerInit(Server) error
}

type OnServerInitFunc func(Server) error

type Option func(o *Options) error

type Options struct {
	// Both sizes should really be uint32 but it's better saved for a single
	// refactor commit.
	MaxFlows      int // max number of flows that can be stored in the ring buffer
	MonitorBuffer int // buffer size for monitor payload

	CiliumDaemon CiliumDaemon // when running inside Cilium, contains a reference to the daemon

	OnServerInit   []OnServerInit          // invoked when the hubble server is initialized
	OnMonitorEvent []OnMonitorEvent        // invoked before an event is decoded
	OnDecodedFlow  []OnDecodedFlow         // invoked after a flow has been decoded
	OnBuildFilter  []filters.OnBuildFilter // invoked while building a flow filter
}

type Server interface {
	GetOptions() Options
	GetLogger() *logrus.Entry
}