workers

Documentation

Index

• type Readiness
  • func NewReadiness() *Readiness
  • func (w *Readiness) AddCriteria(c ReadinessCriteria)
  • func (w *Readiness) Deinit(ctx context.Context)
  • func (w *Readiness) DoWork(ctx context.Context)
  • func (w *Readiness) GetState() ReadinessState
  • func (w *Readiness) Init(ctx context.Context, h app.Handle)
  • func (w *Readiness) IsReady() bool
  • func (w *Readiness) RemoveCriteria(c ReadinessCriteria)
• type ReadinessCriteria
  • func NewSchemaValidityCriteria(s Store) ReadinessCriteria
  • func NewStoreConnectedCriteria(s Store) ReadinessCriteria
• type ReadinessCriteriaFunc
  • func (f ReadinessCriteriaFunc) IsReady() bool
• type ReadinessState
• type SchemaValidityCriteria
  • func (c *SchemaValidityCriteria) IsReady() bool
  • func (c *SchemaValidityCriteria) OnSchemaUpdated(ctx context.Context)
• type Store
  • func NewStore(store data.Store) *Store
  • func (me *Store) Deinit(context.Context)
  • func (me *Store) DoWork(ctx context.Context)
  • func (me *Store) Init(ctx context.Context, handle app.Handle)
  • func (me *Store) IsConnected() bool
• type StoreConnectedCriteria
  • func (c *StoreConnectedCriteria) IsReady() bool
  • func (c *StoreConnectedCriteria) OnStoreConnected()
  • func (c *StoreConnectedCriteria) OnStoreDisconnected()

Types

type Readiness

type Readiness struct {
	BecameReady   signalslots.Signal
	BecameUnready signalslots.Signal
	// contains filtered or unexported fields
}

func NewReadiness

func NewReadiness() *Readiness

func (*Readiness) AddCriteria

func (w *Readiness) AddCriteria(c ReadinessCriteria)

func (*Readiness) Deinit

func (w *Readiness) Deinit(ctx context.Context)

func (*Readiness) DoWork

func (w *Readiness) DoWork(ctx context.Context)

func (*Readiness) GetState

func (w *Readiness) GetState() ReadinessState

func (*Readiness) Init

func (w *Readiness) Init(ctx context.Context, h app.Handle)

func (*Readiness) IsReady

func (w *Readiness) IsReady() bool

func (*Readiness) RemoveCriteria

func (w *Readiness) RemoveCriteria(c ReadinessCriteria)

type ReadinessCriteria

type ReadinessCriteria interface {
	IsReady() bool
}

func NewSchemaValidityCriteria

func NewSchemaValidityCriteria(s Store) ReadinessCriteria

func NewStoreConnectedCriteria

func NewStoreConnectedCriteria(s Store) ReadinessCriteria

type ReadinessCriteriaFunc

type ReadinessCriteriaFunc func() bool

func (ReadinessCriteriaFunc) IsReady

func (f ReadinessCriteriaFunc) IsReady() bool

type ReadinessState

type ReadinessState int

const (
	Ready ReadinessState = iota
	NotReady
)

type SchemaValidityCriteria

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

func (*SchemaValidityCriteria) IsReady

func (c *SchemaValidityCriteria) IsReady() bool

func (*SchemaValidityCriteria) OnSchemaUpdated

func (c *SchemaValidityCriteria) OnSchemaUpdated(ctx context.Context)

type Store

type Store struct {
	Connected     signalslots.Signal
	Disconnected  signalslots.Signal
	SchemaUpdated signalslots.Signal
	// contains filtered or unexported fields
}

func NewStore

func NewStore(store data.Store) *Store

func (*Store) Deinit

func (me *Store) Deinit(context.Context)

func (*Store) DoWork

func (me *Store) DoWork(ctx context.Context)

func (*Store) Init

func (me *Store) Init(ctx context.Context, handle app.Handle)

func (*Store) IsConnected

func (me *Store) IsConnected() bool

type StoreConnectedCriteria

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

func (*StoreConnectedCriteria) IsReady

func (c *StoreConnectedCriteria) IsReady() bool

func (*StoreConnectedCriteria) OnStoreConnected

func (c *StoreConnectedCriteria) OnStoreConnected()

func (*StoreConnectedCriteria) OnStoreDisconnected

func (c *StoreConnectedCriteria) OnStoreDisconnected()