updater

Documentation

Index

• func SplitCorrelationID(correlationID string) (string, string, string, bool)
• type ResourceUpdater
  • func NewResourceUpdater(ctx context.Context, raConfig grpcClient.Config, storage store.Store, ...) (*ResourceUpdater, error)
  • func (h *ResourceUpdater) CancelPendingResourceUpdates(ctx context.Context) error
  • func (h *ResourceUpdater) Close() error
  • func (h *ResourceUpdater) Handle(ctx context.Context, iter eventbus.Iter) error
  • func (h *ResourceUpdater) InvokeConfiguration(ctx context.Context, token, owner string, req *pb.InvokeConfigurationRequest) (*pb.AppliedConfiguration, error)
  • func (h *ResourceUpdater) TimeoutPendingResourceUpdates()

Functions

func SplitCorrelationID

func SplitCorrelationID(correlationID string) (string, string, string, bool)

1) "appliedConfigurationID.resourceCorrelationID" if the configuration was applied by a condition 2) "appliedConfigurationID.resourceCorrelationID{. InvokeConfiguration correlationID}" if the configuration was applied on demand by InvokeConfiguration

Types

type ResourceUpdater

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

func NewResourceUpdater

func NewResourceUpdater(ctx context.Context, raConfig grpcClient.Config, storage store.Store, fileWatcher *fsnotify.Watcher, logger log.Logger, tracerProvider trace.TracerProvider) (*ResourceUpdater, error)

func (*ResourceUpdater) CancelPendingResourceUpdates

func (h *ResourceUpdater) CancelPendingResourceUpdates(ctx context.Context) error

func (*ResourceUpdater) Close

func (h *ResourceUpdater) Close() error

func (*ResourceUpdater) Handle

func (h *ResourceUpdater) Handle(ctx context.Context, iter eventbus.Iter) error

func (*ResourceUpdater) InvokeConfiguration

func (h *ResourceUpdater) InvokeConfiguration(ctx context.Context, token, owner string, req *pb.InvokeConfigurationRequest) (*pb.AppliedConfiguration, error)

func (*ResourceUpdater) TimeoutPendingResourceUpdates

func (h *ResourceUpdater) TimeoutPendingResourceUpdates()