Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

documentdb

package module

Go to main page

Versions in this module

v1

v1.3.0

Jun 25, 2021

Changes in this version

type Config

+ ServicePrincipal ServicePrincipalProvider

+ func NewConfigWithServicePrincipal(servicePrincipal ServicePrincipalProvider) *Config

+ type ServicePrincipalProvider interface

+ EnsureFresh func() error

+ OAuthToken func() string

v1.2.0

Aug 31, 2019

v1.1.0

Jul 30, 2019

Changes in this version

+ const HeaderAIM

+ const HeaderActivityID

+ const HeaderAuth

+ const HeaderConsistency

+ const HeaderContentLength

+ const HeaderContentType

+ const HeaderContinuation

+ const HeaderCrossPartition

+ const HeaderIfMatch

+ const HeaderIfModifiedSince

+ const HeaderIfNonMatch

+ const HeaderIsQuery

+ const HeaderMaxItemCount

+ const HeaderPartitionKey

+ const HeaderPartitionKeyRangeID

+ const HeaderRequestCharge

+ const HeaderSessionToken

+ const HeaderUpsert

+ const HeaderVersion

+ const HeaderXDate

+ const SupportedVersion

+ var DefaultSerialization = SerializationDriver

+ var Serialization = DefaultSerialization

+ func DefaultIdentificationHydrator(config *Config, doc interface{})

+ type CallOption func(r *Request) error

+ func ChangeFeed() CallOption

+ func ChangeFeedPartitionRangeID(id string) CallOption

+ func ConsistencyLevel(consistency Consistency) CallOption

+ func Continuation(continuation string) CallOption

+ func CrossPartition() CallOption

+ func IfMatch(etag string) CallOption

+ func IfModifiedSince(date string) CallOption

+ func IfNoneMatch(etag string) CallOption

+ func Limit(limit int) CallOption

+ func PartitionKey(partitionKey interface{}) CallOption

+ func SessionToken(sessionToken string) CallOption

+ func Upsert() CallOption

+ type Client struct

+ Config *Config

+ Url string

+ func (c *Client) Create(link string, body, ret interface{}, opts ...CallOption) (*Response, error)

+ func (c *Client) Delete(link string, opts ...CallOption) (*Response, error)

+ func (c *Client) Execute(link string, body, ret interface{}, opts ...CallOption) (*Response, error)

+ func (c *Client) Query(link string, query *Query, ret interface{}, opts ...CallOption) (*Response, error)

+ func (c *Client) Read(link string, ret interface{}, opts ...CallOption) (*Response, error)

+ func (c *Client) Replace(link string, body, ret interface{}, opts ...CallOption) (*Response, error)

+ func (c *Client) Upsert(link string, body, ret interface{}, opts ...CallOption) (*Response, error)

+ type Clienter interface

+ Create func(link string, body, ret interface{}, opts ...CallOption) (*Response, error)

+ Delete func(link string, opts ...CallOption) (*Response, error)

+ Execute func(link string, body, ret interface{}, opts ...CallOption) (*Response, error)

+ Query func(link string, query *Query, ret interface{}, opts ...CallOption) (*Response, error)

+ Read func(link string, ret interface{}, opts ...CallOption) (*Response, error)

+ Replace func(link string, body, ret interface{}, opts ...CallOption) (*Response, error)

+ Upsert func(link string, body, ret interface{}, opts ...CallOption) (*Response, error)

+ type Collection struct

+ Conflicts string

+ Docs string

+ IndexingPolicy IndexingPolicy

+ Sporcs string

+ Triggers string

+ Udf string

+ type Collections []Collection

+ func (c Collections) First() *Collection

+ type Config struct

+ Client http.Client

+ IdentificationHydrator IdentificationHydrator

+ IdentificationPropertyName string

+ MasterKey *Key

+ func NewConfig(key *Key) *Config

+ func (c *Config) WithClient(client http.Client) *Config

+ type Consistency string

+ const Bounded

+ const Eventual

+ const Session

+ const Strong

+ type Database struct

+ Colls string

+ Users string

+ type Databases []Database

+ func (d Databases) First() *Database

+ type DecoderFactory func(io.Reader) JSONDecoder

+ type Document struct

+ type DocumentDB struct

+ func New(url string, config *Config) *DocumentDB

+ func (c *DocumentDB) CreateCollection(db string, body interface{}, opts ...CallOption) (coll *Collection, err error)

+ func (c *DocumentDB) CreateDatabase(body interface{}, opts ...CallOption) (db *Database, err error)

+ func (c *DocumentDB) CreateDocument(coll string, doc interface{}, opts ...CallOption) (*Response, error)

+ func (c *DocumentDB) CreateStoredProcedure(coll string, body interface{}, opts ...CallOption) (sproc *Sproc, err error)

+ func (c *DocumentDB) CreateUserDefinedFunction(coll string, body interface{}, opts ...CallOption) (udf *UDF, err error)

+ func (c *DocumentDB) DeleteCollection(link string) (*Response, error)

+ func (c *DocumentDB) DeleteDatabase(link string) (*Response, error)

+ func (c *DocumentDB) DeleteDocument(link string) (*Response, error)

