replication

Documentation

Index

• Constants
• func GetSyncServerClient(clientCache *client.ClientCache, token string, source client.Endpoint) (client.API, error)
• type Config
• type Dependencies
• type DeploymentReplication
  • func New(config Config, deps Dependencies, apiObject *api.ArangoDeploymentReplication) (*DeploymentReplication, error)
  • func (dr *DeploymentReplication) CollectMetrics(m metrics.PushMetric)
  • func (dr *DeploymentReplication) Delete()
  • func (dr *DeploymentReplication) Destination() server.Endpoint
  • func (dr *DeploymentReplication) Name() string
  • func (dr *DeploymentReplication) Namespace() string
  • func (dr *DeploymentReplication) Source() server.Endpoint
  • func (dr *DeploymentReplication) StateColor() server.StateColor
  • func (dr *DeploymentReplication) Update(apiObject *api.ArangoDeploymentReplication)
  • func (dr *DeploymentReplication) WrapLogger(in *zerolog.Event) *zerolog.Event
• type Metrics

Constants

const (
	CancellationTimeout = time.Minute * 15
	AbortTimeout        = time.Minute * 2
)

Functions

func GetSyncServerClient

func GetSyncServerClient(clientCache *client.ClientCache, token string, source client.Endpoint) (client.API, error)

Types

type Config

type Config struct {
	Namespace string
}

Config holds configuration settings for a DeploymentReplication

type Dependencies

type Dependencies struct {
	Client        kclient.Client
	EventRecorder record.EventRecorder
}

Dependencies holds dependent services for a DeploymentReplication

type DeploymentReplication

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

DeploymentReplication is the in process state of an ArangoDeploymentReplication.

func New

func New(config Config, deps Dependencies, apiObject *api.ArangoDeploymentReplication) (*DeploymentReplication, error)

New creates a new DeploymentReplication from the given API object.

func (*DeploymentReplication) CollectMetrics

func (dr *DeploymentReplication) CollectMetrics(m metrics.PushMetric)

func (*DeploymentReplication) Delete

func (dr *DeploymentReplication) Delete()

Delete the deployment replication. Called when the CR was deleted by the user.

func (*DeploymentReplication) Destination

func (dr *DeploymentReplication) Destination() server.Endpoint

Destination provides info on the destination of the replication

func (*DeploymentReplication) Name

func (dr *DeploymentReplication) Name() string

Name returns the name of the deployment.

func (*DeploymentReplication) Namespace

func (dr *DeploymentReplication) Namespace() string

Namespace returns the namespace that contains the deployment.

func (*DeploymentReplication) Source

func (dr *DeploymentReplication) Source() server.Endpoint

Source provides info on the source of the replication

func (*DeploymentReplication) StateColor

func (dr *DeploymentReplication) StateColor() server.StateColor

StateColor determinates the state of the deployment in color codes.

func (*DeploymentReplication) Update

func (dr *DeploymentReplication) Update(apiObject *api.ArangoDeploymentReplication)

Update the deployment replication. This sends an update event in the event queue.

func (*DeploymentReplication) WrapLogger

func (dr *DeploymentReplication) WrapLogger(in *zerolog.Event) *zerolog.Event

type Metrics

type Metrics struct {
	DeploymentReplication struct {
		Active, Failed bool
	}
}