heartbeat

Documentation

Index

• type DeploymentHeartbeatInput
• type GraphQLClient
• type GraphQLHeartbeatReporter
  • func (r *GraphQLHeartbeatReporter) ReportHeartbeat(ctx context.Context, heartbeat DeploymentHeartbeatInput) error
• type HeartbeatReporter
  • func GetReporter(logger logrus.FieldLogger, gql GraphQLClient) HeartbeatReporter
• type NoopHeartbeatReporter
  • func (n NoopHeartbeatReporter) ReportHeartbeat(context.Context, DeploymentHeartbeatInput) error

Types

type DeploymentHeartbeatInput

type DeploymentHeartbeatInput struct {
	NodeCount int `json:"nodeCount"`
}

type GraphQLClient

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

GraphQLClient defines GraphQL client.

type GraphQLHeartbeatReporter

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

GraphQLHeartbeatReporter reports heartbeat to GraphQL server.

func (*GraphQLHeartbeatReporter) ReportHeartbeat

func (r *GraphQLHeartbeatReporter) ReportHeartbeat(ctx context.Context, heartbeat DeploymentHeartbeatInput) error

type HeartbeatReporter

type HeartbeatReporter interface {
	ReportHeartbeat(ctx context.Context, heartBeat DeploymentHeartbeatInput) error
}

func GetReporter

func GetReporter(logger logrus.FieldLogger, gql GraphQLClient) HeartbeatReporter

type NoopHeartbeatReporter

type NoopHeartbeatReporter struct{}

func (NoopHeartbeatReporter) ReportHeartbeat

func (n NoopHeartbeatReporter) ReportHeartbeat(context.Context, DeploymentHeartbeatInput) error