gocosmos

package module

Go to main page

Versions in this module

v1

v1.1.0

Feb 13, 2024

Changes in this version

type Conn

+ func (c *Conn) Ping(_ context.Context) error

+ func (c *Conn) String() string

+ type Connector struct

+ func (c *Connector) Connect(_ context.Context) (driver.Conn, error)

+ func (c *Connector) Driver() driver.Driver

+ func (c *Connector) String() string

type Driver

+ func (d *Driver) OpenConnector(connStr string) (driver.Connector, error)

type Stmt

+ func (s *Stmt) String() string

type StmtAlterCollection

+ func (s *StmtAlterCollection) ExecContext(_ context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *StmtAlterCollection) String() string

type StmtAlterDatabase

+ func (s *StmtAlterDatabase) ExecContext(_ context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *StmtAlterDatabase) String() string

type StmtCRUD

+ func (s *StmtCRUD) String() string

type StmtCreateCollection

+ func (s *StmtCreateCollection) ExecContext(_ context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *StmtCreateCollection) String() string

type StmtCreateDatabase

+ func (s *StmtCreateDatabase) ExecContext(_ context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *StmtCreateDatabase) String() string

type StmtDelete

+ func (s *StmtDelete) ExecContext(_ context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *StmtDelete) String() string

type StmtDropCollection

+ func (s *StmtDropCollection) ExecContext(_ context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *StmtDropCollection) String() string

type StmtDropDatabase

+ func (s *StmtDropDatabase) ExecContext(_ context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *StmtDropDatabase) String() string

type StmtInsert

+ func (s *StmtInsert) ExecContext(_ context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *StmtInsert) String() string

type StmtListCollections

+ func (s *StmtListCollections) QueryContext(_ context.Context, args []driver.NamedValue) (driver.Rows, error)

+ func (s *StmtListCollections) String() string

type StmtListDatabases

+ func (s *StmtListDatabases) QueryContext(_ context.Context, args []driver.NamedValue) (driver.Rows, error)

+ func (s *StmtListDatabases) String() string

type StmtSelect

+ func (s *StmtSelect) QueryContext(_ context.Context, args []driver.NamedValue) (driver.Rows, error)

+ func (s *StmtSelect) String() string

type StmtUpdate

+ func (s *StmtUpdate) ExecContext(_ context.Context, args []driver.NamedValue) (driver.Result, error)

+ func (s *StmtUpdate) String() string

v1.0.0

Dec 22, 2023

Changes in this version

+ const DefaultApiVersion

+ var ErrExecNotSupported = errors.New("this operation is not supported, please use Query")

+ var ErrOperationNotSupported = errors.New("this operation is not supported")

+ var ErrPreconditionFailure = errors.New("StatusCode=412 Precondition failure")

+ var ErrQueryNotSupported = errors.New("this operation is not supported, please use Exec")

type Conn

+ func (c *Conn) BeginTx(_ context.Context, _ driver.TxOptions) (driver.Tx, error)

+ func (c *Conn) PrepareContext(_ context.Context, query string) (driver.Stmt, error)

type DocInfo

+ func (d DocInfo) AsMap() map[string]interface{}

type ListDocsReq

+ IsIncrementalFeed bool

+ PkRangeId string

+ type PkInfo map[string]interface

+ func (pk PkInfo) Kind() string

+ func (pk PkInfo) Paths() []string

+ func (pk PkInfo) Version() int

+ type QueriedDocs []interface

+ func (docs QueriedDocs) AsDocInfoAt(i int) DocInfo

+ func (docs QueriedDocs) AsDocInfoSlice() []DocInfo

+ func (docs QueriedDocs) Flatten(queryPlan *RespQueryPlan) QueriedDocs

+ func (docs QueriedDocs) Merge(queryPlan *RespQueryPlan, otherDocs QueriedDocs) QueriedDocs

+ func (docs QueriedDocs) ReduceDistinct(queryPlan *RespQueryPlan) QueriedDocs

+ func (docs QueriedDocs) ReduceGroupBy(queryPlan *RespQueryPlan) QueriedDocs

type RespQueryDocs

+ QueryPlan *RespQueryPlan

+ RewrittenDocuments QueriedDocs

type RespQueryPlan

+ func (qp *RespQueryPlan) IsDistinctQuery() bool

+ func (qp *RespQueryPlan) IsGroupByQuery() bool

+ func (qp *RespQueryPlan) IsOrderByQuery() bool

type RestClient

+ func (c *RestClient) GetApiVersion() string

