flow_stream

Documentation

Index

• Constants
• func ExtractFlowsRequest(req *ui.GetEventsRequest) *observer.GetFlowsRequest
• type FlowStream
  • func New(log logrus.FieldLogger, connPool grpc_client.ConnectionPool, ...) (*FlowStream, error)
  • func NewDumb() *FlowStream
  • func (h *FlowStream) CollectLimit(ctx context.Context, req *observer.GetFlowsRequest, limit int64) ([]*pbFlow.Flow, error)
  • func (h *FlowStream) Errors() chan error
  • func (h *FlowStream) Flows() chan *pbFlow.Flow
  • func (h *FlowStream) Run(ctx context.Context, req *observer.GetFlowsRequest)
  • func (h *FlowStream) Stop()
  • func (h *FlowStream) Stopped() chan struct{}
• type FlowStreamInterface
• type StreamFn

Constants

const (
	MaxNumOfEOF        = 3
	NumEOFForReconnect = 2
)

Functions

func ExtractFlowsRequest

func ExtractFlowsRequest(
	req *ui.GetEventsRequest,
) *observer.GetFlowsRequest

Types

type FlowStream

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

func New

func New(
	log logrus.FieldLogger,
	connPool grpc_client.ConnectionPool,
	callProps grpc_client.CallPropertiesProvider,
) (*FlowStream, error)

func NewDumb

func NewDumb() *FlowStream

func (*FlowStream) CollectLimit

func (h *FlowStream) CollectLimit(
	ctx context.Context,
	req *observer.GetFlowsRequest,
	limit int64,
) ([]*pbFlow.Flow, error)

func (*FlowStream) Errors

func (h *FlowStream) Errors() chan error

func (*FlowStream) Flows

func (h *FlowStream) Flows() chan *pbFlow.Flow

func (*FlowStream) Run

func (h *FlowStream) Run(ctx context.Context, req *observer.GetFlowsRequest)

func (*FlowStream) Stop

func (h *FlowStream) Stop()

func (*FlowStream) Stopped

func (h *FlowStream) Stopped() chan struct{}

type FlowStreamInterface

type FlowStreamInterface interface {
	Run(ctx context.Context, req *observer.GetFlowsRequest)
	Stop()

	CollectLimit(context.Context, *observer.GetFlowsRequest, int64) ([]*pbFlow.Flow, error)

	Flows() chan *pbFlow.Flow
	Errors() chan error
	Stopped() chan struct{}
}

type StreamFn

type StreamFn = func(context.Context, int) (
	observer.Observer_GetFlowsClient,
	error,
)