cosmosdb

package
v0.0.0-...-c49a9cf Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 2, 2026 License: Apache-2.0 Imports: 17 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ErrETagRequired = fmt.Errorf("ETag is required")

ErrETagRequired is the error returned if the ETag field is not populate on a PUT or DELETE operation

View Source 
var ErrNotImplemented = fmt.Errorf("not implemented")

ErrNotImplemented is the error returned if a fake function is not implemented

Functions

func IsErrorStatusCode 

func IsErrorStatusCode(err error, statusCode int) bool

IsErrorStatusCode returns true if err is of type Error and its StatusCode matches statusCode

func RetryOnPreconditionFailed 

func RetryOnPreconditionFailed(f func() error) (err error)

RetryOnPreconditionFailed retries a function if it fails due to PreconditionFailed

Types

type AsyncOperationDocumentClient 

type AsyncOperationDocumentClient interface {
	Create(context.Context, string, *pkg.AsyncOperationDocument, *Options) (*pkg.AsyncOperationDocument, error)
	List(*Options) AsyncOperationDocumentIterator
	ListAll(context.Context, *Options) (*pkg.AsyncOperationDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.AsyncOperationDocument, error)
	Replace(context.Context, string, *pkg.AsyncOperationDocument, *Options) (*pkg.AsyncOperationDocument, error)
	Delete(context.Context, string, *pkg.AsyncOperationDocument, *Options) error
	Query(string, *Query, *Options) AsyncOperationDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.AsyncOperationDocuments, error)
	ChangeFeed(*Options) AsyncOperationDocumentIterator
}

AsyncOperationDocumentClient is a asyncOperationDocument client

func NewAsyncOperationDocumentClient 

func NewAsyncOperationDocumentClient(collc CollectionClient, collid string) AsyncOperationDocumentClient

NewAsyncOperationDocumentClient returns a new asyncOperationDocument client

type AsyncOperationDocumentIterator 

type AsyncOperationDocumentIterator interface {
	Next(context.Context, int) (*pkg.AsyncOperationDocuments, error)
	Continuation() string
}

AsyncOperationDocumentIterator is a asyncOperationDocument iterator

type AsyncOperationDocumentRawIterator 

type AsyncOperationDocumentRawIterator interface {
	AsyncOperationDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

AsyncOperationDocumentRawIterator is a asyncOperationDocument raw iterator

func NewFakeAsyncOperationDocumentErroringRawIterator 

func NewFakeAsyncOperationDocumentErroringRawIterator(err error) AsyncOperationDocumentRawIterator

NewFakeAsyncOperationDocumentErroringRawIterator returns a AsyncOperationDocumentRawIterator which whose methods return the given error

func NewFakeAsyncOperationDocumentIterator 

func NewFakeAsyncOperationDocumentIterator(asyncOperationDocuments []*pkg.AsyncOperationDocument, continuation int) AsyncOperationDocumentRawIterator

type Authorizer 

type Authorizer interface {
	Authorize(context.Context, *http.Request, string, string) error
}

func NewMasterKeyAuthorizer 

func NewMasterKeyAuthorizer(masterKey string) (Authorizer, error)

func NewTokenAuthorizer 

func NewTokenAuthorizer(token string, expiration time.Time, getToken func(context.Context) (token string, newExpiration time.Time, err error)) Authorizer

type BillingDocumentClient 

type BillingDocumentClient interface {
	Create(context.Context, string, *pkg.BillingDocument, *Options) (*pkg.BillingDocument, error)
	List(*Options) BillingDocumentIterator
	ListAll(context.Context, *Options) (*pkg.BillingDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.BillingDocument, error)
	Replace(context.Context, string, *pkg.BillingDocument, *Options) (*pkg.BillingDocument, error)
	Delete(context.Context, string, *pkg.BillingDocument, *Options) error
	Query(string, *Query, *Options) BillingDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.BillingDocuments, error)
	ChangeFeed(*Options) BillingDocumentIterator
}

BillingDocumentClient is a billingDocument client

func NewBillingDocumentClient 

func NewBillingDocumentClient(collc CollectionClient, collid string) BillingDocumentClient

NewBillingDocumentClient returns a new billingDocument client

type BillingDocumentIterator 

type BillingDocumentIterator interface {
	Next(context.Context, int) (*pkg.BillingDocuments, error)
	Continuation() string
}

BillingDocumentIterator is a billingDocument iterator

type BillingDocumentRawIterator 

type BillingDocumentRawIterator interface {
	BillingDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

BillingDocumentRawIterator is a billingDocument raw iterator

func NewFakeBillingDocumentErroringRawIterator 

func NewFakeBillingDocumentErroringRawIterator(err error) BillingDocumentRawIterator

NewFakeBillingDocumentErroringRawIterator returns a BillingDocumentRawIterator which whose methods return the given error

func NewFakeBillingDocumentIterator 

func NewFakeBillingDocumentIterator(billingDocuments []*pkg.BillingDocument, continuation int) BillingDocumentRawIterator

type Collection 

type Collection struct {
	ID                       string                    `json:"id,omitempty"`
	ResourceID               string                    `json:"_rid,omitempty"`
	Timestamp                int                       `json:"_ts,omitempty"`
	Self                     string                    `json:"_self,omitempty"`
	ETag                     string                    `json:"_etag,omitempty"`
	Documents                string                    `json:"_docs,omitempty"`
	StoredProcedures         string                    `json:"_sprocs,omitempty"`
	Triggers                 string                    `json:"_triggers,omitempty"`
	UserDefinedFunctions     string                    `json:"_udfs,omitempty"`
	Conflicts                string                    `json:"_conflicts,omitempty"`
	IndexingPolicy           *IndexingPolicy           `json:"indexingPolicy,omitempty"`
	PartitionKey             *PartitionKey             `json:"partitionKey,omitempty"`
	UniqueKeyPolicy          *UniqueKeyPolicy          `json:"uniqueKeyPolicy,omitempty"`
	ConflictResolutionPolicy *ConflictResolutionPolicy `json:"conflictResolutionPolicy,omitempty"`
	AllowMaterializedViews   bool                      `json:"allowMaterializedViews,omitempty"`
	GeospatialConfig         *GeospatialConfig         `json:"geospatialConfig,omitempty"`
}

Collection represents a collection

type CollectionClient 

type CollectionClient interface {
	Create(context.Context, *Collection) (*Collection, error)
	List() CollectionIterator
	ListAll(context.Context) (*Collections, error)
	Get(context.Context, string) (*Collection, error)
	Delete(context.Context, *Collection) error
	Replace(context.Context, *Collection) (*Collection, error)
	PartitionKeyRanges(context.Context, string) (*PartitionKeyRanges, error)
}

CollectionClient is a collection client

func NewCollectionClient 

func NewCollectionClient(c DatabaseClient, dbid string) CollectionClient

NewCollectionClient returns a new collection client

type CollectionIterator 

type CollectionIterator interface {
	Next(context.Context) (*Collections, error)
}

CollectionIterator is a collection iterator

type Collections 

type Collections struct {
	Count       int           `json:"_count,omitempty"`
	ResourceID  string        `json:"_rid,omitempty"`
	Collections []*Collection `json:"DocumentCollections,omitempty"`
}

Collections represents collections

type CompositeIndex 

type CompositeIndex []struct {
	Path  string `json:"path,omitempty"`
	Order Order  `json:"order,omitempty"`
}

CompositeIndex represents a composite index

type ConflictResolutionPolicy 

type ConflictResolutionPolicy struct {
	Mode                        ConflictResolutionPolicyMode `json:"mode,omitempty"`
	ConflictResolutionPath      string                       `json:"conflictResolutionPath,omitempty"`
	ConflictResolutionProcedure string                       `json:"conflictResolutionProcedure,omitempty"`
}

ConflictResolutionPolicy represents a conflict resolution policy

type ConflictResolutionPolicyMode 

type ConflictResolutionPolicyMode string

ConflictResolutionPolicyMode represents a conflict resolution policy mode 

const (
	ConflictResolutionPolicyModeLastWriterWins ConflictResolutionPolicyMode = "LastWriterWins"
	ConflictResolutionPolicyModeCustom         ConflictResolutionPolicyMode = "Custom"
)

ConflictResolutionPolicyMode constants

type Database 

type Database struct {
	ID          string `json:"id,omitempty"`
	ResourceID  string `json:"_rid,omitempty"`
	Timestamp   int    `json:"_ts,omitempty"`
	Self        string `json:"_self,omitempty"`
	ETag        string `json:"_etag,omitempty"`
	Collections string `json:"_colls,omitempty"`
	Users       string `json:"_users,omitempty"`
}

Database represents a database

type DatabaseClient 

type DatabaseClient interface {
	SetAuthorizer(Authorizer)
	Create(context.Context, *Database) (*Database, error)
	List() DatabaseIterator
	ListAll(context.Context) (*Databases, error)
	Get(context.Context, string) (*Database, error)
	Delete(context.Context, *Database) error
}

DatabaseClient is a database client

func NewDatabaseClient 

func NewDatabaseClient(log *logrus.Entry, hc *http.Client, jsonHandle *codec.JsonHandle, databaseHostname string, authorizer Authorizer) DatabaseClient

NewDatabaseClient returns a new database client

type DatabaseIterator 

type DatabaseIterator interface {
	Next(context.Context) (*Databases, error)
}

DatabaseIterator is a database iterator

type Databases 

type Databases struct {
	Count      int         `json:"_count,omitempty"`
	ResourceID string      `json:"_rid,omitempty"`
	Databases  []*Database `json:"Databases,omitempty"`
}

Databases represents databases

type Error 

type Error struct {
	StatusCode int
	Code       string `json:"code"`
	Message    string `json:"message"`
}

Error represents an error

func (*Error) Error 

func (e *Error) Error() string

type ExcludedPath 

type ExcludedPath struct {
	Path string `json:"path,omitempty"`
}

ExcludedPath represents an excluded path

type FakeAsyncOperationDocumentClient 

type FakeAsyncOperationDocumentClient struct {
	// contains filtered or unexported fields
}

FakeAsyncOperationDocumentClient is a FakeAsyncOperationDocumentClient

func NewFakeAsyncOperationDocumentClient 

func NewFakeAsyncOperationDocumentClient(h *codec.JsonHandle) *FakeAsyncOperationDocumentClient

NewFakeAsyncOperationDocumentClient returns a FakeAsyncOperationDocumentClient

func (*FakeAsyncOperationDocumentClient) ChangeFeed 

func (c *FakeAsyncOperationDocumentClient) ChangeFeed(*Options) AsyncOperationDocumentIterator

ChangeFeed is a basic implementation of cosmosDB Changefeeds. Compared to the real changefeeds, its implementation is much more simplistic: - Deleting a AsyncOperationDocument does not remove it from the existing change feeds - when a AsyncOperationDocument is pushed into the changefeed, older versions that have not been retrieved won't be removed, meaning there's no guarantee that a asyncOperationDocument from the changefeed is actually the most recent version.

func (*FakeAsyncOperationDocumentClient) Create 

func (c *FakeAsyncOperationDocumentClient) Create(ctx context.Context, partitionkey string, asyncOperationDocument *pkg.AsyncOperationDocument, options *Options) (*pkg.AsyncOperationDocument, error)

Create creates a AsyncOperationDocument in the database

func (*FakeAsyncOperationDocumentClient) Delete 

func (c *FakeAsyncOperationDocumentClient) Delete(ctx context.Context, partitionKey string, asyncOperationDocument *pkg.AsyncOperationDocument, options *Options) error

Delete deletes a AsyncOperationDocument from the database

func (*FakeAsyncOperationDocumentClient) Get 

func (c *FakeAsyncOperationDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.AsyncOperationDocument, error)

Get gets a AsyncOperationDocument from the database

func (*FakeAsyncOperationDocumentClient) List 

func (c *FakeAsyncOperationDocumentClient) List(*Options) AsyncOperationDocumentIterator

List returns a AsyncOperationDocumentIterator to list all AsyncOperationDocuments in the database

func (*FakeAsyncOperationDocumentClient) ListAll 

func (c *FakeAsyncOperationDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.AsyncOperationDocuments, error)

ListAll lists all AsyncOperationDocuments in the database

func (*FakeAsyncOperationDocumentClient) Query 

func (c *FakeAsyncOperationDocumentClient) Query(name string, query *Query, options *Options) AsyncOperationDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakeAsyncOperationDocumentClient) QueryAll 