+ func (c *RestClient) GetAutoId() bool

+ func (c *RestClient) QueryDocumentsCrossPartition(query QueryReq) *RespQueryDocs

+ func (c *RestClient) SetAutoId(value bool) *RestClient

+ type RestResponse struct

+ ApiErr error

+ CallErr error

+ RequestCharge float64

+ RespBody []byte

+ RespHeader map[string]string

+ SessionToken string

+ StatusCode int

+ func (r RestResponse) Error() error

+ type ResultNoResultSet struct

+ func (r *ResultNoResultSet) LastInsertId() (int64, error)

+ func (r *ResultNoResultSet) RowsAffected() (int64, error)

+ type ResultResultSet struct

+ func (r *ResultResultSet) Close() error

+ func (r *ResultResultSet) ColumnTypeDatabaseTypeName(index int) string

+ func (r *ResultResultSet) ColumnTypeScanType(index int) reflect.Type

+ func (r *ResultResultSet) Columns() []string

+ func (r *ResultResultSet) Next(dest []driver.Value) error

+ type StmtCRUD struct

v0

v0.1.8

Dec 5, 2022

Changes in this version

type QueryReq

+ PkRangeId string

+ PkValue string

+ type RespQueryPlan struct

+ QueryExecutionInfoVersion int

+ QueryInfo struct{ ... }

type RestClient

+ func (c *RestClient) QueryPlan(query QueryReq) *RespQueryPlan

v0.1.7

Dec 2, 2022

v0.1.6

Feb 16, 2022

v0.1.5

Feb 16, 2022

v0.1.4

Jul 14, 2021

v0.1.3

Dec 27, 2020

Changes in this version

+ type PkrangeInfo struct

+ Etag string

+ Id string

+ MaxExclusive string

+ MinInclusive string

+ Rid string

+ Self string

+ Ts int64

+ type RespGetPkranges struct

+ Count int64

+ Pkranges []PkrangeInfo

type RestClient

+ func (c *RestClient) GetPkranges(dbName, collName string) *RespGetPkranges

v0.1.2

Dec 26, 2020

v0.1.1

Dec 26, 2020

Changes in this version

+ type OfferInfo struct

+ Content map[string]interface{}

+ Etag string

+ Id string

+ OfferResourceId string

+ OfferType string

+ OfferVersion string

+ Resource string

+ Rid string

+ Self string

+ Ts int64

+ func (o OfferInfo) IsAutopilot() bool

+ func (o OfferInfo) MaxThroughputEverProvisioned() int

+ func (o OfferInfo) OfferThroughput() int

+ type RespGetOffer struct

+ type RespQueryOffers struct

+ ContinuationToken string

+ Count int64

+ Offers []OfferInfo

+ type RespReplaceOffer struct

type RestClient

+ func (c *RestClient) GetOfferForResource(rid string) *RespGetOffer

+ func (c *RestClient) QueryOffers(query string) *RespQueryOffers

+ func (c *RestClient) ReplaceOfferForResource(rid string, ru, maxru int) *RespReplaceOffer

+ type ResultAlterCollection struct

+ Successful bool

+ func (r *ResultAlterCollection) LastInsertId() (int64, error)

+ func (r *ResultAlterCollection) RowsAffected() (int64, error)

+ type ResultAlterDatabase struct

+ Successful bool

+ func (r *ResultAlterDatabase) LastInsertId() (int64, error)

+ func (r *ResultAlterDatabase) RowsAffected() (int64, error)

+ type StmtAlterCollection struct

+ func (s *StmtAlterCollection) Exec(_ []driver.Value) (driver.Result, error)

+ func (s *StmtAlterCollection) Query(_ []driver.Value) (driver.Rows, error)

+ type StmtAlterDatabase struct

+ func (s *StmtAlterDatabase) Exec(_ []driver.Value) (driver.Result, error)

+ func (s *StmtAlterDatabase) Query(_ []driver.Value) (driver.Rows, error)

v0.1.0

Dec 21, 2020

Changes in this version

+ const Version

+ var ErrConflict = errors.New("StatusCode=409 Conflict")

+ var ErrForbidden = errors.New("StatusCode=403 Forbidden")

+ var ErrNotFound = errors.New("StatusCode=404 Not Found")

+ type CollInfo struct

+ ConflictResolutionPolicy map[string]interface{}

+ Conflicts string

+ Docs string

+ Etag string

+ GeospatialConfig map[string]interface{}

+ Id string

+ IndexingPolicy map[string]interface{}

+ PartitionKey map[string]interface{}

