qmgr

Documentation

Index

• type ServiceConstructor
• type ServiceLoader
  • func GetServiceLoader(serviceType string) (ServiceLoader, bool)
• type ServiceManager
  • func CreateServiceManager() *ServiceManager
  • func NewServiceManager() *ServiceManager
  • func (s *ServiceManager) BuildServiceNameList(svcPrefix string) []string
  • func (s *ServiceManager) Close()
  • func (s *ServiceManager) CreatePQueue(svcName string, config *conf.PQConfig) apis.IResponse
  • func (s *ServiceManager) CreateService(svcType string, svcName string, params []string) apis.IResponse
  • func (s *ServiceManager) DropService(svcName string) apis.IResponse
  • func (s *ServiceManager) GetService(name string) (apis.ISvc, bool)
  • func (s *ServiceManager) ListServiceNames(svcPrefix string) apis.IResponse

Types

type ServiceConstructor

type ServiceConstructor func(apis.IServices, *queue_info.ServiceDescription, []string) (apis.ISvc, apis.IResponse)

type ServiceLoader

type ServiceLoader func(apis.IServices, *queue_info.ServiceDescription) (apis.ISvc, error)

func GetServiceLoader

func GetServiceLoader(serviceType string) (ServiceLoader, bool)

type ServiceManager

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

func CreateServiceManager

func CreateServiceManager() *ServiceManager

func NewServiceManager

func NewServiceManager() *ServiceManager

func (*ServiceManager) BuildServiceNameList

func (s *ServiceManager) BuildServiceNameList(svcPrefix string) []string

func (*ServiceManager) Close

func (s *ServiceManager) Close()

Close closes all available services walking through all of them.

func (*ServiceManager) CreatePQueue

func (s *ServiceManager) CreatePQueue(svcName string, config *conf.PQConfig) apis.IResponse

func (*ServiceManager) CreateService

func (s *ServiceManager) CreateService(svcType string, svcName string, params []string) apis.IResponse

CreateService creates a service of the specified type.

func (*ServiceManager) DropService

func (s *ServiceManager) DropService(svcName string) apis.IResponse

DropService drops service.

func (*ServiceManager) GetService

func (s *ServiceManager) GetService(name string) (apis.ISvc, bool)

GetService look up of a service with appropriate name.

func (*ServiceManager) ListServiceNames

func (s *ServiceManager) ListServiceNames(svcPrefix string) apis.IResponse

ListServiceNames returns a list of available