reloader

Documentation

Index

• type DeploymentClient
• type InClusterConfigReloader
  • func NewInClusterConfigReloader(log logrus.FieldLogger, cli dynamic.Interface, cfg config.CfgWatcher, ...) (*InClusterConfigReloader, error)
  • func (l *InClusterConfigReloader) Do(ctx context.Context) error
  • func (l *InClusterConfigReloader) InformerFactory() dynamicinformer.DynamicSharedInformerFactory
• type NoopReloader
  • func NewNoopReloader() *NoopReloader
  • func (u *NoopReloader) Do(context.Context) error
• type Reloader
  • func Get(remoteCfgEnabled bool, log logrus.FieldLogger, deployCli DeploymentClient, ...) (Reloader, error)
• type RemoteConfigReloader
  • func NewRemote(log logrus.FieldLogger, deployCli DeploymentClient, restarter *Restarter, ...) *RemoteConfigReloader
  • func (u *RemoteConfigReloader) Do(ctx context.Context) error
• type ResourceVersionHolder
• type Restarter
  • func NewRestarter(log logrus.FieldLogger, k8sCli kubernetes.Interface, ...) *Restarter
  • func (r *Restarter) Do(ctx context.Context) error
• type SendMessageFn

Types

type DeploymentClient

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

DeploymentClient defines GraphQL client.

type InClusterConfigReloader

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

func NewInClusterConfigReloader

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

func (*InClusterConfigReloader) Do

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

func (*InClusterConfigReloader) InformerFactory

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

type NoopReloader

type NoopReloader struct{}

NoopReloader is a reloader that does nothing.

func NewNoopReloader

func NewNoopReloader() *NoopReloader

NewNoopReloader returns new NoopReloader.

func (*NoopReloader) Do

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

Do does nothing.

type Reloader

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

Reloader is an interface for reloading configuration.

func Get

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)

Get returns Reloader based on remoteCfgEnabled flag.

type RemoteConfigReloader

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

RemoteConfigReloader is responsible for reloading configuration from remote source.

func NewRemote

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

NewRemote returns new RemoteConfigReloader.

func (*RemoteConfigReloader) Do

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

Do starts the remote config reloader.

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

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

NewRestarter returns new Restarter.

func (*Restarter) Do

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

Do restarts the deployment.

type SendMessageFn

type SendMessageFn func(msg string) error

SendMessageFn defines a function which sends a given message.