+ Rid string

+ Self string

+ Sprocs string

+ Triggers string

+ Ts int64

+ Udfs string

+ type CollectionSpec struct

+ CollName string

+ DbName string

+ IndexingPolicy map[string]interface{}

+ MaxRu int

+ PartitionKeyInfo map[string]interface{}

+ Ru int

+ UniqueKeyPolicy map[string]interface{}

+ type Conn struct

+ func (c *Conn) Begin() (driver.Tx, error)

+ func (c *Conn) CheckNamedValue(value *driver.NamedValue) error

+ func (c *Conn) Close() error

+ func (c *Conn) Prepare(query string) (driver.Stmt, error)

+ type DatabaseSpec struct

+ Id string

+ MaxRu int

+ Ru int

+ type DbInfo struct

+ Colls string

+ Etag string

+ Id string

+ Rid string

+ Self string

+ Ts int64

+ Users string

+ type DocInfo map[string]interface

+ func (d DocInfo) Attachments() string

+ func (d DocInfo) Etag() string

+ func (d DocInfo) GetAttrAsType(attrName string, typ reflect.Type) (interface{}, error)

+ func (d DocInfo) GetAttrAsTypeUnsafe(attrName string, typ reflect.Type) interface{}

+ func (d DocInfo) Id() string

+ func (d DocInfo) RemoveSystemAttrs() DocInfo

+ func (d DocInfo) Rid() string

+ func (d DocInfo) Self() string

+ func (d DocInfo) Ts() int64

+ func (d DocInfo) TsAsTime() time.Time

+ type DocReq struct

+ CollName string

+ ConsistencyLevel string

+ DbName string

+ DocId string

+ MatchEtag string

+ NotMatchEtag string

+ PartitionKeyValues []interface{}

+ SessionToken string

+ type DocumentSpec struct

+ CollName string

+ DbName string

+ DocumentData map[string]interface{}

+ IndexingDirective string

+ IsUpsert bool

+ PartitionKeyValues []interface{}

+ type Driver struct

+ func (d *Driver) Open(connStr string) (driver.Conn, error)

+ type ListDocsReq struct

+ CollName string

+ ConsistencyLevel string

+ ContinuationToken string

+ DbName string

+ MaxItemCount int

+ NotMatchEtag string

+ PartitionKeyRangeId string

+ SessionToken string

+ type QueryReq struct

+ CollName string

+ ConsistencyLevel string

+ ContinuationToken string

+ CrossPartitionEnabled bool

+ DbName string

+ MaxItemCount int

+ Params []interface{}

+ Query string

+ SessionToken string

+ type RespCreateColl struct

+ type RespCreateDb struct

+ type RespCreateDoc struct

+ type RespDeleteColl struct

+ type RespDeleteDb struct

+ type RespDeleteDoc struct

+ type RespGetColl struct

+ type RespGetDb struct

+ type RespGetDoc struct

+ type RespListColl struct

+ Collections []CollInfo

+ Count int64

+ type RespListDb struct

+ Count int64

+ Databases []DbInfo

+ type RespListDocs struct

+ ContinuationToken string

+ Count int64

+ Documents []DocInfo

+ Etag string

+ type RespQueryDocs struct

+ ContinuationToken string

+ Count int64

+ Documents []DocInfo

+ type RespReplaceColl struct

+ type RespReplaceDoc struct

+ type RestClient struct

+ func NewRestClient(httpClient *http.Client, connStr string) (*RestClient, error)

+ func (c *RestClient) CreateCollection(spec CollectionSpec) *RespCreateColl

+ func (c *RestClient) CreateDatabase(spec DatabaseSpec) *RespCreateDb

+ func (c *RestClient) CreateDocument(spec DocumentSpec) *RespCreateDoc

+ func (c *RestClient) DeleteCollection(dbName, collName string) *RespDeleteColl

+ func (c *RestClient) DeleteDatabase(dbName string) *RespDeleteDb

+ func (c *RestClient) DeleteDocument(r DocReq) *RespDeleteDoc

+ func (c *RestClient) GetCollection(dbName, collName string) *RespGetColl

+ func (c *RestClient) GetDatabase(dbName string) *RespGetDb

+ func (c *RestClient) GetDocument(r DocReq) *RespGetDoc

+ func (c *RestClient) ListCollections(dbName string) *RespListColl

+ func (c *RestClient) ListDatabases() *RespListDb

+ func (c *RestClient) ListDocuments(r ListDocsReq) *RespListDocs

