database

Documentation

Index

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

Types

type Database

type Database struct {
	OpenShiftClusters OpenShiftClusters
	Subscriptions     Subscriptions
}

Database represents a database

func NewDatabase

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

NewDatabase returns a new Database

type OpenShiftClusters

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

OpenShiftClusters is the database interface for OpenShiftClusterDocuments

func NewOpenShiftClusters

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

NewOpenShiftClusters returns a new OpenShiftClusters

type Subscriptions

type Subscriptions interface {
	Create(*api.SubscriptionDocument) (*api.SubscriptionDocument, error)
	Get(api.Key) (*api.SubscriptionDocument, error)
	Patch(api.Key, func(*api.SubscriptionDocument) error) (*api.SubscriptionDocument, error)
	Update(*api.SubscriptionDocument) (*api.SubscriptionDocument, error)
	Delete(*api.SubscriptionDocument) error
	Dequeue() (*api.SubscriptionDocument, error)
	Lease(api.Key) (*api.SubscriptionDocument, error)
	EndLease(api.Key, bool, bool) (*api.SubscriptionDocument, error)
}

Subscriptions is the database interface for SubscriptionDocuments

func NewSubscriptions

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

NewSubscriptions returns a new Subscriptions