workers

Documentation

Index

• type Leadership
  • func NewLeadership(store data.Store) *Leadership
  • func (w *Leadership) AddAvailabilityCriteria(criteria leadership.AvailabilityCriteria)
  • func (w *Leadership) BecameFollower() signalslots.Signal
  • func (w *Leadership) BecameLeader() signalslots.Signal
  • func (w *Leadership) BecameUnavailable() signalslots.Signal
  • func (w *Leadership) Deinit(ctx context.Context)
  • func (w *Leadership) DoWork(ctx context.Context)
  • func (w *Leadership) GetEntityFieldValidator() data.EntityFieldValidator
  • func (w *Leadership) Init(ctx context.Context, h app.Handle)
  • func (w *Leadership) LosingLeadership() signalslots.Signal
  • func (w *Leadership) OnSchemaUpdated(ctx context.Context, n data.Notification)
  • func (w *Leadership) OnStoreConnected(ctx context.Context)
  • func (w *Leadership) OnStoreDisconnected()
• type Store
  • func NewStore(store data.Store) *Store
  • func (w *Store) Deinit(context.Context)
  • func (w *Store) DoWork(ctx context.Context)
  • func (w *Store) Init(context.Context, app.Handle)
  • func (w *Store) IsConnected() bool
• type Web
  • func NewWeb(addr string) *Web
  • func (w *Web) Broadcast(p *anypb.Any)
  • func (w *Web) Deinit(context.Context)
  • func (w *Web) DoWork(context.Context)
  • func (w *Web) Init(ctx context.Context, h app.Handle)
  • func (w *Web) Send(clientId string, p *anypb.Any)
  • func (w *Web) ServeHTTP(wr http.ResponseWriter, req *http.Request)

Types

type Leadership

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

Modify Leadership struct

func NewLeadership

func NewLeadership(store data.Store) *Leadership

Update initialization

func (*Leadership) AddAvailabilityCriteria

func (w *Leadership) AddAvailabilityCriteria(criteria leadership.AvailabilityCriteria)

func (*Leadership) BecameFollower

func (w *Leadership) BecameFollower() signalslots.Signal

func (*Leadership) BecameLeader

func (w *Leadership) BecameLeader() signalslots.Signal

func (*Leadership) BecameUnavailable

func (w *Leadership) BecameUnavailable() signalslots.Signal

func (*Leadership) Deinit

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

func (*Leadership) DoWork

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

func (*Leadership) GetEntityFieldValidator

func (w *Leadership) GetEntityFieldValidator() data.EntityFieldValidator

func (*Leadership) Init

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

func (*Leadership) LosingLeadership

func (w *Leadership) LosingLeadership() signalslots.Signal

func (*Leadership) OnSchemaUpdated

func (w *Leadership) OnSchemaUpdated(ctx context.Context, n data.Notification)

func (*Leadership) OnStoreConnected

func (w *Leadership) OnStoreConnected(ctx context.Context)

func (*Leadership) OnStoreDisconnected

func (w *Leadership) OnStoreDisconnected()

type Store

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

func NewStore

func NewStore(store data.Store) *Store

func (*Store) Deinit

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

func (*Store) DoWork

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

func (*Store) Init

func (w *Store) Init(context.Context, app.Handle)

func (*Store) IsConnected

func (w *Store) IsConnected() bool

type Web

type Web struct {
	ClientConnected    signalslots.Signal
	ClientDisconnected signalslots.Signal
	Received           signalslots.Signal
	// contains filtered or unexported fields
}

func NewWeb

func NewWeb(addr string) *Web

func (*Web) Broadcast

func (w *Web) Broadcast(p *anypb.Any)

func (*Web) Deinit

func (w *Web) Deinit(context.Context)

func (*Web) DoWork

func (w *Web) DoWork(context.Context)

func (*Web) Init

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

func (*Web) Send

func (w *Web) Send(clientId string, p *anypb.Any)

func (*Web) ServeHTTP

func (w *Web) ServeHTTP(wr http.ResponseWriter, req *http.Request)