database

Documentation

Index

• type AsyncOperations
  • func NewAsyncOperations(uuid string, dbc cosmosdb.DatabaseClient, dbid, collid string) (AsyncOperations, error)
• type Database
  • func NewDatabase(ctx context.Context, env env.Interface, uuid string) (db *Database, err error)
• type OpenShiftClusters
  • func NewOpenShiftClusters(ctx context.Context, uuid string, dbc cosmosdb.DatabaseClient, ...) (OpenShiftClusters, error)
• type Subscriptions
  • func NewSubscriptions(ctx context.Context, uuid string, dbc cosmosdb.DatabaseClient, ...) (Subscriptions, error)

Types

type AsyncOperations

type AsyncOperations interface {
	Create(context.Context, *api.AsyncOperationDocument) (*api.AsyncOperationDocument, error)
	Get(context.Context, string) (*api.AsyncOperationDocument, error)
	Patch(context.Context, string, func(*api.AsyncOperationDocument) error) (*api.AsyncOperationDocument, error)
}

AsyncOperations is the database interface for AsyncOperationDocuments

func NewAsyncOperations

func NewAsyncOperations(uuid string, dbc cosmosdb.DatabaseClient, dbid, collid string) (AsyncOperations, error)

NewAsyncOperations returns a new AsyncOperations

type Database

type Database struct {
	AsyncOperations   AsyncOperations
	OpenShiftClusters OpenShiftClusters
	Subscriptions     Subscriptions
}

Database represents a database

func NewDatabase

func NewDatabase(ctx context.Context, env env.Interface, uuid string) (db *Database, err error)

NewDatabase returns a new Database

type OpenShiftClusters

type OpenShiftClusters interface {
	Create(context.Context, *api.OpenShiftClusterDocument) (*api.OpenShiftClusterDocument, error)
	Get(context.Context, string) (*api.OpenShiftClusterDocument, error)
	Patch(context.Context, string, func(*api.OpenShiftClusterDocument) error) (*api.OpenShiftClusterDocument, error)
	PatchWithLease(context.Context, string, func(*api.OpenShiftClusterDocument) error) (*api.OpenShiftClusterDocument, error)
	Update(context.Context, *api.OpenShiftClusterDocument) (*api.OpenShiftClusterDocument, error)
	Delete(context.Context, *api.OpenShiftClusterDocument) error
	ListByPrefix(string, string) (cosmosdb.OpenShiftClusterDocumentIterator, error)
	Dequeue(context.Context) (*api.OpenShiftClusterDocument, error)
	Lease(context.Context, string) (*api.OpenShiftClusterDocument, error)
	EndLease(context.Context, string, api.ProvisioningState, api.ProvisioningState) (*api.OpenShiftClusterDocument, error)
}

OpenShiftClusters is the database interface for OpenShiftClusterDocuments

func NewOpenShiftClusters

func NewOpenShiftClusters(ctx context.Context, uuid string, dbc cosmosdb.DatabaseClient, dbid, collid string) (OpenShiftClusters, error)

NewOpenShiftClusters returns a new OpenShiftClusters

type Subscriptions

type Subscriptions interface {
	Create(context.Context, *api.SubscriptionDocument) (*api.SubscriptionDocument, error)
	Get(context.Context, string) (*api.SubscriptionDocument, error)
	Update(context.Context, *api.SubscriptionDocument) (*api.SubscriptionDocument, error)
	Dequeue(context.Context) (*api.SubscriptionDocument, error)
	Lease(context.Context, string) (*api.SubscriptionDocument, error)
	EndLease(context.Context, string, bool, bool) (*api.SubscriptionDocument, error)
}

Subscriptions is the database interface for SubscriptionDocuments

func NewSubscriptions

func NewSubscriptions(ctx context.Context, uuid string, dbc cosmosdb.DatabaseClient, dbid, collid string) (Subscriptions, error)

NewSubscriptions returns a new Subscriptions