filewatch

Documentation

Index

• Constants
• func HandleFileWatchUpdateStatusEvent(ctx context.Context, state *store.EngineState, ...)
• type Controller
  • func NewController(client ctrlclient.Client, store store.RStore, ...) *Controller
  • func (c *Controller) CreateBuilder(mgr ctrl.Manager) (*builder.Builder, error)
  • func (c *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)
• type FileWatchUpdateStatusAction
  • func NewFileWatchUpdateStatusAction(fw *filewatches.FileWatch) FileWatchUpdateStatusAction
  • func (FileWatchUpdateStatusAction) Action()
  • func (a FileWatchUpdateStatusAction) Summarize(_ *store.ChangeSummary)

Constants

const DetectedOverflowErrMsg = `` /* 189-byte string literal not displayed */

const MaxFileEventHistory = 20

MaxFileEventHistory is the maximum number of file events that will be retained on the FileWatch status.

Functions

func HandleFileWatchUpdateStatusEvent

func HandleFileWatchUpdateStatusEvent(ctx context.Context, state *store.EngineState, action FileWatchUpdateStatusAction)

Types

type Controller

type Controller struct {
	ctrlclient.Client
	Store store.RStore
	// contains filtered or unexported fields
}

Controller reconciles a FileWatch object

func NewController

func NewController(client ctrlclient.Client, store store.RStore, fsWatcherMaker fsevent.WatcherMaker, timerMaker fsevent.TimerMaker, scheme *runtime.Scheme, clock clockwork.Clock) *Controller

func (*Controller) CreateBuilder

func (c *Controller) CreateBuilder(mgr ctrl.Manager) (*builder.Builder, error)

func (*Controller) Reconcile

func (c *Controller) Reconcile(ctx context.Context, req ctrl.Request) (ctrl.Result, error)

type FileWatchUpdateStatusAction

type FileWatchUpdateStatusAction struct {
	ObjectMeta *metav1.ObjectMeta
	Status     *filewatches.FileWatchStatus
}

func NewFileWatchUpdateStatusAction

func NewFileWatchUpdateStatusAction(fw *filewatches.FileWatch) FileWatchUpdateStatusAction

func (FileWatchUpdateStatusAction) Action

func (FileWatchUpdateStatusAction) Action()

func (FileWatchUpdateStatusAction) Summarize

func (a FileWatchUpdateStatusAction) Summarize(_ *store.ChangeSummary)