+ func (c *DocumentDB) DeleteStoredProcedure(link string) (*Response, error)

+ func (c *DocumentDB) DeleteUserDefinedFunction(link string) (*Response, error)

+ func (c *DocumentDB) ExecuteStoredProcedure(link string, params, body interface{}, opts ...CallOption) (err error)

+ func (c *DocumentDB) QueryCollections(db string, query *Query, opts ...CallOption) (colls []Collection, err error)

+ func (c *DocumentDB) QueryDatabases(query *Query, opts ...CallOption) (dbs Databases, err error)

+ func (c *DocumentDB) QueryDocuments(coll string, query *Query, docs interface{}, opts ...CallOption) (response *Response, err error)

+ func (c *DocumentDB) QueryPartitionKeyRanges(coll string, query *Query, opts ...CallOption) (ranges []PartitionKeyRange, err error)

+ func (c *DocumentDB) QueryStoredProcedures(coll string, query *Query, opts ...CallOption) (sprocs []Sproc, err error)

+ func (c *DocumentDB) QueryUserDefinedFunctions(coll string, query *Query, opts ...CallOption) (udfs []UDF, err error)

+ func (c *DocumentDB) ReadCollection(link string, opts ...CallOption) (coll *Collection, err error)

+ func (c *DocumentDB) ReadCollections(db string, opts ...CallOption) (colls []Collection, err error)

+ func (c *DocumentDB) ReadDatabase(link string, opts ...CallOption) (db *Database, err error)

+ func (c *DocumentDB) ReadDatabases(opts ...CallOption) (dbs []Database, err error)

+ func (c *DocumentDB) ReadDocument(link string, doc interface{}, opts ...CallOption) (err error)

+ func (c *DocumentDB) ReadDocuments(coll string, docs interface{}, opts ...CallOption) (r *Response, err error)

+ func (c *DocumentDB) ReadStoredProcedure(link string, opts ...CallOption) (sproc *Sproc, err error)

+ func (c *DocumentDB) ReadStoredProcedures(coll string, opts ...CallOption) (sprocs []Sproc, err error)

+ func (c *DocumentDB) ReadUserDefinedFunction(link string, opts ...CallOption) (udf *UDF, err error)

+ func (c *DocumentDB) ReadUserDefinedFunctions(coll string, opts ...CallOption) (udfs []UDF, err error)

+ func (c *DocumentDB) ReplaceDatabase(link string, body interface{}, opts ...CallOption) (db *Database, err error)

+ func (c *DocumentDB) ReplaceDocument(link string, doc interface{}, opts ...CallOption) (*Response, error)

+ func (c *DocumentDB) ReplaceStoredProcedure(link string, body interface{}, opts ...CallOption) (sproc *Sproc, err error)

+ func (c *DocumentDB) ReplaceUserDefinedFunction(link string, body interface{}, opts ...CallOption) (udf *UDF, err error)

+ func (c *DocumentDB) UpsertDocument(coll string, doc interface{}, opts ...CallOption) (*Response, error)

+ type EncoderFactory func(*bytes.Buffer) JSONEncoder

+ type IdentificationHydrator func(config *Config, doc interface{})

+ type IndexingPolicy struct

+ Automatic bool

+ IndexingMode string

+ type Iterator struct

+ func NewIterator(db *DocumentDB, source IteratorFunc) *Iterator

+ func (di *Iterator) Error() error

+ func (di *Iterator) Next() bool

+ func (di *Iterator) Response() *Response

+ type IteratorFunc func(db *DocumentDB, internalOpts ...CallOption) (*Response, error)

+ func NewDocumentIterator(coll string, query *Query, docs interface{}, opts ...CallOption) IteratorFunc

+ type JSONDecoder interface

+ Decode func(obj interface{}) error

+ type JSONEncoder interface

+ Encode func(val interface{}) error

+ type Key struct

+ Key string

+ func NewKey(key string) *Key

+ func (k *Key) Salt() ([]byte, error)

+ type Marshal func(v interface{}) ([]byte, error)

+ type P = Parameter

+ type Parameter struct

+ Name string

+ Value string

+ type PartitionKeyRange struct

+ MaxInclusive string

+ MinInclusive string

+ PartitionKeyRangeID string

+ type Query struct

+ Parameters []Parameter

+ Query string

+ func NewQuery(query string, parameters ...Parameter) *Query

+ type Request struct

+ func ResourceRequest(link string, req *http.Request) *Request

+ func (req *Request) DefaultHeaders(mKey *Key) (err error)

+ func (req *Request) QueryHeaders(len int)

+ type RequestError struct

+ Code string

+ Message string

+ func (e RequestError) Error() string

+ type Resource struct

+ Etag string

+ Id string

+ Rid string

+ Self string

+ Ts int

+ type Response struct

+ Header http.Header

+ func (r *Response) Continuation() string

+ type SerializationDriver struct

+ DecoderFactory DecoderFactory

+ EncoderFactory EncoderFactory

+ Marshal Marshal

+ Unmarshal Unmarshal

+ type Sproc struct

+ Body string

+ type UDF struct

+ Body string

+ type Unmarshal func(data []byte, v interface{}) error

v1.0.0

Sep 18, 2018