nodes

Documentation

Index

• Constants
• type Manager
  • func NewManager(logger logrus.FieldLogger, authorizer authorizer, db db, ...) *Manager
  • func (m *Manager) GetNodeStatus(ctx context.Context, principal *models.Principal, className string, ...) ([]*models.NodeStatus, error)

Constants

const GetNodeStatusTimeout = 30 * time.Second

Types

type Manager

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

func NewManager

func NewManager(logger logrus.FieldLogger, authorizer authorizer,
	db db, schemaManager *schemaUC.Manager,
) *Manager

func (*Manager) GetNodeStatus

func (m *Manager) GetNodeStatus(ctx context.Context,
	principal *models.Principal, className string, verbosity string,
) ([]*models.NodeStatus, error)

GetNodeStatus aggregates the status across all nodes. It will try for a maximum of the configured timeout, then mark nodes as timed out.