servicemanager

Documentation

Index

• Constants
• type ServiceMgr
  • func NewServiceMgr(config util.Config, rebalanceRunning bool, superSup common.EventingSuperSup) *ServiceMgr
  • func (m *ServiceMgr) CancelTask(id string, rev service.Revision) error
  • func (m *ServiceMgr) GetCurrentTopology(rev service.Revision, cancel service.Cancel) (*service.Topology, error)
  • func (m *ServiceMgr) GetNodeInfo() (*service.NodeInfo, error)
  • func (m *ServiceMgr) GetTaskList(rev service.Revision, cancel service.Cancel) (*service.TaskList, error)
  • func (m *ServiceMgr) PrepareTopologyChange(change service.TopologyChange) error
  • func (m *ServiceMgr) Shutdown() error
  • func (m *ServiceMgr) StartTopologyChange(change service.TopologyChange) error

Constants

const (
	// EventingPermissionManage for auditing
	EventingPermissionManage = "cluster.eventing.functions!manage"
)

Types

type ServiceMgr

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

ServiceMgr implements cbauth_service interface

func NewServiceMgr

func NewServiceMgr(config util.Config, rebalanceRunning bool, superSup common.EventingSuperSup) *ServiceMgr

NewServiceMgr creates handle for ServiceMgr, which implements cbauth service.Manager

func (*ServiceMgr) CancelTask

func (m *ServiceMgr) CancelTask(id string, rev service.Revision) error

CancelTask callback for cbauth service.Manager

func (*ServiceMgr) GetCurrentTopology

func (m *ServiceMgr) GetCurrentTopology(rev service.Revision, cancel service.Cancel) (*service.Topology, error)

GetCurrentTopology callback for cbauth service.Manager

func (*ServiceMgr) GetNodeInfo

func (m *ServiceMgr) GetNodeInfo() (*service.NodeInfo, error)

GetNodeInfo callback for cbauth service.Manager

func (*ServiceMgr) GetTaskList

func (m *ServiceMgr) GetTaskList(rev service.Revision, cancel service.Cancel) (*service.TaskList, error)

GetTaskList callback for cbauth service.Manager

func (*ServiceMgr) PrepareTopologyChange

func (m *ServiceMgr) PrepareTopologyChange(change service.TopologyChange) error

PrepareTopologyChange callback for cbauth service.Manager

func (*ServiceMgr) Shutdown

func (m *ServiceMgr) Shutdown() error

Shutdown callback for cbauth service.Manager

func (*ServiceMgr) StartTopologyChange

func (m *ServiceMgr) StartTopologyChange(change service.TopologyChange) error

StartTopologyChange callback for cbauth service.Manager