node

Documentation

Index

• func SyncWithDatahub(client client.Client, datahubClient *datahubpkg.Client) error
• type AlamedaNodeRepository
  • func NewNodeRepository(datahubClient *datahubpkg.Client, clusterUID string) *AlamedaNodeRepository
  • func (repo *AlamedaNodeRepository) CreateNodes(nodes []entities.ResourceClusterStatusNode) error
  • func (repo *AlamedaNodeRepository) DeleteNodes(arg interface{}) error
  • func (repo *AlamedaNodeRepository) ListNodes() ([]entities.ResourceClusterStatusNode, error)

Functions

func SyncWithDatahub

func SyncWithDatahub(client client.Client, datahubClient *datahubpkg.Client) error

Types

type AlamedaNodeRepository

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

AlamedaNodeRepository creates predicted node to datahub

func NewNodeRepository

func NewNodeRepository(datahubClient *datahubpkg.Client, clusterUID string) *AlamedaNodeRepository

NewNodeRepository return AlamedaNodeRepository instance

func (*AlamedaNodeRepository) CreateNodes

func (repo *AlamedaNodeRepository) CreateNodes(nodes []entities.ResourceClusterStatusNode) error

CreateNodes creates predicted node to datahub

func (*AlamedaNodeRepository) DeleteNodes

func (repo *AlamedaNodeRepository) DeleteNodes(arg interface{}) error

DeleteNodes delete predicted node from datahub

func (*AlamedaNodeRepository) ListNodes

func (repo *AlamedaNodeRepository) ListNodes() ([]entities.ResourceClusterStatusNode, error)

ListNodes lists nodes to datahub