+ func (c *RestClient) QueryDocuments(query QueryReq) *RespQueryDocs

+ func (c *RestClient) ReplaceCollection(spec CollectionSpec) *RespReplaceColl

+ func (c *RestClient) ReplaceDocument(matchEtag string, spec DocumentSpec) *RespReplaceDoc

+ type RestReponse struct

+ ApiErr error

+ CallErr error

+ RequestCharge float64

+ RespBody []byte

+ RespHeader map[string]string

+ SessionToken string

+ StatusCode int

+ func (r RestReponse) Error() error

+ type ResultCreateCollection struct

+ InsertId string

+ Successful bool

+ func (r *ResultCreateCollection) LastInsertId() (int64, error)

+ func (r *ResultCreateCollection) RowsAffected() (int64, error)

+ type ResultCreateDatabase struct

+ InsertId string

+ Successful bool

+ func (r *ResultCreateDatabase) LastInsertId() (int64, error)

+ func (r *ResultCreateDatabase) RowsAffected() (int64, error)

+ type ResultDelete struct

+ StatusCode int

+ Successful bool

+ func (r *ResultDelete) LastInsertId() (int64, error)

+ func (r *ResultDelete) RowsAffected() (int64, error)

+ type ResultInsert struct

+ InsertId string

+ Successful bool

+ func (r *ResultInsert) LastInsertId() (int64, error)

+ func (r *ResultInsert) RowsAffected() (int64, error)

+ type ResultSelect struct

+ func (r *ResultSelect) Close() error

+ func (r *ResultSelect) Columns() []string

+ func (r *ResultSelect) Next(dest []driver.Value) error

+ type ResultUpdate struct

+ Successful bool

+ func (r *ResultUpdate) LastInsertId() (int64, error)

+ func (r *ResultUpdate) RowsAffected() (int64, error)

+ type RowsListCollections struct

+ func (r *RowsListCollections) Close() error

+ func (r *RowsListCollections) Columns() []string

+ func (r *RowsListCollections) Next(dest []driver.Value) error

+ type RowsListDatabases struct

+ func (r *RowsListDatabases) Close() error

+ func (r *RowsListDatabases) Columns() []string

+ func (r *RowsListDatabases) Next(dest []driver.Value) error

+ type Stmt struct

+ func (s *Stmt) Close() error

+ func (s *Stmt) NumInput() int

+ type StmtCreateCollection struct

+ func (s *StmtCreateCollection) Exec(_ []driver.Value) (driver.Result, error)

+ func (s *StmtCreateCollection) Query(_ []driver.Value) (driver.Rows, error)

+ type StmtCreateDatabase struct

+ func (s *StmtCreateDatabase) Exec(_ []driver.Value) (driver.Result, error)

+ func (s *StmtCreateDatabase) Query(_ []driver.Value) (driver.Rows, error)

+ type StmtDelete struct

+ func (s *StmtDelete) Exec(args []driver.Value) (driver.Result, error)

+ func (s *StmtDelete) Query(args []driver.Value) (driver.Rows, error)

+ type StmtDropCollection struct

+ func (s *StmtDropCollection) Exec(_ []driver.Value) (driver.Result, error)

+ func (s *StmtDropCollection) Query(_ []driver.Value) (driver.Rows, error)

+ type StmtDropDatabase struct

+ func (s *StmtDropDatabase) Exec(_ []driver.Value) (driver.Result, error)

+ func (s *StmtDropDatabase) Query(_ []driver.Value) (driver.Rows, error)

+ type StmtInsert struct

+ func (s *StmtInsert) Exec(args []driver.Value) (driver.Result, error)

+ func (s *StmtInsert) Query(args []driver.Value) (driver.Rows, error)

+ type StmtListCollections struct

+ func (s *StmtListCollections) Exec(_ []driver.Value) (driver.Result, error)

+ func (s *StmtListCollections) Query(_ []driver.Value) (driver.Rows, error)

+ type StmtListDatabases struct

+ func (s *StmtListDatabases) Exec(_ []driver.Value) (driver.Result, error)

+ func (s *StmtListDatabases) Query(_ []driver.Value) (driver.Rows, error)

+ type StmtSelect struct

+ func (s *StmtSelect) Exec(args []driver.Value) (driver.Result, error)

+ func (s *StmtSelect) Query(args []driver.Value) (driver.Rows, error)

+ type StmtUpdate struct

+ func (s *StmtUpdate) Exec(args []driver.Value) (driver.Result, error)

+ func (s *StmtUpdate) Query(args []driver.Value) (driver.Rows, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL