clients

package

v0.0.0-...-17853a9 Latest Latest Go to latest Published: Feb 13, 2025 License: Apache-2.0 Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

func New(ctx context.Context, log logrus.FieldLogger) api_clients.APIClientsInterface

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

NOTE: Every ref to subclient/substream is stored, to have a way to mutate their state in any moment in time

func NewInner(ctx context.Context, log logrus.FieldLogger) *Clients

func (cl *Clients) NSWatcher(ctx context.Context, opts ns_watcher.NSWatcherOptions) (ns_watcher.NSWatcherInterface, error)

func (cl *Clients) RelayClient() relay_client.RelayClientInterface

func (cl *Clients) Reset()

NOTE: You need to call this method between cypress tests to have a clear state

func (cl *Clients) SetFlowsRateLimit(rl rate_limiter.RateLimit)

func (cl *Clients) SetSource(src sources.MockedSource)

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

func NewGRPCClient(log logrus.FieldLogger) *GRPCClient

func (g *GRPCClient) CallOptions(ctx context.Context) []grpc.CallOption

func (g *GRPCClient) ConnStatusChannel() *dllist.ListItem[grpc_client.StatusSub]

func (g *GRPCClient) DialOptions(ctx context.Context) ([]grpc.DialOption, error)

func (g *GRPCClient) Reset()

func (g *GRPCClient) Tag(ctx context.Context) (grpc_client.ConnectionTag, error)

func (g *GRPCClient) Validate(p, q *grpc_client.ConnectionTag) bool

type HubbleClient struct {
	*GRPCClient
	// contains filtered or unexported fields
}

func NewHubbleClient(
	log logrus.FieldLogger,
	gcl *GRPCClient,
	src sources.MockedSource,
	flowsRateLimit rate_limiter.RateLimit,
) *HubbleClient

func (hcl *HubbleClient) FlowStream() flow_stream.FlowStreamInterface

func (hcl *HubbleClient) Reset()

func (hcl *HubbleClient) ServerStatus(ctx context.Context) (*observer.ServerStatusResponse, error)

func (hcl *HubbleClient) ServerStatusChecker(
	opts hubble_client.StatusCheckerOptions,
) (statuschecker.ServerStatusCheckerInterface, error)

type RelayClient struct {
	*GRPCClient
	*HubbleClient
	// contains filtered or unexported fields
}

func NewRelayClient(
	log logrus.FieldLogger,
	gcl *GRPCClient,
	src sources.MockedSource,
	flowsRateLimit rate_limiter.RateLimit,
) *RelayClient

func (rcl *RelayClient) Reset()