func (c *FakeAsyncOperationDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.AsyncOperationDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakeAsyncOperationDocumentClient) Replace 

func (c *FakeAsyncOperationDocumentClient) Replace(ctx context.Context, partitionkey string, asyncOperationDocument *pkg.AsyncOperationDocument, options *Options) (*pkg.AsyncOperationDocument, error)

Replace replaces a AsyncOperationDocument in the database

func (*FakeAsyncOperationDocumentClient) SetConflictChecker 

func (c *FakeAsyncOperationDocumentClient) SetConflictChecker(conflictChecker func(*pkg.AsyncOperationDocument, *pkg.AsyncOperationDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a AsyncOperationDocument

func (*FakeAsyncOperationDocumentClient) SetError 

func (c *FakeAsyncOperationDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakeAsyncOperationDocumentClient method invocation

func (*FakeAsyncOperationDocumentClient) SetQueryHandler 

func (c *FakeAsyncOperationDocumentClient) SetQueryHandler(queryName string, query fakeAsyncOperationDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakeAsyncOperationDocumentClient) SetSorter 

func (c *FakeAsyncOperationDocumentClient) SetSorter(sorter func([]*pkg.AsyncOperationDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakeAsyncOperationDocumentClient) SetTriggerHandler 

func (c *FakeAsyncOperationDocumentClient) SetTriggerHandler(triggerName string, trigger fakeAsyncOperationDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type FakeBillingDocumentClient 

type FakeBillingDocumentClient struct {
	// contains filtered or unexported fields
}

FakeBillingDocumentClient is a FakeBillingDocumentClient

func NewFakeBillingDocumentClient 

func NewFakeBillingDocumentClient(h *codec.JsonHandle) *FakeBillingDocumentClient

NewFakeBillingDocumentClient returns a FakeBillingDocumentClient

func (*FakeBillingDocumentClient) ChangeFeed 

func (c *FakeBillingDocumentClient) ChangeFeed(*Options) BillingDocumentIterator

ChangeFeed is a basic implementation of cosmosDB Changefeeds. Compared to the real changefeeds, its implementation is much more simplistic: - Deleting a BillingDocument does not remove it from the existing change feeds - when a BillingDocument is pushed into the changefeed, older versions that have not been retrieved won't be removed, meaning there's no guarantee that a billingDocument from the changefeed is actually the most recent version.

func (*FakeBillingDocumentClient) Create 

func (c *FakeBillingDocumentClient) Create(ctx context.Context, partitionkey string, billingDocument *pkg.BillingDocument, options *Options) (*pkg.BillingDocument, error)

Create creates a BillingDocument in the database

func (*FakeBillingDocumentClient) Delete 

func (c *FakeBillingDocumentClient) Delete(ctx context.Context, partitionKey string, billingDocument *pkg.BillingDocument, options *Options) error

Delete deletes a BillingDocument from the database

func (*FakeBillingDocumentClient) Get 

func (c *FakeBillingDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.BillingDocument, error)

Get gets a BillingDocument from the database

func (*FakeBillingDocumentClient) List 

func (c *FakeBillingDocumentClient) List(*Options) BillingDocumentIterator

List returns a BillingDocumentIterator to list all BillingDocuments in the database

func (*FakeBillingDocumentClient) ListAll 

func (c *FakeBillingDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.BillingDocuments, error)

ListAll lists all BillingDocuments in the database

func (*FakeBillingDocumentClient) Query 

func (c *FakeBillingDocumentClient) Query(name string, query *Query, options *Options) BillingDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakeBillingDocumentClient) QueryAll 

func (c *FakeBillingDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.BillingDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakeBillingDocumentClient) Replace 

func (c *FakeBillingDocumentClient) Replace(ctx context.Context, partitionkey string, billingDocument *pkg.BillingDocument, options *Options) (*pkg.BillingDocument, error)

Replace replaces a BillingDocument in the database

func (*FakeBillingDocumentClient) SetConflictChecker 

func (c *FakeBillingDocumentClient) SetConflictChecker(conflictChecker func(*pkg.BillingDocument, *pkg.BillingDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a BillingDocument

func (*FakeBillingDocumentClient) SetError 

func (c *FakeBillingDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakeBillingDocumentClient method invocation

func (*FakeBillingDocumentClient) SetQueryHandler 

func (c *FakeBillingDocumentClient) SetQueryHandler(queryName string, query fakeBillingDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakeBillingDocumentClient) SetSorter 

func (c *FakeBillingDocumentClient) SetSorter(sorter func([]*pkg.BillingDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakeBillingDocumentClient) SetTriggerHandler 

func (c *FakeBillingDocumentClient) SetTriggerHandler(triggerName string, trigger fakeBillingDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type FakeGatewayDocumentClient 

type FakeGatewayDocumentClient struct {
	// contains filtered or unexported fields
}

FakeGatewayDocumentClient is a FakeGatewayDocumentClient

func NewFakeGatewayDocumentClient 

func NewFakeGatewayDocumentClient(h *codec.JsonHandle) *FakeGatewayDocumentClient

NewFakeGatewayDocumentClient returns a FakeGatewayDocumentClient

func (*FakeGatewayDocumentClient) ChangeFeed 

func (c *FakeGatewayDocumentClient) ChangeFeed(*Options) GatewayDocumentIterator

ChangeFeed is a basic implementation of cosmosDB Changefeeds. Compared to the real changefeeds, its implementation is much more simplistic: - Deleting a GatewayDocument does not remove it from the existing change feeds - when a GatewayDocument is pushed into the changefeed, older versions that have not been retrieved won't be removed, meaning there's no guarantee that a gatewayDocument from the changefeed is actually the most recent version.

func (*FakeGatewayDocumentClient) Create 

func (c *FakeGatewayDocumentClient) Create(ctx context.Context, partitionkey string, gatewayDocument *pkg.GatewayDocument, options *Options) (*pkg.GatewayDocument, error)

Create creates a GatewayDocument in the database

func (*FakeGatewayDocumentClient) Delete 

func (c *FakeGatewayDocumentClient) Delete(ctx context.Context, partitionKey string, gatewayDocument *pkg.GatewayDocument, options *Options) error

Delete deletes a GatewayDocument from the database

func (*FakeGatewayDocumentClient) Get 

func (c *FakeGatewayDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.GatewayDocument, error)

Get gets a GatewayDocument from the database

func (*FakeGatewayDocumentClient) List 

func (c *FakeGatewayDocumentClient) List(*Options) GatewayDocumentIterator

List returns a GatewayDocumentIterator to list all GatewayDocuments in the database

func (*FakeGatewayDocumentClient) ListAll 

func (c *FakeGatewayDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.GatewayDocuments, error)

ListAll lists all GatewayDocuments in the database

func (*FakeGatewayDocumentClient) Query 

func (c *FakeGatewayDocumentClient) Query(name string, query *Query, options *Options) GatewayDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakeGatewayDocumentClient) QueryAll 

func (c *FakeGatewayDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.GatewayDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakeGatewayDocumentClient) Replace 

func (c *FakeGatewayDocumentClient) Replace(ctx context.Context, partitionkey string, gatewayDocument *pkg.GatewayDocument, options *Options) (*pkg.GatewayDocument, error)

Replace replaces a GatewayDocument in the database

func (*FakeGatewayDocumentClient) SetConflictChecker 

func (c *FakeGatewayDocumentClient) SetConflictChecker(conflictChecker func(*pkg.GatewayDocument, *pkg.GatewayDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a GatewayDocument

func (*FakeGatewayDocumentClient) SetError 

func (c *FakeGatewayDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakeGatewayDocumentClient method invocation

func (*FakeGatewayDocumentClient) SetQueryHandler 

func (c *FakeGatewayDocumentClient) SetQueryHandler(queryName string, query fakeGatewayDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakeGatewayDocumentClient) SetSorter 

func (c *FakeGatewayDocumentClient) SetSorter(sorter func([]*pkg.GatewayDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakeGatewayDocumentClient) SetTriggerHandler 

func (c *FakeGatewayDocumentClient) SetTriggerHandler(triggerName string, trigger fakeGatewayDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type FakeMaintenanceManifestDocumentClient 

type FakeMaintenanceManifestDocumentClient struct {
	// contains filtered or unexported fields
}

FakeMaintenanceManifestDocumentClient is a FakeMaintenanceManifestDocumentClient

func NewFakeMaintenanceManifestDocumentClient 

func NewFakeMaintenanceManifestDocumentClient(h *codec.JsonHandle) *FakeMaintenanceManifestDocumentClient

NewFakeMaintenanceManifestDocumentClient returns a FakeMaintenanceManifestDocumentClient

func (*FakeMaintenanceManifestDocumentClient) ChangeFeed 

func (c *FakeMaintenanceManifestDocumentClient) ChangeFeed(*Options) MaintenanceManifestDocumentIterator

ChangeFeed is a basic implementation of cosmosDB Changefeeds. Compared to the real changefeeds, its implementation is much more simplistic: - Deleting a MaintenanceManifestDocument does not remove it from the existing change feeds - when a MaintenanceManifestDocument is pushed into the changefeed, older versions that have not been retrieved won't be removed, meaning there's no guarantee that a maintenanceManifestDocument from the changefeed is actually the most recent version.

func (*FakeMaintenanceManifestDocumentClient) Create 

func (c *FakeMaintenanceManifestDocumentClient) Create(ctx context.Context, partitionkey string, maintenanceManifestDocument *pkg.MaintenanceManifestDocument, options *Options) (*pkg.MaintenanceManifestDocument, error)

Create creates a MaintenanceManifestDocument in the database

func (*FakeMaintenanceManifestDocumentClient) Delete 

func (c *FakeMaintenanceManifestDocumentClient) Delete(ctx context.Context, partitionKey string, maintenanceManifestDocument *pkg.MaintenanceManifestDocument, options *Options) error

Delete deletes a MaintenanceManifestDocument from the database

func (*FakeMaintenanceManifestDocumentClient) Get 

func (c *FakeMaintenanceManifestDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.MaintenanceManifestDocument, error)

Get gets a MaintenanceManifestDocument from the database

func (*FakeMaintenanceManifestDocumentClient) List 

func (c *FakeMaintenanceManifestDocumentClient) List(*Options) MaintenanceManifestDocumentIterator

List returns a MaintenanceManifestDocumentIterator to list all MaintenanceManifestDocuments in the database

func (*FakeMaintenanceManifestDocumentClient) ListAll 

func (c *FakeMaintenanceManifestDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.MaintenanceManifestDocuments, error)

ListAll lists all MaintenanceManifestDocuments in the database

func (*FakeMaintenanceManifestDocumentClient) Query 

func (c *FakeMaintenanceManifestDocumentClient) Query(name string, query *Query, options *Options) MaintenanceManifestDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakeMaintenanceManifestDocumentClient) QueryAll 

func (c *FakeMaintenanceManifestDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.MaintenanceManifestDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakeMaintenanceManifestDocumentClient) Replace 

func (c *FakeMaintenanceManifestDocumentClient) Replace(ctx context.Context, partitionkey string, maintenanceManifestDocument *pkg.MaintenanceManifestDocument, options *Options) (*pkg.MaintenanceManifestDocument, error)

Replace replaces a MaintenanceManifestDocument in the database

func (*FakeMaintenanceManifestDocumentClient) SetConflictChecker 

func (c *FakeMaintenanceManifestDocumentClient) SetConflictChecker(conflictChecker func(*pkg.MaintenanceManifestDocument, *pkg.MaintenanceManifestDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a MaintenanceManifestDocument

func (*FakeMaintenanceManifestDocumentClient) SetError 

func (c *FakeMaintenanceManifestDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakeMaintenanceManifestDocumentClient method invocation

func (*FakeMaintenanceManifestDocumentClient) SetQueryHandler 

func (c *FakeMaintenanceManifestDocumentClient) SetQueryHandler(queryName string, query fakeMaintenanceManifestDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakeMaintenanceManifestDocumentClient) SetSorter 

func (c *FakeMaintenanceManifestDocumentClient) SetSorter(sorter func([]*pkg.MaintenanceManifestDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakeMaintenanceManifestDocumentClient) SetTriggerHandler 

func (c *FakeMaintenanceManifestDocumentClient) SetTriggerHandler(triggerName string, trigger fakeMaintenanceManifestDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type FakeMaintenanceScheduleDocumentClient 

type FakeMaintenanceScheduleDocumentClient struct {
	// contains filtered or unexported fields
}

FakeMaintenanceScheduleDocumentClient is a FakeMaintenanceScheduleDocumentClient

func NewFakeMaintenanceScheduleDocumentClient 

func NewFakeMaintenanceScheduleDocumentClient(h *codec.JsonHandle) *FakeMaintenanceScheduleDocumentClient

NewFakeMaintenanceScheduleDocumentClient returns a FakeMaintenanceScheduleDocumentClient

func (*FakeMaintenanceScheduleDocumentClient) ChangeFeed 

func (c *FakeMaintenanceScheduleDocumentClient) ChangeFeed(*Options) MaintenanceScheduleDocumentIterator

ChangeFeed is a basic implementation of cosmosDB Changefeeds. Compared to the real changefeeds, its implementation is much more simplistic: - Deleting a MaintenanceScheduleDocument does not remove it from the existing change feeds - when a MaintenanceScheduleDocument is pushed into the changefeed, older versions that have not been retrieved won't be removed, meaning there's no guarantee that a maintenanceScheduleDocument from the changefeed is actually the most recent version.

func (*FakeMaintenanceScheduleDocumentClient) Create 

func (c *FakeMaintenanceScheduleDocumentClient) Create(ctx context.Context, partitionkey string, maintenanceScheduleDocument *pkg.MaintenanceScheduleDocument, options *Options) (*pkg.MaintenanceScheduleDocument, error)

Create creates a MaintenanceScheduleDocument in the database

func (*FakeMaintenanceScheduleDocumentClient) Delete 

func (c *FakeMaintenanceScheduleDocumentClient) Delete(ctx context.Context, partitionKey string, maintenanceScheduleDocument *pkg.MaintenanceScheduleDocument, options *Options) error

Delete deletes a MaintenanceScheduleDocument from the database

func (*FakeMaintenanceScheduleDocumentClient) Get 

func (c *FakeMaintenanceScheduleDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.MaintenanceScheduleDocument, error)

Get gets a MaintenanceScheduleDocument from the database

func (*FakeMaintenanceScheduleDocumentClient) List 

func (c *FakeMaintenanceScheduleDocumentClient) List(*Options) MaintenanceScheduleDocumentIterator

List returns a MaintenanceScheduleDocumentIterator to list all MaintenanceScheduleDocuments in the database

func (*FakeMaintenanceScheduleDocumentClient) ListAll 

func (c *FakeMaintenanceScheduleDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.MaintenanceScheduleDocuments, error)

ListAll lists all MaintenanceScheduleDocuments in the database

func (*FakeMaintenanceScheduleDocumentClient) Query 

func (c *FakeMaintenanceScheduleDocumentClient) Query(name string, query *Query, options *Options) MaintenanceScheduleDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakeMaintenanceScheduleDocumentClient) QueryAll 

func (c *FakeMaintenanceScheduleDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.MaintenanceScheduleDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakeMaintenanceScheduleDocumentClient) Replace 

func (c *FakeMaintenanceScheduleDocumentClient) Replace(ctx context.Context, partitionkey string, maintenanceScheduleDocument *pkg.MaintenanceScheduleDocument, options *Options) (*pkg.MaintenanceScheduleDocument, error)

Replace replaces a MaintenanceScheduleDocument in the database

func (*FakeMaintenanceScheduleDocumentClient) SetConflictChecker 

func (c *FakeMaintenanceScheduleDocumentClient) SetConflictChecker(conflictChecker func(*pkg.MaintenanceScheduleDocument, *pkg.MaintenanceScheduleDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a MaintenanceScheduleDocument

func (*FakeMaintenanceScheduleDocumentClient) SetError 

func (c *FakeMaintenanceScheduleDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakeMaintenanceScheduleDocumentClient method invocation

func (*FakeMaintenanceScheduleDocumentClient) SetQueryHandler 

func (c *FakeMaintenanceScheduleDocumentClient) SetQueryHandler(queryName string, query fakeMaintenanceScheduleDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakeMaintenanceScheduleDocumentClient) SetSorter 

func (c *FakeMaintenanceScheduleDocumentClient) SetSorter(sorter func([]*pkg.MaintenanceScheduleDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakeMaintenanceScheduleDocumentClient) SetTriggerHandler 

func (c *FakeMaintenanceScheduleDocumentClient) SetTriggerHandler(triggerName string, trigger fakeMaintenanceScheduleDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type FakeMonitorDocumentClient 

type FakeMonitorDocumentClient struct {
	// contains filtered or unexported fields
}

FakeMonitorDocumentClient is a FakeMonitorDocumentClient

func NewFakeMonitorDocumentClient 

func NewFakeMonitorDocumentClient(h *codec.JsonHandle) *FakeMonitorDocumentClient

NewFakeMonitorDocumentClient returns a FakeMonitorDocumentClient

func (*FakeMonitorDocumentClient) ChangeFeed 

func (c *FakeMonitorDocumentClient) ChangeFeed(*Options) MonitorDocumentIterator

ChangeFeed is a basic implementation of cosmosDB Changefeeds. Compared to the real changefeeds, its implementation is much more simplistic: - Deleting a MonitorDocument does not remove it from the existing change feeds - when a MonitorDocument is pushed into the changefeed, older versions that have not been retrieved won't be removed, meaning there's no guarantee that a monitorDocument from the changefeed is actually the most recent version.

func (*FakeMonitorDocumentClient) Create 

func (c *FakeMonitorDocumentClient) Create(ctx context.Context, partitionkey string, monitorDocument *pkg.MonitorDocument, options *Options) (*pkg.MonitorDocument, error)

Create creates a MonitorDocument in the database

func (*FakeMonitorDocumentClient) Delete 

func (c *FakeMonitorDocumentClient) Delete(ctx context.Context, partitionKey string, monitorDocument *pkg.MonitorDocument, options *Options) error

Delete deletes a MonitorDocument from the database

func (*FakeMonitorDocumentClient) Get 

func (c *FakeMonitorDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.MonitorDocument, error)

Get gets a MonitorDocument from the database

func (*FakeMonitorDocumentClient) List 

func (c *FakeMonitorDocumentClient) List(*Options) MonitorDocumentIterator

List returns a MonitorDocumentIterator to list all MonitorDocuments in the database

func (*FakeMonitorDocumentClient) ListAll 

func (c *FakeMonitorDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.MonitorDocuments, error)

ListAll lists all MonitorDocuments in the database

func (*FakeMonitorDocumentClient) Query 

func (c *FakeMonitorDocumentClient) Query(name string, query *Query, options *Options) MonitorDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakeMonitorDocumentClient) QueryAll 

func (c *FakeMonitorDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.MonitorDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakeMonitorDocumentClient) Replace 

func (c *FakeMonitorDocumentClient) Replace(ctx context.Context, partitionkey string, monitorDocument *pkg.MonitorDocument, options *Options) (*pkg.MonitorDocument, error)

Replace replaces a MonitorDocument in the database

func (*FakeMonitorDocumentClient) SetConflictChecker 

func (c *FakeMonitorDocumentClient) SetConflictChecker(conflictChecker func(*pkg.MonitorDocument, *pkg.MonitorDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a MonitorDocument

func (*FakeMonitorDocumentClient) SetError 

func (c *FakeMonitorDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakeMonitorDocumentClient method invocation

func (*FakeMonitorDocumentClient) SetQueryHandler 

func (c *FakeMonitorDocumentClient) SetQueryHandler(queryName string, query fakeMonitorDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakeMonitorDocumentClient) SetSorter 

func (c *FakeMonitorDocumentClient) SetSorter(sorter func([]*pkg.MonitorDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakeMonitorDocumentClient) SetTriggerHandler 

func (c *FakeMonitorDocumentClient) SetTriggerHandler(triggerName string, trigger fakeMonitorDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type FakeOpenShiftClusterDocumentClient 

type FakeOpenShiftClusterDocumentClient struct {
	// contains filtered or unexported fields
}

FakeOpenShiftClusterDocumentClient is a FakeOpenShiftClusterDocumentClient

func NewFakeOpenShiftClusterDocumentClient 

func NewFakeOpenShiftClusterDocumentClient(h *codec.JsonHandle) *FakeOpenShiftClusterDocumentClient

NewFakeOpenShiftClusterDocumentClient returns a FakeOpenShiftClusterDocumentClient

func (*FakeOpenShiftClusterDocumentClient) AllIteratorsConsumed 

func (c *FakeOpenShiftClusterDocumentClient) AllIteratorsConsumed() bool

AllIteratorsConsumed returns whether all fake changefeeds have consumed their full contents

func (*FakeOpenShiftClusterDocumentClient) ChangeFeed 

func (c *FakeOpenShiftClusterDocumentClient) ChangeFeed(*Options) OpenShiftClusterDocumentIterator

ChangeFeed is a basic implementation of cosmosDB Changefeeds. Compared to the real changefeeds, its implementation is much more simplistic: - Deleting a OpenShiftClusterDocument does not remove it from the existing change feeds - when a OpenShiftClusterDocument is pushed into the changefeed, older versions that have not been retrieved won't be removed, meaning there's no guarantee that a openShiftClusterDocument from the changefeed is actually the most recent version.

func (*FakeOpenShiftClusterDocumentClient) Create 

func (c *FakeOpenShiftClusterDocumentClient) Create(ctx context.Context, partitionkey string, openShiftClusterDocument *pkg.OpenShiftClusterDocument, options *Options) (*pkg.OpenShiftClusterDocument, error)

Create creates a OpenShiftClusterDocument in the database

func (*FakeOpenShiftClusterDocumentClient) Delete 

func (c *FakeOpenShiftClusterDocumentClient) Delete(ctx context.Context, partitionKey string, openShiftClusterDocument *pkg.OpenShiftClusterDocument, options *Options) error

Delete deletes a OpenShiftClusterDocument from the database

func (*FakeOpenShiftClusterDocumentClient) Get 

func (c *FakeOpenShiftClusterDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.OpenShiftClusterDocument, error)

Get gets a OpenShiftClusterDocument from the database

func (*FakeOpenShiftClusterDocumentClient) List 

func (c *FakeOpenShiftClusterDocumentClient) List(*Options) OpenShiftClusterDocumentIterator

List returns a OpenShiftClusterDocumentIterator to list all OpenShiftClusterDocuments in the database

func (*FakeOpenShiftClusterDocumentClient) ListAll 

func (c *FakeOpenShiftClusterDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.OpenShiftClusterDocuments, error)

ListAll lists all OpenShiftClusterDocuments in the database

func (*FakeOpenShiftClusterDocumentClient) Query 

func (c *FakeOpenShiftClusterDocumentClient) Query(name string, query *Query, options *Options) OpenShiftClusterDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakeOpenShiftClusterDocumentClient) QueryAll 

func (c *FakeOpenShiftClusterDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.OpenShiftClusterDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakeOpenShiftClusterDocumentClient) Replace 

func (c *FakeOpenShiftClusterDocumentClient) Replace(ctx context.Context, partitionkey string, openShiftClusterDocument *pkg.OpenShiftClusterDocument, options *Options) (*pkg.OpenShiftClusterDocument, error)

Replace replaces a OpenShiftClusterDocument in the database

func (*FakeOpenShiftClusterDocumentClient) SetConflictChecker 

func (c *FakeOpenShiftClusterDocumentClient) SetConflictChecker(conflictChecker func(*pkg.OpenShiftClusterDocument, *pkg.OpenShiftClusterDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a OpenShiftClusterDocument

func (*FakeOpenShiftClusterDocumentClient) SetError 

func (c *FakeOpenShiftClusterDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakeOpenShiftClusterDocumentClient method invocation

func (*FakeOpenShiftClusterDocumentClient) SetQueryHandler 

func (c *FakeOpenShiftClusterDocumentClient) SetQueryHandler(queryName string, query fakeOpenShiftClusterDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakeOpenShiftClusterDocumentClient) SetSorter 

func (c *FakeOpenShiftClusterDocumentClient) SetSorter(sorter func([]*pkg.OpenShiftClusterDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakeOpenShiftClusterDocumentClient) SetTriggerHandler 

func (c *FakeOpenShiftClusterDocumentClient) SetTriggerHandler(triggerName string, trigger fakeOpenShiftClusterDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type FakeOpenShiftVersionDocumentClient 

type FakeOpenShiftVersionDocumentClient struct {
	// contains filtered or unexported fields
}

FakeOpenShiftVersionDocumentClient is a FakeOpenShiftVersionDocumentClient

func NewFakeOpenShiftVersionDocumentClient 

func NewFakeOpenShiftVersionDocumentClient(h *codec.JsonHandle) *FakeOpenShiftVersionDocumentClient

NewFakeOpenShiftVersionDocumentClient returns a FakeOpenShiftVersionDocumentClient

func (*FakeOpenShiftVersionDocumentClient) ChangeFeed 

func (c *FakeOpenShiftVersionDocumentClient) ChangeFeed(*Options) OpenShiftVersionDocumentIterator

ChangeFeed is a basic implementation of cosmosDB Changefeeds. Compared to the real changefeeds, its implementation is much more simplistic: - Deleting a OpenShiftVersionDocument does not remove it from the existing change feeds - when a OpenShiftVersionDocument is pushed into the changefeed, older versions that have not been retrieved won't be removed, meaning there's no guarantee that a openShiftVersionDocument from the changefeed is actually the most recent version.

func (*FakeOpenShiftVersionDocumentClient) Create 

func (c *FakeOpenShiftVersionDocumentClient) Create(ctx context.Context, partitionkey string, openShiftVersionDocument *pkg.OpenShiftVersionDocument, options *Options) (*pkg.OpenShiftVersionDocument, error)

Create creates a OpenShiftVersionDocument in the database

func (*FakeOpenShiftVersionDocumentClient) Delete 

func (c *FakeOpenShiftVersionDocumentClient) Delete(ctx context.Context, partitionKey string, openShiftVersionDocument *pkg.OpenShiftVersionDocument, options *Options) error

Delete deletes a OpenShiftVersionDocument from the database

func (*FakeOpenShiftVersionDocumentClient) Get 

func (c *FakeOpenShiftVersionDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.OpenShiftVersionDocument, error)

Get gets a OpenShiftVersionDocument from the database

func (*FakeOpenShiftVersionDocumentClient) List 

func (c *FakeOpenShiftVersionDocumentClient) List(*Options) OpenShiftVersionDocumentIterator

List returns a OpenShiftVersionDocumentIterator to list all OpenShiftVersionDocuments in the database

func (*FakeOpenShiftVersionDocumentClient) ListAll 

func (c *FakeOpenShiftVersionDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.OpenShiftVersionDocuments, error)

ListAll lists all OpenShiftVersionDocuments in the database

func (*FakeOpenShiftVersionDocumentClient) Query 

func (c *FakeOpenShiftVersionDocumentClient) Query(name string, query *Query, options *Options) OpenShiftVersionDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakeOpenShiftVersionDocumentClient) QueryAll 

func (c *FakeOpenShiftVersionDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.OpenShiftVersionDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakeOpenShiftVersionDocumentClient) Replace 

func (c *FakeOpenShiftVersionDocumentClient) Replace(ctx context.Context, partitionkey string, openShiftVersionDocument *pkg.OpenShiftVersionDocument, options *Options) (*pkg.OpenShiftVersionDocument, error)

Replace replaces a OpenShiftVersionDocument in the database

func (*FakeOpenShiftVersionDocumentClient) SetConflictChecker 

func (c *FakeOpenShiftVersionDocumentClient) SetConflictChecker(conflictChecker func(*pkg.OpenShiftVersionDocument, *pkg.OpenShiftVersionDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a OpenShiftVersionDocument

func (*FakeOpenShiftVersionDocumentClient) SetError 

func (c *FakeOpenShiftVersionDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakeOpenShiftVersionDocumentClient method invocation

func (*FakeOpenShiftVersionDocumentClient) SetQueryHandler 

func (c *FakeOpenShiftVersionDocumentClient) SetQueryHandler(queryName string, query fakeOpenShiftVersionDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakeOpenShiftVersionDocumentClient) SetSorter 

func (c *FakeOpenShiftVersionDocumentClient) SetSorter(sorter func([]*pkg.OpenShiftVersionDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakeOpenShiftVersionDocumentClient) SetTriggerHandler 

func (c *FakeOpenShiftVersionDocumentClient) SetTriggerHandler(triggerName string, trigger fakeOpenShiftVersionDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type FakePlatformWorkloadIdentityRoleSetDocumentClient 

type FakePlatformWorkloadIdentityRoleSetDocumentClient struct {
	// contains filtered or unexported fields
}

FakePlatformWorkloadIdentityRoleSetDocumentClient is a FakePlatformWorkloadIdentityRoleSetDocumentClient

func NewFakePlatformWorkloadIdentityRoleSetDocumentClient 

func NewFakePlatformWorkloadIdentityRoleSetDocumentClient(h *codec.JsonHandle) *FakePlatformWorkloadIdentityRoleSetDocumentClient

NewFakePlatformWorkloadIdentityRoleSetDocumentClient returns a FakePlatformWorkloadIdentityRoleSetDocumentClient

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) ChangeFeed 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) ChangeFeed(*Options) PlatformWorkloadIdentityRoleSetDocumentIterator

ChangeFeed is a basic implementation of cosmosDB Changefeeds. Compared to the real changefeeds, its implementation is much more simplistic: - Deleting a PlatformWorkloadIdentityRoleSetDocument does not remove it from the existing change feeds - when a PlatformWorkloadIdentityRoleSetDocument is pushed into the changefeed, older versions that have not been retrieved won't be removed, meaning there's no guarantee that a platformWorkloadIdentityRoleSetDocument from the changefeed is actually the most recent version.

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) Create 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) Create(ctx context.Context, partitionkey string, platformWorkloadIdentityRoleSetDocument *pkg.PlatformWorkloadIdentityRoleSetDocument, options *Options) (*pkg.PlatformWorkloadIdentityRoleSetDocument, error)

Create creates a PlatformWorkloadIdentityRoleSetDocument in the database

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) Delete 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) Delete(ctx context.Context, partitionKey string, platformWorkloadIdentityRoleSetDocument *pkg.PlatformWorkloadIdentityRoleSetDocument, options *Options) error

Delete deletes a PlatformWorkloadIdentityRoleSetDocument from the database

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) Get 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.PlatformWorkloadIdentityRoleSetDocument, error)

Get gets a PlatformWorkloadIdentityRoleSetDocument from the database

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) List 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) List(*Options) PlatformWorkloadIdentityRoleSetDocumentIterator

List returns a PlatformWorkloadIdentityRoleSetDocumentIterator to list all PlatformWorkloadIdentityRoleSetDocuments in the database

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) ListAll 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.PlatformWorkloadIdentityRoleSetDocuments, error)

ListAll lists all PlatformWorkloadIdentityRoleSetDocuments in the database

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) Query 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) Query(name string, query *Query, options *Options) PlatformWorkloadIdentityRoleSetDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) QueryAll 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.PlatformWorkloadIdentityRoleSetDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) Replace 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) Replace(ctx context.Context, partitionkey string, platformWorkloadIdentityRoleSetDocument *pkg.PlatformWorkloadIdentityRoleSetDocument, options *Options) (*pkg.PlatformWorkloadIdentityRoleSetDocument, error)

Replace replaces a PlatformWorkloadIdentityRoleSetDocument in the database

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) SetConflictChecker 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) SetConflictChecker(conflictChecker func(*pkg.PlatformWorkloadIdentityRoleSetDocument, *pkg.PlatformWorkloadIdentityRoleSetDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a PlatformWorkloadIdentityRoleSetDocument

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) SetError 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakePlatformWorkloadIdentityRoleSetDocumentClient method invocation

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) SetQueryHandler 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) SetQueryHandler(queryName string, query fakePlatformWorkloadIdentityRoleSetDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) SetSorter 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) SetSorter(sorter func([]*pkg.PlatformWorkloadIdentityRoleSetDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakePlatformWorkloadIdentityRoleSetDocumentClient) SetTriggerHandler 

func (c *FakePlatformWorkloadIdentityRoleSetDocumentClient) SetTriggerHandler(triggerName string, trigger fakePlatformWorkloadIdentityRoleSetDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type FakePortalDocumentClient 

type FakePortalDocumentClient struct {
	// contains filtered or unexported fields
}

FakePortalDocumentClient is a FakePortalDocumentClient

func NewFakePortalDocumentClient 

func NewFakePortalDocumentClient(h *codec.JsonHandle) *FakePortalDocumentClient

NewFakePortalDocumentClient returns a FakePortalDocumentClient

func (*FakePortalDocumentClient) ChangeFeed 

func (c *FakePortalDocumentClient) ChangeFeed(*Options) PortalDocumentIterator

ChangeFeed is unimplemented

func (*FakePortalDocumentClient) Create 

func (c *FakePortalDocumentClient) Create(ctx context.Context, partitionkey string, portalDocument *pkg.PortalDocument, options *Options) (*pkg.PortalDocument, error)

Create creates a PortalDocument in the database

func (*FakePortalDocumentClient) Delete 

func (c *FakePortalDocumentClient) Delete(ctx context.Context, partitionKey string, portalDocument *pkg.PortalDocument, options *Options) error

Delete deletes a PortalDocument from the database

func (*FakePortalDocumentClient) Get 

func (c *FakePortalDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.PortalDocument, error)

Get gets a PortalDocument from the database

func (*FakePortalDocumentClient) List 

func (c *FakePortalDocumentClient) List(*Options) PortalDocumentIterator

List returns a PortalDocumentIterator to list all PortalDocuments in the database

func (*FakePortalDocumentClient) ListAll 

func (c *FakePortalDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.PortalDocuments, error)

ListAll lists all PortalDocuments in the database

func (*FakePortalDocumentClient) Query 

func (c *FakePortalDocumentClient) Query(name string, query *Query, options *Options) PortalDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakePortalDocumentClient) QueryAll 

func (c *FakePortalDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.PortalDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakePortalDocumentClient) Replace 

func (c *FakePortalDocumentClient) Replace(ctx context.Context, partitionkey string, portalDocument *pkg.PortalDocument, options *Options) (*pkg.PortalDocument, error)

Replace replaces a PortalDocument in the database

func (*FakePortalDocumentClient) SetConflictChecker 

func (c *FakePortalDocumentClient) SetConflictChecker(conflictChecker func(*pkg.PortalDocument, *pkg.PortalDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a PortalDocument

func (*FakePortalDocumentClient) SetError 

func (c *FakePortalDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakePortalDocumentClient method invocation

func (*FakePortalDocumentClient) SetQueryHandler 

func (c *FakePortalDocumentClient) SetQueryHandler(queryName string, query fakePortalDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakePortalDocumentClient) SetSorter 

func (c *FakePortalDocumentClient) SetSorter(sorter func([]*pkg.PortalDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakePortalDocumentClient) SetTriggerHandler 

func (c *FakePortalDocumentClient) SetTriggerHandler(triggerName string, trigger fakePortalDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type FakeSubscriptionDocumentClient 

type FakeSubscriptionDocumentClient struct {
	// contains filtered or unexported fields
}

FakeSubscriptionDocumentClient is a FakeSubscriptionDocumentClient

func NewFakeSubscriptionDocumentClient 

func NewFakeSubscriptionDocumentClient(h *codec.JsonHandle) *FakeSubscriptionDocumentClient

NewFakeSubscriptionDocumentClient returns a FakeSubscriptionDocumentClient

func (*FakeSubscriptionDocumentClient) AllIteratorsConsumed 

func (c *FakeSubscriptionDocumentClient) AllIteratorsConsumed() bool

AllIteratorsConsumed returns whether all fake changefeeds have consumed their full contents

func (*FakeSubscriptionDocumentClient) ChangeFeed 

func (c *FakeSubscriptionDocumentClient) ChangeFeed(*Options) SubscriptionDocumentIterator

ChangeFeed is a basic implementation of cosmosDB Changefeeds. Compared to the real changefeeds, its implementation is much more simplistic: - Deleting a SubscriptionDocument does not remove it from the existing change feeds - when a SubscriptionDocument is pushed into the changefeed, older versions that have not been retrieved won't be removed, meaning there's no guarantee that a subscriptionDocument from the changefeed is actually the most recent version.

func (*FakeSubscriptionDocumentClient) Create 

func (c *FakeSubscriptionDocumentClient) Create(ctx context.Context, partitionkey string, subscriptionDocument *pkg.SubscriptionDocument, options *Options) (*pkg.SubscriptionDocument, error)

Create creates a SubscriptionDocument in the database

func (*FakeSubscriptionDocumentClient) Delete 

func (c *FakeSubscriptionDocumentClient) Delete(ctx context.Context, partitionKey string, subscriptionDocument *pkg.SubscriptionDocument, options *Options) error

Delete deletes a SubscriptionDocument from the database

func (*FakeSubscriptionDocumentClient) Get 

func (c *FakeSubscriptionDocumentClient) Get(ctx context.Context, partitionkey string, id string, options *Options) (*pkg.SubscriptionDocument, error)

Get gets a SubscriptionDocument from the database

func (*FakeSubscriptionDocumentClient) List 

func (c *FakeSubscriptionDocumentClient) List(*Options) SubscriptionDocumentIterator

List returns a SubscriptionDocumentIterator to list all SubscriptionDocuments in the database

func (*FakeSubscriptionDocumentClient) ListAll 

func (c *FakeSubscriptionDocumentClient) ListAll(ctx context.Context, options *Options) (*pkg.SubscriptionDocuments, error)

ListAll lists all SubscriptionDocuments in the database

func (*FakeSubscriptionDocumentClient) Query 

func (c *FakeSubscriptionDocumentClient) Query(name string, query *Query, options *Options) SubscriptionDocumentRawIterator

Query calls a query handler to implement database querying

func (*FakeSubscriptionDocumentClient) QueryAll 

func (c *FakeSubscriptionDocumentClient) QueryAll(ctx context.Context, partitionkey string, query *Query, options *Options) (*pkg.SubscriptionDocuments, error)

QueryAll calls a query handler to implement database querying

func (*FakeSubscriptionDocumentClient) Replace 

func (c *FakeSubscriptionDocumentClient) Replace(ctx context.Context, partitionkey string, subscriptionDocument *pkg.SubscriptionDocument, options *Options) (*pkg.SubscriptionDocument, error)

Replace replaces a SubscriptionDocument in the database

func (*FakeSubscriptionDocumentClient) SetConflictChecker 

func (c *FakeSubscriptionDocumentClient) SetConflictChecker(conflictChecker func(*pkg.SubscriptionDocument, *pkg.SubscriptionDocument) bool)

SetConflictChecker sets or unsets a function which can be used to validate additional unique keys in a SubscriptionDocument

func (*FakeSubscriptionDocumentClient) SetError 

func (c *FakeSubscriptionDocumentClient) SetError(err error)

SetError sets or unsets an error that will be returned on any FakeSubscriptionDocumentClient method invocation

func (*FakeSubscriptionDocumentClient) SetQueryHandler 

func (c *FakeSubscriptionDocumentClient) SetQueryHandler(queryName string, query fakeSubscriptionDocumentQueryHandler)

SetQueryHandler sets or unsets a query handler

func (*FakeSubscriptionDocumentClient) SetSorter 

func (c *FakeSubscriptionDocumentClient) SetSorter(sorter func([]*pkg.SubscriptionDocument))

SetSorter sets or unsets a sorter function which will be used to sort values returned by List() for test stability

func (*FakeSubscriptionDocumentClient) SetTriggerHandler 

func (c *FakeSubscriptionDocumentClient) SetTriggerHandler(triggerName string, trigger fakeSubscriptionDocumentTriggerHandler)

SetTriggerHandler sets or unsets a trigger handler

type GatewayDocumentClient 

type GatewayDocumentClient interface {
	Create(context.Context, string, *pkg.GatewayDocument, *Options) (*pkg.GatewayDocument, error)
	List(*Options) GatewayDocumentIterator
	ListAll(context.Context, *Options) (*pkg.GatewayDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.GatewayDocument, error)
	Replace(context.Context, string, *pkg.GatewayDocument, *Options) (*pkg.GatewayDocument, error)
	Delete(context.Context, string, *pkg.GatewayDocument, *Options) error
	Query(string, *Query, *Options) GatewayDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.GatewayDocuments, error)
	ChangeFeed(*Options) GatewayDocumentIterator
}

GatewayDocumentClient is a gatewayDocument client

func NewGatewayDocumentClient 

func NewGatewayDocumentClient(collc CollectionClient, collid string) GatewayDocumentClient

NewGatewayDocumentClient returns a new gatewayDocument client

type GatewayDocumentIterator 

type GatewayDocumentIterator interface {
	Next(context.Context, int) (*pkg.GatewayDocuments, error)
	Continuation() string
}

GatewayDocumentIterator is a gatewayDocument iterator

type GatewayDocumentRawIterator 

type GatewayDocumentRawIterator interface {
	GatewayDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

GatewayDocumentRawIterator is a gatewayDocument raw iterator

func NewFakeGatewayDocumentErroringRawIterator 

func NewFakeGatewayDocumentErroringRawIterator(err error) GatewayDocumentRawIterator

NewFakeGatewayDocumentErroringRawIterator returns a GatewayDocumentRawIterator which whose methods return the given error

func NewFakeGatewayDocumentIterator 

func NewFakeGatewayDocumentIterator(gatewayDocuments []*pkg.GatewayDocument, continuation int) GatewayDocumentRawIterator

type GeospatialConfig 

type GeospatialConfig struct {
	Type GeospatialConfigType `json:"type,omitempty"`
}

GeospatialConfig represents a geospatial config

type GeospatialConfigType 

type GeospatialConfigType string

GeospatialConfigType represents geospatial config types 

const (
	GeospatialConfigTypeGeography GeospatialConfigType = "Geography"
)

GeospatialConfigType constants

type IncludedPath 

type IncludedPath struct {
	Path    string  `json:"path,omitempty"`
	Indexes []Index `json:"indexes,omitempty"`
}

IncludedPath represents an included path

type Index 

type Index struct {
	DataType  IndexDataType `json:"dataType,omitempty"`
	Kind      IndexKind     `json:"kind,omitempty"`
	Precision int           `json:"precision,omitempty"`
}

Index represents an index

type IndexDataType 

type IndexDataType string

IndexDataType represents an index data type 

const (
	IndexDataTypeString     IndexDataType = "String"
	IndexDataTypeNumber     IndexDataType = "Number"
	IndexDataTypePoint      IndexDataType = "Point"
	IndexDataTypePolygon    IndexDataType = "Polygon"
	IndexDataTypeLineString IndexDataType = "LineString"
)

IndexDataType constants

type IndexKind 

type IndexKind string

IndexKind represents an index kind 

const (
	IndexKindHash    IndexKind = "Hash"
	IndexKindRange   IndexKind = "Range"
	IndexKindSpatial IndexKind = "Spatial"
)

IndexKind constants

type IndexingPolicy 

type IndexingPolicy struct {
	Automatic        bool               `json:"automatic,omitempty"`
	IndexingMode     IndexingPolicyMode `json:"indexingMode,omitempty"`
	IncludedPaths    []IncludedPath     `json:"includedPaths,omitempty"`
	ExcludedPaths    []IncludedPath     `json:"excludedPaths,omitempty"`
	CompositeIndexes []CompositeIndex   `json:"compositeIndexes,omitempty"`
}

IndexingPolicy represents an indexing policy

type IndexingPolicyMode 

type IndexingPolicyMode string

IndexingPolicyMode represents an indexing policy mode 

const (
	IndexingPolicyModeConsistent IndexingPolicyMode = "Consistent"
	IndexingPolicyModeLazy       IndexingPolicyMode = "Lazy"
)

IndexingPolicyMode constants

type MaintenanceManifestDocumentClient 

type MaintenanceManifestDocumentClient interface {
	Create(context.Context, string, *pkg.MaintenanceManifestDocument, *Options) (*pkg.MaintenanceManifestDocument, error)
	List(*Options) MaintenanceManifestDocumentIterator
	ListAll(context.Context, *Options) (*pkg.MaintenanceManifestDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.MaintenanceManifestDocument, error)
	Replace(context.Context, string, *pkg.MaintenanceManifestDocument, *Options) (*pkg.MaintenanceManifestDocument, error)
	Delete(context.Context, string, *pkg.MaintenanceManifestDocument, *Options) error
	Query(string, *Query, *Options) MaintenanceManifestDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.MaintenanceManifestDocuments, error)
	ChangeFeed(*Options) MaintenanceManifestDocumentIterator
}

MaintenanceManifestDocumentClient is a maintenanceManifestDocument client

func NewMaintenanceManifestDocumentClient 

func NewMaintenanceManifestDocumentClient(collc CollectionClient, collid string) MaintenanceManifestDocumentClient

NewMaintenanceManifestDocumentClient returns a new maintenanceManifestDocument client

type MaintenanceManifestDocumentIterator 

type MaintenanceManifestDocumentIterator interface {
	Next(context.Context, int) (*pkg.MaintenanceManifestDocuments, error)
	Continuation() string
}

MaintenanceManifestDocumentIterator is a maintenanceManifestDocument iterator

type MaintenanceManifestDocumentRawIterator 

type MaintenanceManifestDocumentRawIterator interface {
	MaintenanceManifestDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

MaintenanceManifestDocumentRawIterator is a maintenanceManifestDocument raw iterator

func NewFakeMaintenanceManifestDocumentErroringRawIterator 

func NewFakeMaintenanceManifestDocumentErroringRawIterator(err error) MaintenanceManifestDocumentRawIterator

NewFakeMaintenanceManifestDocumentErroringRawIterator returns a MaintenanceManifestDocumentRawIterator which whose methods return the given error

func NewFakeMaintenanceManifestDocumentIterator 

func NewFakeMaintenanceManifestDocumentIterator(maintenanceManifestDocuments []*pkg.MaintenanceManifestDocument, continuation int) MaintenanceManifestDocumentRawIterator

type MaintenanceScheduleDocumentClient 

type MaintenanceScheduleDocumentClient interface {
	Create(context.Context, string, *pkg.MaintenanceScheduleDocument, *Options) (*pkg.MaintenanceScheduleDocument, error)
	List(*Options) MaintenanceScheduleDocumentIterator
	ListAll(context.Context, *Options) (*pkg.MaintenanceScheduleDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.MaintenanceScheduleDocument, error)
	Replace(context.Context, string, *pkg.MaintenanceScheduleDocument, *Options) (*pkg.MaintenanceScheduleDocument, error)
	Delete(context.Context, string, *pkg.MaintenanceScheduleDocument, *Options) error
	Query(string, *Query, *Options) MaintenanceScheduleDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.MaintenanceScheduleDocuments, error)
	ChangeFeed(*Options) MaintenanceScheduleDocumentIterator
}

MaintenanceScheduleDocumentClient is a maintenanceScheduleDocument client

func NewMaintenanceScheduleDocumentClient 

func NewMaintenanceScheduleDocumentClient(collc CollectionClient, collid string) MaintenanceScheduleDocumentClient

NewMaintenanceScheduleDocumentClient returns a new maintenanceScheduleDocument client

type MaintenanceScheduleDocumentIterator 

type MaintenanceScheduleDocumentIterator interface {
	Next(context.Context, int) (*pkg.MaintenanceScheduleDocuments, error)
	Continuation() string
}

MaintenanceScheduleDocumentIterator is a maintenanceScheduleDocument iterator

type MaintenanceScheduleDocumentRawIterator 

type MaintenanceScheduleDocumentRawIterator interface {
	MaintenanceScheduleDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

MaintenanceScheduleDocumentRawIterator is a maintenanceScheduleDocument raw iterator

func NewFakeMaintenanceScheduleDocumentErroringRawIterator 

func NewFakeMaintenanceScheduleDocumentErroringRawIterator(err error) MaintenanceScheduleDocumentRawIterator

NewFakeMaintenanceScheduleDocumentErroringRawIterator returns a MaintenanceScheduleDocumentRawIterator which whose methods return the given error

func NewFakeMaintenanceScheduleDocumentIterator 

func NewFakeMaintenanceScheduleDocumentIterator(maintenanceScheduleDocuments []*pkg.MaintenanceScheduleDocument, continuation int) MaintenanceScheduleDocumentRawIterator

type MissingFields 

type MissingFields struct {
	// contains filtered or unexported fields
}

MissingFields retains values that do not map to struct fields during JSON marshalling/unmarshalling. MissingFields implements github.com/ugorji/go/codec.MissingFielder.

func (*MissingFields) CodecMissingField 

func (mf *MissingFields) CodecMissingField(field []byte, value interface{}) bool

CodecMissingField is called to set a missing field and value pair

func (*MissingFields) CodecMissingFields 

func (mf *MissingFields) CodecMissingFields() map[string]interface{}

CodecMissingFields returns the set of fields which are not struct fields

type MonitorDocumentClient 

type MonitorDocumentClient interface {
	Create(context.Context, string, *pkg.MonitorDocument, *Options) (*pkg.MonitorDocument, error)
	List(*Options) MonitorDocumentIterator
	ListAll(context.Context, *Options) (*pkg.MonitorDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.MonitorDocument, error)
	Replace(context.Context, string, *pkg.MonitorDocument, *Options) (*pkg.MonitorDocument, error)
	Delete(context.Context, string, *pkg.MonitorDocument, *Options) error
	Query(string, *Query, *Options) MonitorDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.MonitorDocuments, error)
	ChangeFeed(*Options) MonitorDocumentIterator
}

MonitorDocumentClient is a monitorDocument client

func NewMonitorDocumentClient 

func NewMonitorDocumentClient(collc CollectionClient, collid string) MonitorDocumentClient

NewMonitorDocumentClient returns a new monitorDocument client

type MonitorDocumentIterator 

type MonitorDocumentIterator interface {
	Next(context.Context, int) (*pkg.MonitorDocuments, error)
	Continuation() string
}

MonitorDocumentIterator is a monitorDocument iterator

type MonitorDocumentRawIterator 

type MonitorDocumentRawIterator interface {
	MonitorDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

MonitorDocumentRawIterator is a monitorDocument raw iterator

func NewFakeMonitorDocumentErroringRawIterator 

func NewFakeMonitorDocumentErroringRawIterator(err error) MonitorDocumentRawIterator

NewFakeMonitorDocumentErroringRawIterator returns a MonitorDocumentRawIterator which whose methods return the given error

func NewFakeMonitorDocumentIterator 

func NewFakeMonitorDocumentIterator(monitorDocuments []*pkg.MonitorDocument, continuation int) MonitorDocumentRawIterator

type OpenShiftClusterDocumentClient 

type OpenShiftClusterDocumentClient interface {
	Create(context.Context, string, *pkg.OpenShiftClusterDocument, *Options) (*pkg.OpenShiftClusterDocument, error)
	List(*Options) OpenShiftClusterDocumentIterator
	ListAll(context.Context, *Options) (*pkg.OpenShiftClusterDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.OpenShiftClusterDocument, error)
	Replace(context.Context, string, *pkg.OpenShiftClusterDocument, *Options) (*pkg.OpenShiftClusterDocument, error)
	Delete(context.Context, string, *pkg.OpenShiftClusterDocument, *Options) error
	Query(string, *Query, *Options) OpenShiftClusterDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.OpenShiftClusterDocuments, error)
	ChangeFeed(*Options) OpenShiftClusterDocumentIterator
}

OpenShiftClusterDocumentClient is a openShiftClusterDocument client

func NewOpenShiftClusterDocumentClient 

func NewOpenShiftClusterDocumentClient(collc CollectionClient, collid string) OpenShiftClusterDocumentClient

NewOpenShiftClusterDocumentClient returns a new openShiftClusterDocument client

type OpenShiftClusterDocumentIterator 

type OpenShiftClusterDocumentIterator interface {
	Next(context.Context, int) (*pkg.OpenShiftClusterDocuments, error)
	Continuation() string
}

OpenShiftClusterDocumentIterator is a openShiftClusterDocument iterator

type OpenShiftClusterDocumentRawIterator 

type OpenShiftClusterDocumentRawIterator interface {
	OpenShiftClusterDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

OpenShiftClusterDocumentRawIterator is a openShiftClusterDocument raw iterator

func NewFakeOpenShiftClusterDocumentErroringRawIterator 

func NewFakeOpenShiftClusterDocumentErroringRawIterator(err error) OpenShiftClusterDocumentRawIterator

NewFakeOpenShiftClusterDocumentErroringRawIterator returns a OpenShiftClusterDocumentRawIterator which whose methods return the given error

func NewFakeOpenShiftClusterDocumentIterator 

func NewFakeOpenShiftClusterDocumentIterator(openShiftClusterDocuments []*pkg.OpenShiftClusterDocument, continuation int) OpenShiftClusterDocumentRawIterator

type OpenShiftVersionDocumentClient 

type OpenShiftVersionDocumentClient interface {
	Create(context.Context, string, *pkg.OpenShiftVersionDocument, *Options) (*pkg.OpenShiftVersionDocument, error)
	List(*Options) OpenShiftVersionDocumentIterator
	ListAll(context.Context, *Options) (*pkg.OpenShiftVersionDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.OpenShiftVersionDocument, error)
	Replace(context.Context, string, *pkg.OpenShiftVersionDocument, *Options) (*pkg.OpenShiftVersionDocument, error)
	Delete(context.Context, string, *pkg.OpenShiftVersionDocument, *Options) error
	Query(string, *Query, *Options) OpenShiftVersionDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.OpenShiftVersionDocuments, error)
	ChangeFeed(*Options) OpenShiftVersionDocumentIterator
}

OpenShiftVersionDocumentClient is a openShiftVersionDocument client

func NewOpenShiftVersionDocumentClient 

func NewOpenShiftVersionDocumentClient(collc CollectionClient, collid string) OpenShiftVersionDocumentClient

NewOpenShiftVersionDocumentClient returns a new openShiftVersionDocument client

type OpenShiftVersionDocumentIterator 

type OpenShiftVersionDocumentIterator interface {
	Next(context.Context, int) (*pkg.OpenShiftVersionDocuments, error)
	Continuation() string
}

OpenShiftVersionDocumentIterator is a openShiftVersionDocument iterator

type OpenShiftVersionDocumentRawIterator 

type OpenShiftVersionDocumentRawIterator interface {
	OpenShiftVersionDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

OpenShiftVersionDocumentRawIterator is a openShiftVersionDocument raw iterator

func NewFakeOpenShiftVersionDocumentErroringRawIterator 

func NewFakeOpenShiftVersionDocumentErroringRawIterator(err error) OpenShiftVersionDocumentRawIterator

NewFakeOpenShiftVersionDocumentErroringRawIterator returns a OpenShiftVersionDocumentRawIterator which whose methods return the given error

func NewFakeOpenShiftVersionDocumentIterator 

func NewFakeOpenShiftVersionDocumentIterator(openShiftVersionDocuments []*pkg.OpenShiftVersionDocument, continuation int) OpenShiftVersionDocumentRawIterator

type Options 

type Options struct {
	NoETag              bool
	PreTriggers         []string
	PostTriggers        []string
	PartitionKeyRangeID string
	Continuation        string
}

Options represents API options

type Order 

type Order string

Order represents an order 

const (
	OrderAscending  Order = "ascending"
	OrderDescending Order = "descending"
)

Order constants

type Parameter 

type Parameter struct {
	Name  string `json:"name,omitempty"`
	Value string `json:"value,omitempty"`
}

Parameter represents a parameter

type PartitionKey 

type PartitionKey struct {
	Paths   []string         `json:"paths,omitempty"`
	Kind    PartitionKeyKind `json:"kind,omitempty"`
	Version int              `json:"version,omitempty"`
}

PartitionKey represents a partition key

type PartitionKeyKind 

type PartitionKeyKind string

PartitionKeyKind represents a partition key kind 

const (
	PartitionKeyKindHash PartitionKeyKind = "Hash"
)

PartitionKeyKind constants

type PartitionKeyRange 

type PartitionKeyRange struct {
	MissingFields

	ID                 string                  `json:"id,omitempty"`
	ResourceID         string                  `json:"_rid,omitempty"`
	Timestamp          int                     `json:"_ts,omitempty"`
	Self               string                  `json:"_self,omitempty"`
	ETag               string                  `json:"_etag,omitempty"`
	MaxExclusive       string                  `json:"maxExclusive,omitempty"`
	MinInclusive       string                  `json:"minInclusive,omitempty"`
	ResourceIDPrefix   int                     `json:"ridPrefix,omitempty"`
	ThroughputFraction float64                 `json:"throughputFraction,omitempty"`
	Status             PartitionKeyRangeStatus `json:"status,omitempty"`
	Parents            []string                `json:"parents,omitempty"`
	LSN                int                     `json:"lsn,omitempty"`
}

PartitionKeyRange represents a partition key range

type PartitionKeyRangeStatus 

type PartitionKeyRangeStatus string

PartitionKeyRangeStatus represents a partition key range status 

const (
	PartitionKeyRangeStatusOnline PartitionKeyRangeStatus = "online"
)

PartitionKeyRangeStatus constants

type PartitionKeyRanges 

type PartitionKeyRanges struct {
	Count              int                 `json:"_count,omitempty"`
	ResourceID         string              `json:"_rid,omitempty"`
	PartitionKeyRanges []PartitionKeyRange `json:"PartitionKeyRanges,omitempty"`
}

PartitionKeyRanges represents partition key ranges

type Permission 

type Permission struct {
	ID             string         `json:"id,omitempty"`
	ResourceID     string         `json:"_rid,omitempty"`
	Timestamp      int            `json:"_ts,omitempty"`
	Self           string         `json:"_self,omitempty"`
	ETag           string         `json:"_etag,omitempty"`
	Token          string         `json:"_token,omitempty"`
	PermissionMode PermissionMode `json:"permissionMode,omitempty"`
	Resource       string         `json:"resource,omitempty"`
}

Permission represents a permission

type PermissionClient 

type PermissionClient interface {
	Create(context.Context, *Permission) (*Permission, error)
	List() PermissionIterator
	ListAll(context.Context) (*Permissions, error)
	Get(context.Context, string) (*Permission, error)
	Delete(context.Context, *Permission) error
	Replace(context.Context, *Permission) (*Permission, error)
}

PermissionClient is a permission client

func NewPermissionClient 

func NewPermissionClient(userc UserClient, userid string) PermissionClient

NewPermissionClient returns a new permission client

type PermissionIterator 

type PermissionIterator interface {
	Next(context.Context) (*Permissions, error)
}

PermissionIterator is a permission iterator

type PermissionMode 

type PermissionMode string

PermissionMode represents a permission mode 

const (
	PermissionModeAll  PermissionMode = "All"
	PermissionModeRead PermissionMode = "Read"
)

PermissionMode constants

type Permissions 

type Permissions struct {
	Count       int           `json:"_count,omitempty"`
	ResourceID  string        `json:"_rid,omitempty"`
	Permissions []*Permission `json:"Permissions,omitempty"`
}

Permissions represents permissions

type PlatformWorkloadIdentityRoleSetDocumentClient 

type PlatformWorkloadIdentityRoleSetDocumentClient interface {
	Create(context.Context, string, *pkg.PlatformWorkloadIdentityRoleSetDocument, *Options) (*pkg.PlatformWorkloadIdentityRoleSetDocument, error)
	List(*Options) PlatformWorkloadIdentityRoleSetDocumentIterator
	ListAll(context.Context, *Options) (*pkg.PlatformWorkloadIdentityRoleSetDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.PlatformWorkloadIdentityRoleSetDocument, error)
	Replace(context.Context, string, *pkg.PlatformWorkloadIdentityRoleSetDocument, *Options) (*pkg.PlatformWorkloadIdentityRoleSetDocument, error)
	Delete(context.Context, string, *pkg.PlatformWorkloadIdentityRoleSetDocument, *Options) error
	Query(string, *Query, *Options) PlatformWorkloadIdentityRoleSetDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.PlatformWorkloadIdentityRoleSetDocuments, error)
	ChangeFeed(*Options) PlatformWorkloadIdentityRoleSetDocumentIterator
}

PlatformWorkloadIdentityRoleSetDocumentClient is a platformWorkloadIdentityRoleSetDocument client

func NewPlatformWorkloadIdentityRoleSetDocumentClient 

func NewPlatformWorkloadIdentityRoleSetDocumentClient(collc CollectionClient, collid string) PlatformWorkloadIdentityRoleSetDocumentClient

NewPlatformWorkloadIdentityRoleSetDocumentClient returns a new platformWorkloadIdentityRoleSetDocument client

type PlatformWorkloadIdentityRoleSetDocumentIterator 

type PlatformWorkloadIdentityRoleSetDocumentIterator interface {
	Next(context.Context, int) (*pkg.PlatformWorkloadIdentityRoleSetDocuments, error)
	Continuation() string
}

PlatformWorkloadIdentityRoleSetDocumentIterator is a platformWorkloadIdentityRoleSetDocument iterator

type PlatformWorkloadIdentityRoleSetDocumentRawIterator 

type PlatformWorkloadIdentityRoleSetDocumentRawIterator interface {
	PlatformWorkloadIdentityRoleSetDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

PlatformWorkloadIdentityRoleSetDocumentRawIterator is a platformWorkloadIdentityRoleSetDocument raw iterator

func NewFakePlatformWorkloadIdentityRoleSetDocumentErroringRawIterator 

func NewFakePlatformWorkloadIdentityRoleSetDocumentErroringRawIterator(err error) PlatformWorkloadIdentityRoleSetDocumentRawIterator

NewFakePlatformWorkloadIdentityRoleSetDocumentErroringRawIterator returns a PlatformWorkloadIdentityRoleSetDocumentRawIterator which whose methods return the given error

func NewFakePlatformWorkloadIdentityRoleSetDocumentIterator 

func NewFakePlatformWorkloadIdentityRoleSetDocumentIterator(platformWorkloadIdentityRoleSetDocuments []*pkg.PlatformWorkloadIdentityRoleSetDocument, continuation int) PlatformWorkloadIdentityRoleSetDocumentRawIterator

type PortalDocumentClient 

type PortalDocumentClient interface {
	Create(context.Context, string, *pkg.PortalDocument, *Options) (*pkg.PortalDocument, error)
	List(*Options) PortalDocumentIterator
	ListAll(context.Context, *Options) (*pkg.PortalDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.PortalDocument, error)
	Replace(context.Context, string, *pkg.PortalDocument, *Options) (*pkg.PortalDocument, error)
	Delete(context.Context, string, *pkg.PortalDocument, *Options) error
	Query(string, *Query, *Options) PortalDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.PortalDocuments, error)
	ChangeFeed(*Options) PortalDocumentIterator
}

PortalDocumentClient is a portalDocument client

func NewPortalDocumentClient 

func NewPortalDocumentClient(collc CollectionClient, collid string) PortalDocumentClient

NewPortalDocumentClient returns a new portalDocument client

type PortalDocumentIterator 

type PortalDocumentIterator interface {
	Next(context.Context, int) (*pkg.PortalDocuments, error)
	Continuation() string
}

PortalDocumentIterator is a portalDocument iterator

type PortalDocumentRawIterator 

type PortalDocumentRawIterator interface {
	PortalDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

PortalDocumentRawIterator is a portalDocument raw iterator

func NewFakePortalDocumentErroringRawIterator 

func NewFakePortalDocumentErroringRawIterator(err error) PortalDocumentRawIterator

NewFakePortalDocumentErroringRawIterator returns a PortalDocumentRawIterator which whose methods return the given error

func NewFakePortalDocumentIterator 

func NewFakePortalDocumentIterator(portalDocuments []*pkg.PortalDocument, continuation int) PortalDocumentRawIterator

type Query 

type Query struct {
	Query      string      `json:"query,omitempty"`
	Parameters []Parameter `json:"parameters,omitempty"`
}

Query represents a query

type SubscriptionDocumentClient 

type SubscriptionDocumentClient interface {
	Create(context.Context, string, *pkg.SubscriptionDocument, *Options) (*pkg.SubscriptionDocument, error)
	List(*Options) SubscriptionDocumentIterator
	ListAll(context.Context, *Options) (*pkg.SubscriptionDocuments, error)
	Get(context.Context, string, string, *Options) (*pkg.SubscriptionDocument, error)
	Replace(context.Context, string, *pkg.SubscriptionDocument, *Options) (*pkg.SubscriptionDocument, error)
	Delete(context.Context, string, *pkg.SubscriptionDocument, *Options) error
	Query(string, *Query, *Options) SubscriptionDocumentRawIterator
	QueryAll(context.Context, string, *Query, *Options) (*pkg.SubscriptionDocuments, error)
	ChangeFeed(*Options) SubscriptionDocumentIterator
}

SubscriptionDocumentClient is a subscriptionDocument client

func NewSubscriptionDocumentClient 

func NewSubscriptionDocumentClient(collc CollectionClient, collid string) SubscriptionDocumentClient

NewSubscriptionDocumentClient returns a new subscriptionDocument client

type SubscriptionDocumentIterator 

type SubscriptionDocumentIterator interface {
	Next(context.Context, int) (*pkg.SubscriptionDocuments, error)
	Continuation() string
}

SubscriptionDocumentIterator is a subscriptionDocument iterator

type SubscriptionDocumentRawIterator 

type SubscriptionDocumentRawIterator interface {
	SubscriptionDocumentIterator
	NextRaw(context.Context, int, interface{}) error
}

SubscriptionDocumentRawIterator is a subscriptionDocument raw iterator

func NewFakeSubscriptionDocumentErroringRawIterator 

func NewFakeSubscriptionDocumentErroringRawIterator(err error) SubscriptionDocumentRawIterator

NewFakeSubscriptionDocumentErroringRawIterator returns a SubscriptionDocumentRawIterator which whose methods return the given error

func NewFakeSubscriptionDocumentIterator 

func NewFakeSubscriptionDocumentIterator(subscriptionDocuments []*pkg.SubscriptionDocument, continuation int) SubscriptionDocumentRawIterator

type Trigger 

type Trigger struct {
	ID               string           `json:"id,omitempty"`
	ResourceID       string           `json:"_rid,omitempty"`
	Timestamp        int              `json:"_ts,omitempty"`
	Self             string           `json:"_self,omitempty"`
	ETag             string           `json:"_etag,omitempty"`
	Body             string           `json:"body,omitempty"`
	TriggerOperation TriggerOperation `json:"triggerOperation,omitempty"`
	TriggerType      TriggerType      `json:"triggerType,omitempty"`
}

Trigger represents a trigger

type TriggerClient 

type TriggerClient interface {
	Create(context.Context, *Trigger) (*Trigger, error)
	List() TriggerIterator
	ListAll(context.Context) (*Triggers, error)
	Get(context.Context, string) (*Trigger, error)
	Delete(context.Context, *Trigger) error
	Replace(context.Context, *Trigger) (*Trigger, error)
}

TriggerClient is a trigger client

func NewTriggerClient 

func NewTriggerClient(collc CollectionClient, collid string) TriggerClient

NewTriggerClient returns a new trigger client

type TriggerIterator 

type TriggerIterator interface {
	Next(context.Context) (*Triggers, error)
}

TriggerIterator is a trigger iterator

type TriggerOperation 

type TriggerOperation string

TriggerOperation represents a trigger operation 

const (
	TriggerOperationAll     TriggerOperation = "All"
	TriggerOperationCreate  TriggerOperation = "Create"
	TriggerOperationReplace TriggerOperation = "Replace"
	TriggerOperationDelete  TriggerOperation = "Delete"
)

TriggerOperation constants

type TriggerType 

type TriggerType string

TriggerType represents a trigger type 

const (
	TriggerTypePre  TriggerType = "Pre"
	TriggerTypePost TriggerType = "Post"
)

TriggerType constants

type Triggers 

type Triggers struct {
	Count      int        `json:"_count,omitempty"`
	ResourceID string     `json:"_rid,omitempty"`
	Triggers   []*Trigger `json:"Triggers,omitempty"`
}

Triggers represents triggers

type UniqueKey 

type UniqueKey struct {
	Paths []string `json:"paths,omitempty"`
}

UniqueKey represents a unique key

type UniqueKeyPolicy 

type UniqueKeyPolicy struct {
	UniqueKeys []UniqueKey `json:"uniqueKeys,omitempty"`
}

UniqueKeyPolicy represents a unique key policy

type User 

type User struct {
	ID          string `json:"id,omitempty"`
	ResourceID  string `json:"_rid,omitempty"`
	Timestamp   int    `json:"_ts,omitempty"`
	Self        string `json:"_self,omitempty"`
	ETag        string `json:"_etag,omitempty"`
	Permissions string `json:"_permissions,omitempty"`
}

User represents a user

type UserClient 

type UserClient interface {
	Create(context.Context, *User) (*User, error)
	List() UserIterator
	ListAll(context.Context) (*Users, error)
	Get(context.Context, string) (*User, error)
	Delete(context.Context, *User) error
	Replace(context.Context, *User) (*User, error)
}

UserClient is a user client

func NewUserClient 

func NewUserClient(c DatabaseClient, dbid string) UserClient

NewUserClient returns a new user client

type UserIterator 

type UserIterator interface {
	Next(context.Context) (*Users, error)
}

UserIterator is a user iterator

type Users 

type Users struct {
	Count      int     `json:"_count,omitempty"`
	ResourceID string  `json:"_rid,omitempty"`
	Users      []*User `json:"Users,omitempty"`
}

Users represents users

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.