dcwatch

Documentation

Index

• type DisableSubscriber
  • func NewDisableSubscriber(dcc dockercompose.DockerComposeClient, clock clockwork.Clock) *DisableSubscriber
  • func (w *DisableSubscriber) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary) error
  • func (w *DisableSubscriber) Reconcile(ctx context.Context)
• type EventAction
  • func NewEventAction(evt dockercompose.Event, state types.ContainerState) EventAction
  • func (EventAction) Action()
• type EventWatcher
  • func NewEventWatcher(dcc dockercompose.DockerComposeClient, docker docker.LocalClient) *EventWatcher
  • func (w *EventWatcher) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary) error

Types

type DisableSubscriber

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

func NewDisableSubscriber

func NewDisableSubscriber(dcc dockercompose.DockerComposeClient, clock clockwork.Clock) *DisableSubscriber

func (*DisableSubscriber) OnChange

func (w *DisableSubscriber) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary) error

func (*DisableSubscriber) Reconcile

func (w *DisableSubscriber) Reconcile(ctx context.Context)

type EventAction

type EventAction struct {
	Event          dockercompose.Event
	Time           time.Time
	ContainerState types.ContainerState
}

func NewEventAction

func NewEventAction(evt dockercompose.Event, state types.ContainerState) EventAction

func (EventAction) Action

func (EventAction) Action()

type EventWatcher

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

func NewEventWatcher

func NewEventWatcher(dcc dockercompose.DockerComposeClient, docker docker.LocalClient) *EventWatcher

func (*EventWatcher) OnChange

func (w *EventWatcher) OnChange(ctx context.Context, st store.RStore, summary store.ChangeSummary) error