package api // Copyright (c) Microsoft Corporation. // Licensed under the Apache License 2.0. // SubscriptionDocuments represents subscription documents. // pkg/database/cosmosdb requires its definition. type SubscriptionDocuments struct { Count int `json:"_count,omitempty"` ResourceID string `json:"_rid,omitempty"` SubscriptionDocuments []*SubscriptionDocument `json:"Documents,omitempty"` } func (c *SubscriptionDocuments) String() string { return encodeJSON(c) } // SubscriptionDocument represents a subscription document. // pkg/database/cosmosdb requires its definition. type SubscriptionDocument 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" deep:"-"` Attachments string `json:"_attachments,omitempty"` LSN int `json:"_lsn,omitempty"` Metadata map[string]interface{} `json:"_metadata,omitempty"` LeaseOwner string `json:"leaseOwner,omitempty"` LeaseExpires int `json:"leaseExpires,omitempty"` Dequeues int `json:"dequeues,omitempty"` Deleting bool `json:"deleting,omitempty"` Subscription *Subscription `json:"subscription,omitempty"` } func (c *SubscriptionDocument) String() string { return encodeJSON(c) }