services_bbs

Documentation

Index

• type Presence
  • func NewPresence(store storeadapter.StoreAdapter, key string, value []byte) Presence
• type ServicesBBS
  • func New(store storeadapter.StoreAdapter, logger lager.Logger) *ServicesBBS
  • func (bbs *ServicesBBS) GetAllExecutors() ([]models.ExecutorPresence, error)
  • func (bbs *ServicesBBS) GetAvailableFileServer() (string, error)
  • func (bbs *ServicesBBS) GetServiceRegistrations() (models.ServiceRegistrations, error)
  • func (bbs *ServicesBBS) MaintainExecutorPresence(heartbeatInterval time.Duration, executorPresence models.ExecutorPresence) (Presence, <-chan bool, error)
  • func (bbs *ServicesBBS) MaintainFileServerPresence(heartbeatInterval time.Duration, fileServerURL string, fileServerId string) (Presence, <-chan bool, error)

Types

type Presence

type Presence interface {
	Maintain(interval time.Duration) (status <-chan bool, err error)
	Remove()
}

func NewPresence

func NewPresence(store storeadapter.StoreAdapter, key string, value []byte) Presence

type ServicesBBS

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

func New

func New(store storeadapter.StoreAdapter, logger lager.Logger) *ServicesBBS

func (*ServicesBBS) GetAllExecutors

func (bbs *ServicesBBS) GetAllExecutors() ([]models.ExecutorPresence, error)

func (*ServicesBBS) GetAvailableFileServer

func (bbs *ServicesBBS) GetAvailableFileServer() (string, error)

func (*ServicesBBS) GetServiceRegistrations

func (bbs *ServicesBBS) GetServiceRegistrations() (models.ServiceRegistrations, error)

func (*ServicesBBS) MaintainExecutorPresence

func (bbs *ServicesBBS) MaintainExecutorPresence(heartbeatInterval time.Duration, executorPresence models.ExecutorPresence) (Presence, <-chan bool, error)

func (*ServicesBBS) MaintainFileServerPresence

func (bbs *ServicesBBS) MaintainFileServerPresence(heartbeatInterval time.Duration, fileServerURL string, fileServerId string) (Presence, <-chan bool, error)