coordinator

Documentation

Index

• Variables
• type Service
  • func New(state state.Stater, dispatcherClient am.DispatcherService, ...) *Service
  • func (s *Service) Init(config []byte) error
  • func (s *Service) StartGroup(ctx context.Context, userContext am.UserContext, scanGroupID int) error
  • func (s *Service) StopGroup(ctx context.Context, userContext am.UserContext, orgID, scanGroupID int) (string, error)

Variables

var (
	ErrScanGroupPaused         = errors.New("scan group is currently paused")
	ErrScanGroupAlreadyStarted = errors.New("scan group is already running")
	ErrNoDispatcherConnected   = errors.New("service unavailable, no dispatchers connected")
)

Types

type Service

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

Service for coordinating all scans

func New

func New(state state.Stater, dispatcherClient am.DispatcherService, orgClient am.OrganizationService, scanGroupClient am.ScanGroupService, systemOrgID, systemUserID int) *Service

New returns

func (*Service) Init

func (s *Service) Init(config []byte) error

Init by

func (*Service) StartGroup

func (s *Service) StartGroup(ctx context.Context, userContext am.UserContext, scanGroupID int) error

StartGroup initializes state system if they do not exist, or updates with scan group details

func (*Service) StopGroup

func (s *Service) StopGroup(ctx context.Context, userContext am.UserContext, orgID, scanGroupID int) (string, error)

StopGroup checks the group status in our state system. If it's already stopped, we are done. Otherwise, it extracts group from scangroup client to create a proxyUserContext.