Documentation ¶
Index ¶
- func SyncWithDatahub(client client.Client, conn *grpc.ClientConn) error
- type NamespaceRepository
- func (repo *NamespaceRepository) Close()
- func (repo *NamespaceRepository) CreateNamespaces(arg interface{}) error
- func (repo *NamespaceRepository) DeleteNamespaces(arg interface{}) error
- func (repo *NamespaceRepository) IsNSExcluded(ns string) bool
- func (repo *NamespaceRepository) ListNamespaces() ([]*datahub_resources.Namespace, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func SyncWithDatahub ¶
func SyncWithDatahub(client client.Client, conn *grpc.ClientConn) error
Types ¶
type NamespaceRepository ¶
type NamespaceRepository struct {
// contains filtered or unexported fields
}
func NewNamespaceRepository ¶
func NewNamespaceRepository(conn *grpc.ClientConn, clusterUID string) *NamespaceRepository
NewNamespaceRepository return NamespaceRepository instance
func (*NamespaceRepository) Close ¶
func (repo *NamespaceRepository) Close()
func (*NamespaceRepository) CreateNamespaces ¶
func (repo *NamespaceRepository) CreateNamespaces(arg interface{}) error
CreateNamespaces creates namespaces to datahub
func (*NamespaceRepository) DeleteNamespaces ¶
func (repo *NamespaceRepository) DeleteNamespaces(arg interface{}) error
DeleteNamespace delete namespaces from datahub
func (*NamespaceRepository) IsNSExcluded ¶
func (repo *NamespaceRepository) IsNSExcluded(ns string) bool
func (*NamespaceRepository) ListNamespaces ¶
func (repo *NamespaceRepository) ListNamespaces() ( []*datahub_resources.Namespace, error)
Click to show internal directories.
Click to hide internal directories.