bridge

Documentation

Index

• type Bridge
  • func New(c *types.Config) (*Bridge, error)
  • func (b *Bridge) ProcessSchedulerEvents() error
  • func (b *Bridge) Sync() error

Types

type Bridge

type Bridge struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func New

func New(c *types.Config) (*Bridge, error)

func (*Bridge) ProcessSchedulerEvents

func (b *Bridge) ProcessSchedulerEvents() error

func (*Bridge) Sync

func (b *Bridge) Sync() error

Sync performs full synchronization of scheduler tasks to service registry.