gocosmos

package module

Go to main page

Versions in this module

v1

v1.1.1

Feb 9, 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 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 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)

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)

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)

type StmtUpdate

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

v1.1.0

Jan 29, 2024

Changes in this version

type Stmt

+ func (s *Stmt) String() string

type StmtCRUD

+ func (s *StmtCRUD) String() string

type StmtDelete

+ func (s *StmtDelete) String() string

type StmtInsert

+ func (s *StmtInsert) String() string

type StmtSelect

+ func (s *StmtSelect) String() string

type StmtUpdate

+ func (s *StmtUpdate) String() string

v1.0.2

Dec 20, 2023

v1.0.1

Dec 19, 2023

v1.0.0

Dec 19, 2023

Changes in this version

+ const DefaultApiVersion

+ const Version

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

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

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

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

+ 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")

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

+ type CollInfo struct

+ ConflictResolutionPolicy map[string]interface{}

+ Conflicts string

+ Docs string

+ Etag string

+ GeospatialConfig map[string]interface{}

+ Id string

+ IndexingPolicy map[string]interface{}

+ PartitionKey PkInfo

+ 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) BeginTx(_ context.Context, _ driver.TxOptions) (driver.Tx, error)

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

+ func (c *Conn) Close() error

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

+ func (c *Conn) PrepareContext(_ context.Context, 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) AsMap() 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 DocInfo

+ 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

+ IsIncrementalFeed bool

+ MaxItemCount int

+ NotMatchEtag string

+ PkRangeId string

+ SessionToken string

+ 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 PkInfo map[string]interface

+ func (pk PkInfo) Kind() string

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

+ func (pk PkInfo) Version() int

+ type PkrangeInfo struct

+ Etag string

+ Id string

+ MaxExclusive string

+ MinInclusive string

+ Rid string

+ Self string

+ Ts int64

+ 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 QueryReq struct

+ CollName string

+ ConsistencyLevel string

+ ContinuationToken string

+ CrossPartitionEnabled bool

+ DbName string

+ MaxItemCount int

+ Params []interface{}

+ PkRangeId string

+ PkValue string

+ 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 RespGetOffer struct

+ type RespGetPkranges struct

+ Count int

+ Pkranges []PkrangeInfo

+ type RespListColl struct

+ Collections []CollInfo

+ Count int

+ type RespListDb struct

+ Count int

+ Databases []DbInfo

+ type RespListDocs struct

+ ContinuationToken string

+ Count int

+ Documents []DocInfo

+ Etag string

+ type RespQueryDocs struct

+ ContinuationToken string

+ Count int

+ Documents QueriedDocs

+ QueryPlan *RespQueryPlan

+ RewrittenDocuments QueriedDocs

+ type RespQueryOffers struct

+ ContinuationToken string

+ Count int

+ Offers []OfferInfo

+ type RespQueryPlan struct

+ QueryExecutionInfoVersion int

+ QueryInfo struct{ ... }

+ func (qp *RespQueryPlan) IsDistinctQuery() bool

+ func (qp *RespQueryPlan) IsGroupByQuery() bool

+ func (qp *RespQueryPlan) IsOrderByQuery() bool

+ type RespReplaceColl struct

+ type RespReplaceDoc struct

+ type RespReplaceOffer 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) GetApiVersion() string

+ func (c *RestClient) GetAutoId() bool

+ 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) GetOfferForResource(rid string) *RespGetOffer

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

+ 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) QueryDocumentsCrossPartition(query QueryReq) *RespQueryDocs

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

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

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

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

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

+ 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 Stmt struct

+ func (s *Stmt) Close() error

+ func (s *Stmt) NumInput() int

+ 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)

+ type StmtCRUD struct

+ 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(_ []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(_ []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(_ []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(_ []driver.Value) (driver.Rows, error)

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