Documentation
¶
Index ¶
- type FlowStream
- func (fs *FlowStream) CollectLimit(ctx context.Context, req *observer.GetFlowsRequest, lim int64) ([]*pbflow.Flow, error)
- func (fs *FlowStream) Errors() chan error
- func (fs *FlowStream) Flows() chan *pbflow.Flow
- func (fs *FlowStream) Run(ctx context.Context, req *observer.GetFlowsRequest)
- func (fs *FlowStream) Stop()
- func (fs *FlowStream) Stopped() chan struct{}
- type GRPCClientStream
- type NSWatcher
- type StatusChecker
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type FlowStream ¶
type FlowStream struct {
// contains filtered or unexported fields
}
func NewFlowStream ¶
func NewFlowStream( log logrus.FieldLogger, src sources.MockedSource, rl rate_limiter.RateLimit, ) *FlowStream
func (*FlowStream) CollectLimit ¶
func (fs *FlowStream) CollectLimit(ctx context.Context, req *observer.GetFlowsRequest, lim int64) ( []*pbflow.Flow, error, )
func (*FlowStream) Errors ¶
func (fs *FlowStream) Errors() chan error
func (*FlowStream) Flows ¶
func (fs *FlowStream) Flows() chan *pbflow.Flow
func (*FlowStream) Run ¶
func (fs *FlowStream) Run(ctx context.Context, req *observer.GetFlowsRequest)
func (*FlowStream) Stop ¶
func (fs *FlowStream) Stop()
func (*FlowStream) Stopped ¶
func (fs *FlowStream) Stopped() chan struct{}
type GRPCClientStream ¶
type GRPCClientStream struct {
// contains filtered or unexported fields
}
func NewGRPCClientStream ¶
func NewGRPCClientStream(ctx context.Context, log logrus.FieldLogger) *GRPCClientStream
func (*GRPCClientStream) CloseSend ¶
func (s *GRPCClientStream) CloseSend() error
func (*GRPCClientStream) Context ¶
func (s *GRPCClientStream) Context() context.Context
func (*GRPCClientStream) RecvMsg ¶
func (s *GRPCClientStream) RecvMsg(m any) error
func (*GRPCClientStream) SendMsg ¶
func (s *GRPCClientStream) SendMsg(m any) error
func (*GRPCClientStream) Trailer ¶
func (s *GRPCClientStream) Trailer() metadata.MD
type NSWatcher ¶
type NSWatcher struct {
// contains filtered or unexported fields
}
func NewNSWatcher ¶
func NewNSWatcher(log logrus.FieldLogger, source sources.MockedSource) *NSWatcher
type StatusChecker ¶
type StatusChecker struct {
// contains filtered or unexported fields
}
func NewStatusChecker ¶
func NewStatusChecker(log logrus.FieldLogger) *StatusChecker
func (*StatusChecker) Errors ¶
func (sc *StatusChecker) Errors() chan error
func (*StatusChecker) Run ¶
func (sc *StatusChecker) Run(ctx context.Context)
func (*StatusChecker) Statuses ¶
func (sc *StatusChecker) Statuses() chan *statuschecker.FullStatus
func (*StatusChecker) Stop ¶
func (sc *StatusChecker) Stop()
Source Files
Click to show internal directories.
Click to hide internal directories.