client

Documentation

Index

• func DefaultLogsClient(ctx context.Context, overrideAPIAddr string) (pb.LogsClient, error)
• func DefaultResultsClient(ctx context.Context, overrideAPIAddr string) (pb.ResultsClient, error)
• type Factory
  • func NewDefaultFactory() (*Factory, error)
  • func (f *Factory) LogClient(ctx context.Context, overrideAPIAddr string) (pb.LogsClient, error)
  • func (f *Factory) ResultsClient(ctx context.Context, overrideAPIAddr string) (pb.ResultsClient, error)

Functions

func DefaultLogsClient

func DefaultLogsClient(ctx context.Context, overrideAPIAddr string) (pb.LogsClient, error)

DefaultLogsClient creates a new default logs client.

func DefaultResultsClient

func DefaultResultsClient(ctx context.Context, overrideAPIAddr string) (pb.ResultsClient, error)

DefaultResultsClient creates a new results client. Will dial overrideAPIAddr if overrideAPIAddr is not empty

Types

type Factory

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

Factory contains the configuration for creating a k8s client.

func NewDefaultFactory

func NewDefaultFactory() (*Factory, error)

NewDefaultFactory creates a new Factory with the default configuration.

func (*Factory) LogClient

func (f *Factory) LogClient(ctx context.Context, overrideAPIAddr string) (pb.LogsClient, error)

LogClient creates a new Results gRPC client for the given factory settings. TODO: Refactor this with watcher client code?

func (*Factory) ResultsClient

func (f *Factory) ResultsClient(ctx context.Context, overrideAPIAddr string) (pb.ResultsClient, error)

ResultsClient creates a new Results gRPC client for the given factory settings. TODO: Refactor this with watcher client code?