hubble_client

Documentation

Index

• type GRPCHubbleClient
  • func New(gcl *grpc_client.GRPCClient, log logrus.FieldLogger, ...) (*GRPCHubbleClient, error)
  • func (hc *GRPCHubbleClient) ConnectionPool() grpc_client.ConnectionPool
  • func (c *GRPCHubbleClient) FlowStream() flow_stream.FlowStreamInterface
  • func (c *GRPCHubbleClient) HubbleNodes(ctx context.Context) (*observer.GetNodesResponse, error)
  • func (c *GRPCHubbleClient) ServerStatus(ctx context.Context) (*observer.ServerStatusResponse, error)
  • func (c *GRPCHubbleClient) ServerStatusChecker(opts StatusCheckerOptions) (statuschecker.ServerStatusCheckerInterface, error)
• type HubbleClientInterface
• type StatusCheckerOptions

Types

type GRPCHubbleClient

type GRPCHubbleClient struct {
	*grpc_client.GRPCClient
	// contains filtered or unexported fields
}

func New

func New(
	gcl *grpc_client.GRPCClient,
	log logrus.FieldLogger,
	callPropsProvider grpc_client.CallPropertiesProvider,
) (*GRPCHubbleClient, error)

func (*GRPCHubbleClient) ConnectionPool

func (hc *GRPCHubbleClient) ConnectionPool() grpc_client.ConnectionPool

func (*GRPCHubbleClient) FlowStream

func (c *GRPCHubbleClient) FlowStream() flow_stream.FlowStreamInterface

func (*GRPCHubbleClient) HubbleNodes

func (c *GRPCHubbleClient) HubbleNodes(
	ctx context.Context,
) (*observer.GetNodesResponse, error)

func (*GRPCHubbleClient) ServerStatus

func (c *GRPCHubbleClient) ServerStatus(
	ctx context.Context,
) (*observer.ServerStatusResponse, error)

func (*GRPCHubbleClient) ServerStatusChecker

func (c *GRPCHubbleClient) ServerStatusChecker(opts StatusCheckerOptions) (
	statuschecker.ServerStatusCheckerInterface, error,
)

type HubbleClientInterface

type HubbleClientInterface interface {
	FlowStream() flow_stream.FlowStreamInterface
	ServerStatus(context.Context) (*observer.ServerStatusResponse, error)
	ServerStatusChecker(opts StatusCheckerOptions) (statuschecker.ServerStatusCheckerInterface, error)
}

type StatusCheckerOptions

type StatusCheckerOptions struct {
	Delay time.Duration
	Log   logrus.FieldLogger
}