reloader

type DeploymentClient ¶

type DeploymentClient interface {
	GetResourceVersion(ctx context.Context) (int, error)
	GetConfigWithResourceVersion(ctx context.Context) (remote.Deployment, error)
}

DeploymentClient defines GraphQL client.

type InClusterConfigReloader ¶ added in v1.5.0

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

func NewInClusterConfigReloader(log logrus.FieldLogger, cli dynamic.Interface, cfg config.CfgWatcher, restarter restarter, reporter analytics.Reporter) (*InClusterConfigReloader, error)

func (l *InClusterConfigReloader) Do(ctx context.Context) error

func (l *InClusterConfigReloader) InformerFactory() dynamicinformer.DynamicSharedInformerFactory

type NoopReloader ¶

type NoopReloader struct{}

NoopReloader is a reloader that does nothing.

func NewNoopReloader() *NoopReloader

func (u *NoopReloader) Do(context.Context) error

type Reloader ¶

type Reloader interface {
	Do(ctx context.Context) error
}

Reloader is an interface for reloading configuration.

func Get(remoteCfgEnabled bool, log logrus.FieldLogger, deployCli DeploymentClient, dynamicCli dynamic.Interface, restarter *Restarter, reporter analytics.Reporter, cfg config.Config, cfgVer int, resVerHolders ...ResourceVersionHolder) (Reloader, error)

type RemoteConfigReloader ¶

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

RemoteConfigReloader is responsible for reloading configuration from remote source.

func NewRemote(log logrus.FieldLogger, deployCli DeploymentClient, restarter *Restarter, cfg config.Config, cfgVer int, resVerHolders ...ResourceVersionHolder) *RemoteConfigReloader

func (u *RemoteConfigReloader) Do(ctx context.Context) error

type ResourceVersionHolder ¶

type ResourceVersionHolder interface {
	SetResourceVersion(int)
}

ResourceVersionHolder is an interface for holding resource version with ability to set it.

type Restarter ¶

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

Restarter is responsible for restarting the deployment.

func NewRestarter(log logrus.FieldLogger, k8sCli kubernetes.Interface, deploy config.K8sResourceRef, clusterName string, sendMsgFn SendMessageFn) *Restarter

func (r *Restarter) Do(ctx context.Context) error

type SendMessageFn ¶

type SendMessageFn func(msg string) error

SendMessageFn defines a function which sends a given message.