node

Documentation

Index

• func SyncWithDatahub(client client.Client, conn *grpc.ClientConn) error
• type AlamedaNodeRepository
  • func NewNodeRepository(conn *grpc.ClientConn, clusterUID string) *AlamedaNodeRepository
  • func (repo *AlamedaNodeRepository) Close()
  • func (repo *AlamedaNodeRepository) CreateNodes(nodes []*datahub_resources.Node) error
  • func (repo *AlamedaNodeRepository) DeleteNodes(arg interface{}) error
  • func (repo *AlamedaNodeRepository) ListNodes() ([]*datahub_resources.Node, error)

Functions

func SyncWithDatahub

func SyncWithDatahub(client client.Client, conn *grpc.ClientConn) error

Types

type AlamedaNodeRepository

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

AlamedaNodeRepository creates predicted node to datahub

func NewNodeRepository

func NewNodeRepository(conn *grpc.ClientConn, clusterUID string) *AlamedaNodeRepository

NewNodeRepository return AlamedaNodeRepository instance

func (*AlamedaNodeRepository) Close

func (repo *AlamedaNodeRepository) Close()

func (*AlamedaNodeRepository) CreateNodes

func (repo *AlamedaNodeRepository) CreateNodes(nodes []*datahub_resources.Node) 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() ([]*datahub_resources.Node, error)

ListNodes lists nodes to datahub