flow

Documentation

Index

• type StatusSync
  • func NewStatusSync(factory session.ContainerFactory, localSources map[string][]store.Interface, ...) *StatusSync
  • func (s *StatusSync) Run(ctx context.Context)
• type StatusSyncClient

Types

type StatusSync

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

func NewStatusSync

func NewStatusSync(factory session.ContainerFactory, localSources map[string][]store.Interface, client StatusSyncClient, configMap string) *StatusSync

func (*StatusSync) Run

func (s *StatusSync) Run(ctx context.Context)

type StatusSyncClient

type StatusSyncClient interface {
	Logger() *slog.Logger
	Get(ctx context.Context) (*corev1.ConfigMap, error)
	Update(ctx context.Context, latest *corev1.ConfigMap) error
}