status

Documentation

Index

• type GraphQLClient
• type GraphQLStatusReporter
  • func (r *GraphQLStatusReporter) ReportDeploymentConnectionInit(ctx context.Context, k8sVer string) error
  • func (r *GraphQLStatusReporter) ReportDeploymentFailure(ctx context.Context, errMsg string) error
  • func (r *GraphQLStatusReporter) ReportDeploymentShutdown(ctx context.Context) error
  • func (r *GraphQLStatusReporter) ReportDeploymentStartup(ctx context.Context) error
  • func (r *GraphQLStatusReporter) SetLogger(logger logrus.FieldLogger)
  • func (r *GraphQLStatusReporter) SetResourceVersion(resourceVersion int)
• type NoopStatusReporter
  • func (n NoopStatusReporter) ReportDeploymentConnectionInit(context.Context, string) error
  • func (n NoopStatusReporter) ReportDeploymentFailure(context.Context, string) error
  • func (n NoopStatusReporter) ReportDeploymentShutdown(context.Context) error
  • func (n NoopStatusReporter) ReportDeploymentStartup(context.Context) error
  • func (n NoopStatusReporter) SetLogger(logrus.FieldLogger)
  • func (n NoopStatusReporter) SetResourceVersion(int)
• type ResVerClient
• type StatusReporter
  • func GetReporter(remoteCfgEnabled bool, gql GraphQLClient, resVerClient ResVerClient, ...) StatusReporter

Types

type GraphQLClient

type GraphQLClient interface {
	Client() *graphql.Client
	DeploymentID() string
}

GraphQLClient defines GraphQL client.

type GraphQLStatusReporter

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

GraphQLStatusReporter reports status to GraphQL server.

func (*GraphQLStatusReporter) ReportDeploymentConnectionInit

func (r *GraphQLStatusReporter) ReportDeploymentConnectionInit(ctx context.Context, k8sVer string) error

ReportDeploymentConnectionInit reports connection initialization.

func (*GraphQLStatusReporter) ReportDeploymentFailure

func (r *GraphQLStatusReporter) ReportDeploymentFailure(ctx context.Context, errMsg string) error

ReportDeploymentFailure reports deployment failure to GraphQL server.

func (*GraphQLStatusReporter) ReportDeploymentShutdown

func (r *GraphQLStatusReporter) ReportDeploymentShutdown(ctx context.Context) error

ReportDeploymentShutdown reports deployment shutdown to GraphQL server.

func (*GraphQLStatusReporter) ReportDeploymentStartup

func (r *GraphQLStatusReporter) ReportDeploymentStartup(ctx context.Context) error

ReportDeploymentStartup reports deployment startup to GraphQL server.

func (*GraphQLStatusReporter) SetLogger

func (r *GraphQLStatusReporter) SetLogger(logger logrus.FieldLogger)

func (*GraphQLStatusReporter) SetResourceVersion

func (r *GraphQLStatusReporter) SetResourceVersion(resourceVersion int)

SetResourceVersion sets resource version.

type NoopStatusReporter

type NoopStatusReporter struct{}

func (NoopStatusReporter) ReportDeploymentConnectionInit

func (n NoopStatusReporter) ReportDeploymentConnectionInit(context.Context, string) error

func (NoopStatusReporter) ReportDeploymentFailure

func (n NoopStatusReporter) ReportDeploymentFailure(context.Context, string) error

func (NoopStatusReporter) ReportDeploymentShutdown

func (n NoopStatusReporter) ReportDeploymentShutdown(context.Context) error

func (NoopStatusReporter) ReportDeploymentStartup

func (n NoopStatusReporter) ReportDeploymentStartup(context.Context) error

func (NoopStatusReporter) SetLogger

func (n NoopStatusReporter) SetLogger(logrus.FieldLogger)

func (NoopStatusReporter) SetResourceVersion

func (n NoopStatusReporter) SetResourceVersion(int)

type ResVerClient

type ResVerClient interface {
	GetResourceVersion(ctx context.Context) (int, error)
}

ResVerClient defines client for getting resource version.

type StatusReporter

type StatusReporter interface {
	ReportDeploymentConnectionInit(ctx context.Context, k8sVer string) error
	ReportDeploymentStartup(ctx context.Context) error
	ReportDeploymentShutdown(ctx context.Context) error
	ReportDeploymentFailure(ctx context.Context, errMsg string) error
	SetResourceVersion(resourceVersion int)
	SetLogger(logger logrus.FieldLogger)
}

func GetReporter

func GetReporter(remoteCfgEnabled bool, gql GraphQLClient, resVerClient ResVerClient, log logrus.FieldLogger) StatusReporter