Documentation ¶
Index ¶
- func SyncWithDatahub(client client.Client, conn *grpc.ClientConn) error
- type ApplicationRepository
- func (repo *ApplicationRepository) Close()
- func (repo *ApplicationRepository) CreateApplications(arg interface{}) error
- func (repo *ApplicationRepository) DeleteApplications(ctx context.Context, objectMetas []*datahub_resources.ObjectMeta) error
- func (repo *ApplicationRepository) GetApplication(ctx context.Context, namespace, name string) (datahub_resources.Application, error)
- func (repo *ApplicationRepository) ListApplications() ([]*datahub_resources.Application, 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 ApplicationRepository ¶
type ApplicationRepository struct {
// contains filtered or unexported fields
}
func NewApplicationRepository ¶
func NewApplicationRepository(conn *grpc.ClientConn, clusterUID string) *ApplicationRepository
NewApplicationRepository return ApplicationRepository instance
func (*ApplicationRepository) Close ¶
func (repo *ApplicationRepository) Close()
func (*ApplicationRepository) CreateApplications ¶
func (repo *ApplicationRepository) CreateApplications(arg interface{}) error
CreateApplications creates applications to datahub
func (*ApplicationRepository) DeleteApplications ¶
func (repo *ApplicationRepository) DeleteApplications(ctx context.Context, objectMetas []*datahub_resources.ObjectMeta) error
DeleteApplications delete applications from datahub
func (*ApplicationRepository) GetApplication ¶
func (repo *ApplicationRepository) GetApplication(ctx context.Context, namespace, name string) (datahub_resources.Application, error)
func (*ApplicationRepository) ListApplications ¶
func (repo *ApplicationRepository) ListApplications() ([]*datahub_resources.Application, error)
Click to show internal directories.
Click to hide internal directories.