controller

Documentation

Index

• func SyncWithDatahub(client client.Client, conn *grpc.ClientConn) error
• type ControllerRepository
  • func NewControllerRepository(conn *grpc.ClientConn, clusterUID string) *ControllerRepository
  • func (repo *ControllerRepository) Close()
  • func (repo *ControllerRepository) CreateControllers(arg interface{}) error
  • func (repo *ControllerRepository) DeleteControllers(arg interface{}, kindIf interface{}) error
  • func (repo *ControllerRepository) ListControllers() ([]*datahub_resources.Controller, error)

Functions

func SyncWithDatahub

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

Types

type ControllerRepository

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

func NewControllerRepository

func NewControllerRepository(conn *grpc.ClientConn, clusterUID string) *ControllerRepository

NewControllerRepository return ControllerRepository instance

func (*ControllerRepository) Close

func (repo *ControllerRepository) Close()

func (*ControllerRepository) CreateControllers

func (repo *ControllerRepository) CreateControllers(arg interface{}) error

CreateControllers creates controllers to datahub

func (*ControllerRepository) DeleteControllers

func (repo *ControllerRepository) DeleteControllers(arg interface{},
	kindIf interface{}) error

DeleteController delete controllers from datahub

func (*ControllerRepository) ListControllers

func (repo *ControllerRepository) ListControllers() (
	[]*datahub_resources.Controller, error)