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(ctx context.Context, arg interface{}, kindIf interface{}) error
  • func (repo *ControllerRepository) ListControllers() ([]*datahub_resources.Controller, error)
  • func (repo *ControllerRepository) ListControllersByApplication(ctx context.Context, namespace, name string) ([]*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(ctx context.Context, arg interface{}, kindIf interface{}) error

DeleteControllers delete controllers from datahub

func (*ControllerRepository) ListControllers

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

func (*ControllerRepository) ListControllersByApplication

func (repo *ControllerRepository) ListControllersByApplication(ctx context.Context, namespace, name string) ([]*datahub_resources.Controller, error)