ravendb

README

This is information on how to use the library. For docs on working on the library itself see readme-dev.md.

This library requires go 1.11 or later.

API reference: https://godoc.org/github.com/ravendb/ravendb-go-client

This library is in beta state. All the basic functionality works and passes extensive test suite, but the API for more esoteric features might change.

If you encounter bugs, have suggestions or feature requests, please open an issue.

Documentation

To learn basics of RavenDB, read RavenDB Documentation or Dive into RavenDB.

Getting started

Full source code of those examples is in examples directory.

To run a a specific example, e.g. crudStore, you can run:

• .\scripts\run_example.ps1 crudStore : works on mac / linux if you have powershell installed
• go run examples\log.go examples\main.go crudStore : on mac / linux change paths to examples/log.go etc.

1. Import the package

import (
	ravendb "github.com/ravendb/ravendb-go-client"
)

1. Initialize document store (you should have one DocumentStore instance per application)

func getDocumentStore(databaseName string) (*ravendb.DocumentStore, error) {
	serverNodes := []string{"http://live-test.ravendb.net"}
	store := ravendb.NewDocumentStore(serverNodes, databaseName)
	if err := store.Initialize(); err != nil {
		return nil, err
	}
	return store, nil
}

To setup an document store with security, you'll need to provide the client certificate for authentication. Here is how to setup a document store with a certificate:

func getDocumentStore(databaseName string) (*ravendb.DocumentStore, error) {
	cerPath := "/path/to/certificate.crt"
	keyPath := "/path/to/certificate.key"
	serverNodes := []string{"https://a.tasty.ravendb.run", 
		"https://b.tasty.ravendb.run", "https://c.tasty.ravendb.run"}

	cer, err := tls.LoadX509KeyPair(cerPath, keyPath)
	if err != nil {
		return nil, err
	}
	store := ravendb.NewDocumentStore(serverNodes, databaseName)
	store.Certificate = &cer
	x509cert, err :=  x509.ParseCertificate(cer.Certificate[0])
	if err != nil {
		return nil, err
	}
	store.TrustStore = x509cert
	if err := store.Initialize(); err != nil {
		return nil, err
	}
	return store, nil
}

If you are using an encrypted certificate, see the sample code on how to translate that to tls.Certificate here: https://play.golang.org/p/8OYTuZtZIQ

1. Open a session and close it when done

session, err = store.OpenSession()
if err != nil {
	log.Fatalf("store.OpenSession() failed with %s", err)
}
// ... use session
session.Close()

1. Call SaveChanges() to persist changes in a session:

var e *northwind.Employee
err = session.Load(&e, "employees/7-A")
if err != nil {
    log.Fatalf("session.Load() failed with %s\n", err)
}

origName := e.FirstName
e.FirstName = e.FirstName + "Changed"
err = session.Store(e)
if err != nil {
    log.Fatalf("session.Store() failed with %s\n", err)
}

err = session.SaveChanges()
if err != nil {
    log.Fatalf("session.SaveChanges() failed with %s\n", err)
}

var e2 *northwind.Employee
err = session.Load(&e2, "employees/7-A")
if err != nil {
    log.Fatalf("session.Load() failed with %s\n", err)
}
fmt.Printf("Updated Employee.FirstName from '%s' to '%s'\n", origName, e2.FirstName)

See loadUpdateSave() in examples/main.go for full example.

CRUD example

Storing documents

product := &northwind.Product{
    Name:         "iPhone X",
    PricePerUnit: 999.99,
    Category:     "electronis",
    ReorderLevel: 15,
}
err = session.Store(product)
if err != nil {
    log.Fatalf("session.Store() failed with %s\n", err)
}

See crudStore() in examples/main.go for full example.

Loading documents

var e *northwind.Employee
err = session.Load(&e, "employees/7-A")
if err != nil {
    log.Fatalf("session.Load() failed with %s\n", err)
}
fmt.Printf("employee: %#v\n", e)

See crudLoad() in examples/main.go for full example.

Loading documents with includes

Some entities point to other entities via id. For example Employee has ReportsTo field which is an id of Employee that it reports to.

To improve performance by minimizing number of server requests, we can use includes functionality to load such linked entities.

// load employee with id "employees/7-A" and entity whose id is ReportsTo
var e *northwind.Employee
err = session.Include("ReportsTo").Load(&e, "employees/5-A")
if err != nil {
    log.Fatalf("session.Load() failed with %s\n", err)
}
if e.ReportsTo == "" {
    fmt.Printf("Employee with id employees/5-A doesn't report to anyone\n")
    return
}

numRequests := session.GetNumberOfRequests()
var reportsTo *northwind.Employee
err = session.Load(&reportsTo, e.ReportsTo)
if err != nil {
    log.Fatalf("session.Load() failed with %s\n", err)
}
if numRequests != session.GetNumberOfRequests() {
    fmt.Printf("Something's wrong, this shouldn't send a request to the server\n")
} else {
    fmt.Printf("Loading e.ReportsTo employee didn't require a new request to the server because we've loaded it in original requests thanks to using Include functionality\n")
}

See crudLoadWithInclude() in examples/main.go for full example.

Updating documents

// load entity from the server
var p *northwind.Product
err = session.Load(&p, productID)
if err != nil {
    log.Fatalf("session.Load() failed with %s\n", err)
}

// update price
origPrice = p.PricePerUnit
newPrice = origPrice + 10
p.PricePerUnit = newPrice
err = session.Store(p)
if err != nil {
    log.Fatalf("session.Store() failed with %s\n", err)
}

// persist changes on the server
err = session.SaveChanges()
if err != nil {
    log.Fatalf("session.SaveChanges() failed with %s\n", err)
}

See crudUpdate() in examples/main.go for full example.

Deleting documents

Delete using entity:

// ... store a product and remember its id in productID

var p *northwind.Product
err = session.Load(&p, productID)
if err != nil {
    log.Fatalf("session.Load() failed with %s\n", err)
}

err = session.Delete(p)
if err != nil {
    log.Fatalf("session.Delete() failed with %s\n", err)
}

err = session.SaveChanges()
if err != nil {
    log.Fatalf("session.SaveChanges() failed with %s\n", err)
}

See crudDeleteUsingEntity() in examples/main.go for full example.

Entity must be a value that we either stored in the database in the current session via Store() or loaded from database using Load(), LoadMulti(), query etc.

Delete using id:

// ... store a product and remember its id in productID

err = session.DeleteByID(productID, "")
if err != nil {
    log.Fatalf("session.Delete() failed with %s\n", err)
}

err = session.SaveChanges()
if err != nil {
    log.Fatalf("session.SaveChanges() failed with %s\n", err)
}

Second argument to DeleteByID is optional changeVector, for fine-grain concurrency control.

See crudDeleteUsingID() in examples/main.go for full example.

Querying documents

Selecting what to query

First you need to decide what to query.

RavenDB stores documents in collections. By default each type (struct) is stored in its own collection e.g. all Employee structs are stored in employees collection.

You can query by collection name:

q := session.QueryCollection("employees")

See queryCollectionByName() in examples/main.go for full example.

To get a collection name for a given type use ravendb.GetCollectionNameDefault(&MyStruct{}).

You can query a collection for a given type:

tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)

See queryCollectionByType() in examples/main.go for full example.

You can query an index:

q := session.QueryIndex("Orders/ByCompany")

See queryIndex() in examples/main.go for full example.

Limit what is returned

tp := reflect.TypeOf(&northwind.Product{})
q := session.QueryCollectionForType(tp)

q = q.WaitForNonStaleResults(0)
q = q.WhereEquals("Name", "iPhone X")
q = q.OrderBy("PricePerUnit")
q = q.Take(2) // limit to 2 results

See queryComplex() in examples/main.go for full example.

Obtain the results

You can get all matching results:

var products []*northwind.Product
err = q.GetResults(&products)

See queryComplex() in examples/main.go for full example.

You can get just first one:

var first *northwind.Employee
err = q.First(&first)

See queryFirst() in examples/main.go for full example.

Overview of DocumentQuery methods

SelectFields() - projections using a single field

// RQL equivalent: from employees select FirstName
q = q.SelectFields(reflect.TypeOf(""), "FirstName")

var names []string
err = q.GetResults(&names)

See querySelectSingleField() in examples/main.go for full example.

SelectFields() - projections using multiple fields

type employeeNameTitle struct {
	FirstName string
	Title     string
}

// RQL equivalent: from employees select FirstName, Title
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.SelectFields(reflect.TypeOf(&employeeNameTitle{}), "FirstName", "Title")

See querySelectFields() in examples/main.go for full example.

Distinct()

// RQL equivalent: from employees select distinct Title
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.SelectFields(reflect.TypeOf(""), "Title")
q = q.Distinct()

See queryDistinct() in examples/main.go for full example.

WhereEquals() / WhereNotEquals()

// RQL equivalent: from employees where Title = 'Sales Representative'
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.WhereEquals("Title", "Sales Representative")

See queryEquals() in examples/main.go for full example.

WhereIn

// RQL equivalent: from employees where Title in ['Sales Representative', 'Sales Manager']
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.WhereIn("Title", []interface{}{"Sales Representative", "Sales Manager"})

See queryIn() in examples/main.go for full example.

WhereStartsWith() / WhereEndsWith()

// RQL equivalent:
// from employees where startsWith('Ro')
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.WhereStartsWith("FirstName", "Ro")

See queryStartsWith() and queryEndsWith in examples/main.go for full example.

WhereBetween()

// RQL equivalent:
// from orders where Freight between 11 and 13
tp := reflect.TypeOf(&northwind.Order{})
q := session.QueryCollectionForType(tp)
q = q.WhereBetween("Freight", 11, 13)

See queryBetween() in examples/main.go for full example.

WhereGreaterThan() / WhereGreaterThanOrEqual() / WhereLessThan() / WhereLessThanOrEqual()

// RQL equivalent:
// from orders where Freight Freight > 11
tp := reflect.TypeOf(&northwind.Order{})
q := session.QueryCollectionForType(tp)
// can also be WhereGreaterThanOrEqual(), WhereLessThan(), WhereLessThanOrEqual()
q = q.WhereGreaterThan("Freight", 11)

See queryGreater() in examples/main.go for full example.

WhereExists()

Checks if the field exists.

// RQL equivalent:
// from employees where exists ("ReportsTo")
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.WhereExists("ReportsTo")

See queryExists() in examples/main.go for full example.

ContainsAny() / ContainsAll()

// RQL equivalent:
// from employees where FirstName in ("Anne", "Nancy")
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.ContainsAny("FirstName", []interface{}{"Anne", "Nancy"})

See queryContainsAny() in examples/main.go for full example.

Search()

Performs full-text search:

// RQL equivalent:
// from employees where search(FirstName, 'Anne Nancy')
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.Search("FirstName", "Anne Nancy")

See querySearch() in examples/main.go for full example.

OpenSubclause() / CloseSubclause()

// RQL equivalent:
// from employees where (FirstName = 'Steven') or (Title = 'Sales Representative' and LastName = 'Davolio')
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.WhereEquals("FirstName", "Steven")
q = q.OrElse()
q = q.OpenSubclause()
q = q.WhereEquals("Title", "Sales Representative")
q = q.WhereEquals("LastName", "Davolio")
q = q.CloseSubclause()

See querySubclause() in examples/main.go for full example.

Not()

// RQL equivalent:
// from employees where not FirstName = 'Steven'
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.Not()
q = q.WhereEquals("FirstName", "Steven")

See queryNot() in examples/main.go for full example.

AndAlso() / OrElse()

// RQL equivalent:
// from employees where FirstName = 'Steven' or FirstName  = 'Nancy'
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.WhereEquals("FirstName", "Steven")
// can also be AndElse()
q = q.OrElse()
q = q.WhereEquals("FirstName", "Nancy")

See queryOrElse() in examples/main.go for full example.

UsingDefaultOperator()

Sets default operator (which will be used if no AndAlso() / OrElse() was called. Just after query instantiation, OR is used as default operator. Default operator can be changed only adding any conditions.

OrderBy() / RandomOrdering()

// RQL equivalent:
// from employees order by FirstName
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
// can also be RandomOrdering()
q = q.OrderBy("FirstName")

See queryOrderBy() in examples/main.go for full example.

Take()

// RQL equivalent:
// from employees order by FirstName desc
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.OrderByDescending("FirstName")
q = q.Take(2)

See queryTake() in examples/main.go for full example.

Skip()

// RQL equivalent:
// from employees order by FirstName desc
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.OrderByDescending("FirstName")
q = q.Take(2)
q = q.Skip(1)

See querySkip() in examples/main.go for full example.

Getting query statistics

To obtain query statistics use Statistics() method.

var stats *ravendb.QueryStatistics
tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
q = q.WhereGreaterThan("FirstName", "Bernard")
q = q.OrderByDescending("FirstName")
q.Statistics(&stats)

Statistics:

Statistics:
{IsStale:           false,
 DurationInMs:      0,
 TotalResults:      7,
 SkippedResults:    0,
 Timestamp:         2019-02-13 02:57:31.5226409 +0000 UTC,
 IndexName:         "Auto/employees/ByLastNameAndReportsToAndSearch(FirstName)AndTitle",
 IndexTimestamp:    2019-02-13 02:57:31.5226409 +0000 UTC,
 LastQueryTime:     2019-02-13 03:50:25.7602429 +0000 UTC,
 TimingsInMs:       {},
 ResultEtag:        7591488513381790088,
 ResultSize:        0,
 ScoreExplanations: {}}

See queryStatistics() in examples/main.go for full example.

GetResults() / First() / Single() / Count()

GetResults() - returns all results

First() - first result

Single() - first result, returns error if there's more entries

Count() - returns the number of the results (not affected by take())

See queryFirst(), querySingle() and queryCount() in examples/main.go for full example.

Attachments

Store attachments

fileStream, err := os.Open(path)
if err != nil {
    log.Fatalf("os.Open() failed with '%s'\n", err)
}
defer fileStream.Close()

fmt.Printf("new employee id: %s\n", e.ID)
err = session.Advanced().Attachments().Store(e, "photo.png", fileStream, "image/png")

// could also be done using document id
// err = session.Advanced().Attachments().Store(e.ID, "photo.png", fileStream, "image/png")

if err != nil {
    log.Fatalf("session.Advanced().Attachments().Store() failed with '%s'\n", err)
}

err = session.SaveChanges()

See storeAttachments() in examples/main.go for full example.

Get attachments

attachment, err := session.Advanced().Attachments().Get(docID, "photo.png")
if err != nil {
    log.Fatalf("session.Advanced().Attachments().Get() failed with '%s'\n", err)
}
defer attachment.Close()
fmt.Print("Attachment details:\n")
pretty.Print(attachment.Details)
// read attachment data
// attachment.Data is io.Reader
var attachmentData bytes.Buffer
n, err := io.Copy(&attachmentData, attachment.Data)
if err != nil {
    log.Fatalf("io.Copy() failed with '%s'\n", err)
}
fmt.Printf("Attachment size: %d bytes\n", n)

Attachment details:

{AttachmentName: {Name:        "photo.png",
                  Hash:        "MvUEcrFHSVDts5ZQv2bQ3r9RwtynqnyJzIbNYzu1ZXk=",
                  ContentType: "image/png",
                  Size:        4579},
 ChangeVector:   "A:4905-dMAeI9ANZ06DOxCRLnSmNw",
 DocumentID:     "employees/44-A"}
Attachment size: 4579 bytes

See getAttachments() in examples/main.go for full example.

Check if attachment exists

name := "photo.png"
exists, err := session.Advanced().Attachments().Exists(docID, name)
if err != nil {
    log.Fatalf("session.Advanced().Attachments().Exists() failed with '%s'\n", err)
}

See checkAttachmentExists() in examples/main.go for full example.

Get attachment names

names, err := session.Advanced().Attachments().GetNames(doc)
if err != nil {
    log.Fatalf("session.Advanced().Attachments().GetNames() failed with '%s'\n", err)
}

Attachment names:

[{Name:        "photo.png",
  Hash:        "MvUEcrFHSVDts5ZQv2bQ3r9RwtynqnyJzIbNYzu1ZXk=",
  ContentType: "image/png",
  Size:        4579}]

See getAttachmentNames() in examples/main.go for full example.

Bulk insert

When storing multiple documents, use bulk insertion.

bulkInsert := store.BulkInsert("")

names := []string{"Anna", "Maria", "Miguel", "Emanuel", "Dayanara", "Aleida"}
for _, name := range names {
    e := &northwind.Employee{
        FirstName: name,
    }
    id, err := bulkInsert.Store(e, nil)
    if err != nil {
        log.Fatalf("bulkInsert.Store() failed with '%s'\n", err)
    }
}
// flush data and finish
err = bulkInsert.Close()

See bulkInsert() in examples/main.go for full example.

Observing changes in the database

Listen for database changes e.g. document changes.

changes := store.Changes("")

err = changes.EnsureConnectedNow()
if err != nil {
    log.Fatalf("changes.EnsureConnectedNow() failed with '%s'\n", err)
}

cb := func(change *ravendb.DocumentChange) {
    fmt.Print("change:\n")
    pretty.Print(change)
}
docChangesCancel, err := changes.ForAllDocuments(cb)
if err != nil {
    log.Fatalf("changes.ForAllDocuments() failed with '%s'\n", err)
}

defer docChangesCancel()

e := &northwind.Employee{
    FirstName: "Jon",
    LastName:  "Snow",
}
err = session.Store(e)
if err != nil {
    log.Fatalf("session.Store() failed with '%s'\n", err)
}

err = session.SaveChanges()
if err != nil {
    log.Fatalf("session.SaveChanges() failed with '%s'\n", err)
}
// cb should now be called notifying there's a new document

Example change:

{Type:           "Put",
 ID:             "Raven/Hilo/employees",
 CollectionName: "@hilo",
 ChangeVector:   "A:4892-bJERJNLunE+4xQ/yDEuk1Q"}

See changes() in examples/main.go for full example.

Streaming

Streaming allows interating over documents matching certain criteria.

It's useful when there's a large number of results as it limits memory use by reading documents in batches (as opposed to all at once).

Stream documents with ID prefix

Here we iterate over all documents in products collection:

args := &ravendb.StartsWithArgs{
    StartsWith: "products/",
}
iterator, err := session.Advanced().Stream(args)
if err != nil {
    log.Fatalf("session.Advanced().Stream() failed with '%s'\n", err)
}
for {
    var p *northwind.Product
    streamResult, err := iterator.Next(&p)
    if err != nil {
        // io.EOF means there are no more results
        if err == io.EOF {
            err = nil
        } else {
            log.Fatalf("iterator.Next() failed with '%s'\n", err)
        }
        break
    }
    // handle p
}

See streamWithIDPrefix() in examples/main.go for full example.

This returns:

streamResult:
{ID:           "products/1-A",
 ChangeVector: "A:96-bJERJNLunE+4xQ/yDEuk1Q",
 Metadata:     {},
 Document:     ... same as product but as map[string]interface{} ...

product:
{ID:              "products/1-A",
 Name:            "Chai",
 Supplier:        "suppliers/1-A",
 Category:        "categories/1-A",
 QuantityPerUnit: "10 boxes x 20 bags",
 PricePerUnit:    18,
 UnitsInStock:    1,
 UnistsOnOrder:   0,
 Discontinued:    false,
 ReorderLevel:    10}

Stream query results

tp := reflect.TypeOf(&northwind.Product{})
q := session.QueryCollectionForType(tp)
q = q.WhereGreaterThan("PricePerUnit", 15)
q = q.OrderByDescending("PricePerUnit")

iterator, err := session.Advanced().StreamQuery(q, nil)
if err != nil {
    log.Fatalf("session.Advanced().StreamQuery() failed with '%s'\n", err)
}
// rest of processing as above

See streamQueryResults() in examples/main.go for full example.

Revisions

Note: make sure to enable revisions in a given store using NewConfigureRevisionsOperation operation.

e := &northwind.Employee{
    FirstName: "Jon",
    LastName:  "Snow",
}
err = session.Store(e)
if err != nil {
    log.Fatalf("session.Store() failed with '%s'\n", err)
}
err = session.SaveChanges()
if err != nil {
    log.Fatalf("session.SaveChanges() failed with '%s'\n", err)
}

// modify document to create a new revision
e.FirstName = "Jhonny"
err = session.SaveChanges()
if err != nil {
    log.Fatalf("session.SaveChanges() failed with '%s'\n", err)
}

var revisions []*northwind.Employee
err = session.Advanced().Revisions().GetFor(&revisions, e.ID)

See revisions() in examples/main.go for full example.

Returns:

[{ID:          "employees/43-A",
  LastName:    "Snow",
  FirstName:   "Jhonny",
  Title:       "",
  Address:     nil,
  HiredAt:     {},
  Birthday:    {},
  HomePhone:   "",
  Extension:   "",
  ReportsTo:   "",
  Notes:       [],
  Territories: []},
 {ID:          "employees/43-A",
  LastName:    "Snow",
  FirstName:   "Jon",
  Title:       "",
  Address:     nil,
  HiredAt:     {},
  Birthday:    {},
  HomePhone:   "",
  Extension:   "",
  ReportsTo:   "",
  Notes:       [],
  Territories: []}]

Suggestions

Suggestions provides similarity queries. Here we're asking for FirstName values similar to Micael and the database suggests Michael.

index := ravendb.NewIndexCreationTask("EmployeeIndex")
index.Map = "from doc in docs.Employees select new { doc.FirstName }"
index.Suggestion("FirstName")

err = store.ExecuteIndex(index, "")
if err != nil {
    log.Fatalf("store.ExecuteIndex() failed with '%s'\n", err)
}

tp := reflect.TypeOf(&northwind.Employee{})
q := session.QueryCollectionForType(tp)
su := ravendb.NewSuggestionWithTerm("FirstName")
su.Term = "Micael"
suggestionQuery := q.SuggestUsing(su)
results, err := suggestionQuery.Execute()

See suggestions() in examples/main.go for full example.

Returns:

{FirstName: {Name:        "FirstName",
             Suggestions: ["michael"]}}

Advanced patching

To update documents more efficiently than sending the whole document, you can patch just a given field or atomically add/substract values of numeric fields.

err = session.Advanced().IncrementByID(product.ID, "PricePerUnit", 15)
if err != nil {
    log.Fatalf("session.Advanced().IncrementByID() failed with %s\n", err)
}

err = session.Advanced().Patch(product, "Category", "expensive products")
if err != nil {
    log.Fatalf("session.Advanced().PatchEntity() failed with %s\n", err)
}

err = session.SaveChanges()
if err != nil {
    log.Fatalf("session.SaveChanges() failed with %s\n", err)
}

See advancedPatching() in examples/main.go for full example.

Subscriptions

opts := ravendb.SubscriptionCreationOptions{
    Query: "from Products where PricePerUnit > 17 and PricePerUnit < 19",
}
subscriptionName, err := store.Subscriptions().Create(&opts, "")
if err != nil {
    log.Fatalf("store.Subscriptions().Create() failed with %s\n", err)
}
wopts := ravendb.NewSubscriptionWorkerOptions(subscriptionName)
worker, err := store.Subscriptions().GetSubscriptionWorker(tp, wopts, "")
if err != nil {
    log.Fatalf("store.Subscriptions().GetSubscriptionWorker() failed with %s\n", err)
}

results := make(chan *ravendb.SubscriptionBatch, 16)
cb := func(batch *ravendb.SubscriptionBatch) error {
    results <- batch
    return nil
}
err = worker.Run(cb)
if err != nil {
    log.Fatalf("worker.Run() failed with %s\n", err)
}

// wait for first batch result
select {
case batch := <-results:
    fmt.Print("Batch of subscription results:\n")
    pretty.Print(batch)
case <-time.After(time.Second * 5):
    fmt.Printf("Timed out waiting for first subscription batch\n")

}

_ = worker.Close()

See subscriptions() in examples/main.go for full example.

Documentation

Overview

Package ravendb implements a driver for RavenDB NOSQL document database.

For more documentation see https://github.com/ravendb/ravendb-go-client/blob/master/readme.md

Index

• Constants
• Variables
• func FieldsFor(s interface{}) []string
• func GetCollectionNameDefault(entityOrType interface{}) string
• func GetWrappedError(err error) error
• func IsPlural(word string) bool
• func IsSingular(word string) bool
• func NewHttpPost(uri string, data []byte) (*http.Request, error)
• func ParseTime(s string) (time.Time, error)
• func Pluralize(word string, count int, inclusive bool) string
• func RoundToServerTime(t time.Time) time.Time
• func ToPlural(word string) string
• func ToSingular(word string) string
• type AdvancedSessionExtensionBase
  • func (e *AdvancedSessionExtensionBase) Defer(commands ...ICommandData)
• type AdvancedSessionOperations
  • func (o *AdvancedSessionOperations) AddAfterSaveChangesListener(handler func(*AfterSaveChangesEventArgs)) int
  • func (o *AdvancedSessionOperations) AddBeforeDeleteListener(handler func(*BeforeDeleteEventArgs)) int
  • func (o *AdvancedSessionOperations) AddBeforeQueryListener(handler func(*BeforeQueryEventArgs)) int
  • func (o *AdvancedSessionOperations) AddBeforeStoreListener(handler func(*BeforeStoreEventArgs)) int
  • func (o *AdvancedSessionOperations) Attachments() *AttachmentsSessionOperations
  • func (o *AdvancedSessionOperations) Clear()
  • func (o *AdvancedSessionOperations) Defer(commands ...ICommandData)
  • func (o *AdvancedSessionOperations) Eagerly() *EagerSessionOperations
  • func (o *AdvancedSessionOperations) Evict(entity interface{}) error
  • func (o *AdvancedSessionOperations) Exists(id string) (bool, error)
  • func (o *AdvancedSessionOperations) GetChangeVectorFor(instance interface{}) (*string, error)
  • func (o *AdvancedSessionOperations) GetCurrentSessionNode() (*ServerNode, error)
  • func (o *AdvancedSessionOperations) GetDocumentID(instance interface{}) string
  • func (o *AdvancedSessionOperations) GetDocumentStore() *DocumentStore
  • func (o *AdvancedSessionOperations) GetLastModifiedFor(instance interface{}) (*time.Time, error)
  • func (o *AdvancedSessionOperations) GetMaxNumberOfRequestsPerSession() int
  • func (o *AdvancedSessionOperations) GetMetadataFor(instance interface{}) (*MetadataAsDictionary, error)
  • func (o *AdvancedSessionOperations) GetNumberOfRequests() int
  • func (o *AdvancedSessionOperations) GetRequestExecutor() *RequestExecutor
  • func (o *AdvancedSessionOperations) HasChanged(entity interface{}) (bool, error)
  • func (o *AdvancedSessionOperations) HasChanges() bool
  • func (o *AdvancedSessionOperations) IgnoreChangesFor(entity interface{}) error
  • func (o *AdvancedSessionOperations) Increment(entity interface{}, path string, valueToAdd interface{}) error
  • func (o *AdvancedSessionOperations) IncrementByID(id string, path string, valueToAdd interface{}) error
  • func (o *AdvancedSessionOperations) IsLoaded(id string) bool
  • func (o *AdvancedSessionOperations) Lazily() *LazySessionOperations
  • func (o *AdvancedSessionOperations) LoadIntoStream(ids []string, output io.Writer) error
  • func (o *AdvancedSessionOperations) LoadStartingWith(results interface{}, args *StartsWithArgs) error
  • func (o *AdvancedSessionOperations) LoadStartingWithIntoStream(output io.Writer, args *StartsWithArgs) error
  • func (o *AdvancedSessionOperations) Patch(entity interface{}, path string, value interface{}) error
  • func (o *AdvancedSessionOperations) PatchArray(entity interface{}, pathToArray string, arrayAdder func(*JavaScriptArray)) error
  • func (o *AdvancedSessionOperations) PatchArrayByID(id string, pathToArray string, arrayAdder func(*JavaScriptArray)) error
  • func (o *AdvancedSessionOperations) PatchByID(id string, path string, value interface{}) error
  • func (o *AdvancedSessionOperations) Query(opts *DocumentQueryOptions) *DocumentQuery
  • func (o *AdvancedSessionOperations) QueryCollection(collectionName string) *DocumentQuery
  • func (o *AdvancedSessionOperations) QueryCollectionForType(typ reflect.Type) *DocumentQuery
  • func (o *AdvancedSessionOperations) QueryIndex(indexName string) *DocumentQuery
  • func (o *AdvancedSessionOperations) RawQuery(rawQuery string) *RawDocumentQuery
  • func (o *AdvancedSessionOperations) Refresh(entity interface{}) error
  • func (o *AdvancedSessionOperations) RemoveAfterSaveChangesListener(handlerID int)
  • func (o *AdvancedSessionOperations) RemoveBeforeDeleteListener(handlerID int)
  • func (o *AdvancedSessionOperations) RemoveBeforeQueryListener(handlerID int)
  • func (o *AdvancedSessionOperations) RemoveBeforeStoreListener(handlerID int)
  • func (o *AdvancedSessionOperations) Revisions() *RevisionsSessionOperations
  • func (o *AdvancedSessionOperations) SetMaxNumberOfRequestsPerSession(n int)
  • func (o *AdvancedSessionOperations) Stream(args *StartsWithArgs) (*StreamIterator, error)
  • func (o *AdvancedSessionOperations) StreamQuery(query *DocumentQuery, streamQueryStats *StreamQueryStatistics) (*StreamIterator, error)
  • func (o *AdvancedSessionOperations) StreamQueryInto(query *DocumentQuery, output io.Writer) error
  • func (o *AdvancedSessionOperations) StreamRawQuery(query *RawDocumentQuery, streamQueryStats *StreamQueryStatistics) (*StreamIterator, error)
  • func (o *AdvancedSessionOperations) StreamRawQueryInto(query *RawDocumentQuery, output io.Writer) error
  • func (o *AdvancedSessionOperations) WaitForIndexesAfterSaveChanges(options func(*IndexesWaitOptsBuilder))
  • func (o *AdvancedSessionOperations) WaitForReplicationAfterSaveChanges(options func(*ReplicationWaitOptsBuilder))
  • func (o *AdvancedSessionOperations) WhatChanged() (map[string][]*DocumentsChanges, error)
• type AfterSaveChangesEventArgs
  • func (a *AfterSaveChangesEventArgs) GetDocumentMetadata() *MetadataAsDictionary
• type AggregationDocumentQuery
  • func (q *AggregationDocumentQuery) AndAggregateByFacet(facet FacetBase) *AggregationDocumentQuery
  • func (q *AggregationDocumentQuery) GetIndexQuery() (*IndexQuery, error)
• type AggressiveCacheOptions
• type AllTopologyNodesDownError
  • func (e *AllTopologyNodesDownError) Error() string
  • func (e *AllTopologyNodesDownError) WrappedError() error
• type AttachmentDetails
• type AttachmentName
• type AttachmentResult
  • func (r *AttachmentResult) Close() error
• type AttachmentType
• type AttachmentsSessionOperations
• type AuthorizationError
  • func (e *AuthorizationError) Error() string
  • func (e *AuthorizationError) WrappedError() error
• type BadRequestError
  • func (e *BadRequestError) Error() string
  • func (e *BadRequestError) WrappedError() error
• type BadResponseError
  • func (e *BadResponseError) Error() string
  • func (e *BadResponseError) WrappedError() error
• type BatchCommand
  • func (c *BatchCommand) Close() error
  • func (c *BatchCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *BatchCommand) SetResponse(response []byte, fromCache bool) error
• type BatchOperation
• type BatchOptions
  • func NewBatchOptions() *BatchOptions
• type BeforeDeleteEventArgs
  • func (a *BeforeDeleteEventArgs) GetDocumentMetadata() *MetadataAsDictionary
• type BeforeQueryEventArgs
• type BeforeStoreEventArgs
  • func (a *BeforeStoreEventArgs) GetDocumentMetadata() *MetadataAsDictionary
• type BulkInsertAbortedError
  • func (e *BulkInsertAbortedError) Error() string
  • func (e *BulkInsertAbortedError) WrappedError() error
• type BulkInsertCommand
  • func NewBulkInsertCommand(id int64, stream io.Reader, useCompression bool) *BulkInsertCommand
  • func (c *BulkInsertCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *BulkInsertCommand) Send(client *http.Client, req *http.Request) (*http.Response, error)
  • func (c *BulkInsertCommand) SetResponse(response []byte, fromCache bool) error
• type BulkInsertOperation
  • func NewBulkInsertOperation(database string, store *DocumentStore) *BulkInsertOperation
  • func (o *BulkInsertOperation) Abort() error
  • func (o *BulkInsertOperation) Close() error
  • func (o *BulkInsertOperation) GetID(entity interface{}) (string, error)
  • func (o *BulkInsertOperation) Store(entity interface{}, metadata *MetadataAsDictionary) (string, error)
  • func (o *BulkInsertOperation) StoreWithID(entity interface{}, id string, metadata *MetadataAsDictionary) error
  • func (o *BulkInsertOperation) WaitForID() error
• type BulkInsertProtocolViolationError
  • func (e *BulkInsertProtocolViolationError) Error() string
  • func (e *BulkInsertProtocolViolationError) WrappedError() error
• type CancelFunc
• type CancellationError
  • func (e *CancellationError) Error() string
• type CertificateNameMismatchError
  • func (e *CertificateNameMismatchError) Error() string
  • func (e *CertificateNameMismatchError) WrappedError() error
• type ChangeProcessingError
  • func (e *ChangeProcessingError) Error() string
  • func (e *ChangeProcessingError) WrappedError() error
• type ChangeType
• type CircleCriteria
  • func NewCircleCriteria(radius float64, latitude float64, longitude float64, radiusUnits SpatialUnits, ...) *CircleCriteria
  • func (c *CircleCriteria) GetShapeToken(addQueryParameter func(interface{}) string) *shapeToken
  • func (c *CircleCriteria) ToQueryToken(fieldName string, addQueryParameter func(interface{}) string) queryToken
• type ClientConfiguration
• type ClientVersionMismatchError
  • func (e *ClientVersionMismatchError) Error() string
  • func (e *ClientVersionMismatchError) WrappedError() error
• type ClusterRequestExecutor
• type ClusterTopology
• type CmpXchg
  • func CmpXchgValue(key string) *CmpXchg
• type CollectionStatistics
• type CollectionStats
  • func NewCollectionStats() *CollectionStats
• type CommandData
• type CommandExecutionError
  • func (e *CommandExecutionError) Error() string
  • func (e *CommandExecutionError) WrappedError() error
• type CommandType
• type CompactDatabaseCommand
  • func NewCompactDatabaseCommand(conventions *DocumentConventions, compactSettings *CompactSettings) (*CompactDatabaseCommand, error)
  • func (c *CompactDatabaseCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *CompactDatabaseCommand) SetResponse(response []byte, fromCache bool) error
• type CompactDatabaseOperation
  • func NewCompactDatabaseOperation(compactSettings *CompactSettings) *CompactDatabaseOperation
  • func (o *CompactDatabaseOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type CompactSettings
• type CompareExchangeResult
• type CompareExchangeValue
  • func NewCompareExchangeValue(key string, index int64, value interface{}) *CompareExchangeValue
• type CompilationError
  • func (e *CompilationError) Error() string
  • func (e *CompilationError) WrappedError() error
• type ConcurrencyCheckMode
• type ConcurrencyError
  • func (e *ConcurrencyError) Error() string
  • func (e *ConcurrencyError) WrappedError() error
• type ConfigureRevisionsCommand
  • func NewConfigureRevisionsCommand(configuration *RevisionsConfiguration) *ConfigureRevisionsCommand
  • func (c *ConfigureRevisionsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *ConfigureRevisionsCommand) SetResponse(response []byte, fromCache bool) error
• type ConfigureRevisionsOperation
  • func NewConfigureRevisionsOperation(configuration *RevisionsConfiguration) *ConfigureRevisionsOperation
  • func (o *ConfigureRevisionsOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type ConfigureRevisionsOperationResult
• type Conflict
• type ConflictError
  • func (e *ConflictError) Error() string
  • func (e *ConflictError) WrappedError() error
• type ConflictSolver
• type ConnectionString
• type ConnectionStringType
• type CreateDatabaseCommand
  • func NewCreateDatabaseCommand(conventions *DocumentConventions, databaseRecord *DatabaseRecord, ...) (*CreateDatabaseCommand, error)
  • func (c *CreateDatabaseCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *CreateDatabaseCommand) SetResponse(response []byte, fromCache bool) error
• type CreateDatabaseOperation
  • func NewCreateDatabaseOperation(databaseRecord *DatabaseRecord, replicationFactor int) *CreateDatabaseOperation
  • func (o *CreateDatabaseOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type CreateSampleDataCommand
  • func NewCreateSampleDataCommand(conventions *DocumentConventions) *CreateSampleDataCommand
  • func (c *CreateSampleDataCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type CreateSampleDataOperation
  • func NewCreateSampleDataOperation() *CreateSampleDataOperation
  • func (o *CreateSampleDataOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type CreateSubscriptionCommand
  • func (c *CreateSubscriptionCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *CreateSubscriptionCommand) SetResponse(response []byte, fromCache bool) error
• type CreateSubscriptionResult
• type CurrentIndexAndNode
  • func NewCurrentIndexAndNode(currentIndex int, currentNode *ServerNode) *CurrentIndexAndNode
• type DatabaseChanges
  • func (c *DatabaseChanges) AddConnectionStatusChanged(handler func()) int
  • func (c *DatabaseChanges) AddOnError(handler func(error)) int
  • func (c *DatabaseChanges) Close()
  • func (c *DatabaseChanges) EnsureConnectedNow() error
  • func (c *DatabaseChanges) ForAllDocuments(cb func(*DocumentChange)) (CancelFunc, error)
  • func (c *DatabaseChanges) ForAllIndexes(cb func(*IndexChange)) (CancelFunc, error)
  • func (c *DatabaseChanges) ForAllOperations(cb func(change *OperationStatusChange)) (CancelFunc, error)
  • func (c *DatabaseChanges) ForDocument(docID string, cb func(*DocumentChange)) (CancelFunc, error)
  • func (c *DatabaseChanges) ForDocumentsInCollection(collectionName string, cb func(*DocumentChange)) (CancelFunc, error)
  • func (c *DatabaseChanges) ForDocumentsInCollectionOfType(clazz reflect.Type, cb func(*DocumentChange)) (CancelFunc, error)
  • func (c *DatabaseChanges) ForDocumentsStartingWith(docIDPrefix string, cb func(*DocumentChange)) (CancelFunc, error)
  • func (c *DatabaseChanges) ForIndex(indexName string, cb func(*IndexChange)) (CancelFunc, error)
  • func (c *DatabaseChanges) ForOperationID(operationID int64, cb func(*OperationStatusChange)) (CancelFunc, error)
  • func (c *DatabaseChanges) RemoveConnectionStatusChanged(handlerID int)
  • func (c *DatabaseChanges) RemoveOnError(handlerID int)
• type DatabaseConcurrentLoadTimeoutError
  • func (e *DatabaseConcurrentLoadTimeoutError) Error() string
  • func (e *DatabaseConcurrentLoadTimeoutError) WrappedError() error
• type DatabaseDisabledError
  • func (e *DatabaseDisabledError) Error() string
  • func (e *DatabaseDisabledError) WrappedError() error
• type DatabaseDoesNotExistError
  • func (e *DatabaseDoesNotExistError) Error() string
  • func (e *DatabaseDoesNotExistError) WrappedError() error
• type DatabaseLoadFailureError
  • func (e *DatabaseLoadFailureError) Error() string
  • func (e *DatabaseLoadFailureError) WrappedError() error
• type DatabaseLoadTimeoutError
  • func (e *DatabaseLoadTimeoutError) Error() string
  • func (e *DatabaseLoadTimeoutError) WrappedError() error
• type DatabaseNotRelevantError
  • func (e *DatabaseNotRelevantError) Error() string
  • func (e *DatabaseNotRelevantError) WrappedError() error
• type DatabasePromotionStatus
• type DatabasePutResult
• type DatabaseRecord
  • func NewDatabaseRecord() *DatabaseRecord
• type DatabaseRecordWithEtag
• type DatabaseStatistics
  • func (s *DatabaseStatistics) GetLastIndexingTime() *time.Time
• type DatabaseTopology
• type DeleteAttachmentCommand
  • func NewDeleteAttachmentCommand(documentID string, name string, changeVector *string) (*DeleteAttachmentCommand, error)
  • func (c *DeleteAttachmentCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type DeleteAttachmentCommandData
  • func NewDeleteAttachmentCommandData(documentID string, name string, changeVector *string) (*DeleteAttachmentCommandData, error)
• type DeleteAttachmentOperation
  • func NewDeleteAttachmentOperation(documentID string, name string, changeVector *string) *DeleteAttachmentOperation
  • func (o *DeleteAttachmentOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)
• type DeleteByIndexCommand
  • func NewDeleteByIndexCommand(conventions *DocumentConventions, queryToDelete *IndexQuery, ...) (*DeleteByIndexCommand, error)
  • func (c *DeleteByIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *DeleteByIndexCommand) SetResponse(response []byte, fromCache bool) error
• type DeleteByQueryOperation
  • func NewDeleteByQueryOperation(queryToDelete *IndexQuery, options *QueryOperationOptions) (*DeleteByQueryOperation, error)
  • func (o *DeleteByQueryOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)
• type DeleteCommandData
• type DeleteCompareExchangeValueOperation
  • func NewDeleteCompareExchangeValueOperation(clazz reflect.Type, key string, index int64) (*DeleteCompareExchangeValueOperation, error)
  • func (o *DeleteCompareExchangeValueOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)
• type DeleteDatabaseCommand
  • func NewDeleteDatabaseCommand(conventions *DocumentConventions, parameters *DeleteDatabaseParameters) (*DeleteDatabaseCommand, error)
  • func (c *DeleteDatabaseCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *DeleteDatabaseCommand) SetResponse(response []byte, fromCache bool) error
• type DeleteDatabaseParameters
• type DeleteDatabaseResult
• type DeleteDatabasesOperation
  • func NewDeleteDatabasesOperation(databaseName string, hardDelete bool) *DeleteDatabasesOperation
  • func NewDeleteDatabasesOperation2(databaseName string, hardDelete bool, fromNode string, ...) *DeleteDatabasesOperation
  • func NewDeleteDatabasesOperationWithParameters(parameters *DeleteDatabaseParameters) *DeleteDatabasesOperation
  • func (o *DeleteDatabasesOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type DeleteDocumentCommand
  • func NewDeleteDocumentCommand(id string, changeVector *string) *DeleteDocumentCommand
  • func (c *DeleteDocumentCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type DeleteIndexCommand
  • func NewDeleteIndexCommand(indexName string) (*DeleteIndexCommand, error)
  • func (c *DeleteIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type DeleteIndexOperation
  • func NewDeleteIndexOperation(indexName string) *DeleteIndexOperation
  • func (o *DeleteIndexOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type DeleteSubscriptionCommand
  • func (c *DeleteSubscriptionCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type DisableIndexCommand
  • func NewDisableIndexCommand(indexName string) (*DisableIndexCommand, error)
  • func (c *DisableIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type DisableIndexOperation
  • func NewDisableIndexOperation(indexName string) (*DisableIndexOperation, error)
  • func (o *DisableIndexOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type DocumentChange
  • func (c *DocumentChange) String() string
• type DocumentChangeTypes
• type DocumentConflictError
  • func (e *DocumentConflictError) Error() string
  • func (e *DocumentConflictError) WrappedError() error
• type DocumentConventions
  • func NewDocumentConventions() *DocumentConventions
  • func (c *DocumentConventions) Clone() *DocumentConventions
  • func (c *DocumentConventions) Freeze()
  • func (c *DocumentConventions) GenerateDocumentID(databaseName string, entity interface{}) (string, error)
  • func (c *DocumentConventions) GetDocumentIDGenerator() DocumentIDGeneratorFunc
  • func (c *DocumentConventions) GetIdentityPartsSeparator() string
  • func (c *DocumentConventions) GetIdentityProperty(clazz reflect.Type) string
  • func (c *DocumentConventions) GetTransformClassCollectionNameToDocumentIdPrefix() func(string) string
  • func (c *DocumentConventions) IsDisableTopologyUpdates() bool
  • func (c *DocumentConventions) SetDisableTopologyUpdates(disable bool)
  • func (c *DocumentConventions) SetDocumentIDGenerator(documentIDGenerator DocumentIDGeneratorFunc)
  • func (c *DocumentConventions) TryConvertValueForQuery(fieldName string, value interface{}, forRange bool, stringValue *string) bool
  • func (c *DocumentConventions) UpdateFrom(configuration *ClientConfiguration)
• type DocumentDoesNotExistError
  • func (e *DocumentDoesNotExistError) Error() string
  • func (e *DocumentDoesNotExistError) WrappedError() error
• type DocumentIDGeneratorFunc
• type DocumentQuery
  • func (q *DocumentQuery) AddBeforeQueryExecutedListener(action func(*IndexQuery)) int
  • func (q *DocumentQuery) AddOrder(fieldName string, descending bool) *DocumentQuery
  • func (q *DocumentQuery) AddOrderWithOrdering(fieldName string, descending bool, ordering OrderingType) *DocumentQuery
  • func (q *DocumentQuery) AddParameter(name string, value interface{}) *DocumentQuery
  • func (q *DocumentQuery) AggregateByFacet(facet FacetBase) *AggregationDocumentQuery
  • func (q *DocumentQuery) AggregateByFacets(facets ...*Facet) *AggregationDocumentQuery
  • func (q *DocumentQuery) AggregateUsing(facetSetupDocumentID string) *AggregationDocumentQuery
  • func (q *DocumentQuery) AndAlso() *DocumentQuery
  • func (q DocumentQuery) Any() (bool, error)
  • func (q *DocumentQuery) Boost(boost float64) *DocumentQuery
  • func (q *DocumentQuery) CloseSubclause() *DocumentQuery
  • func (q *DocumentQuery) ContainsAll(fieldName string, values []interface{}) *DocumentQuery
  • func (q *DocumentQuery) ContainsAny(fieldName string, values []interface{}) *DocumentQuery
  • func (q DocumentQuery) Count() (int, error)
  • func (q DocumentQuery) CountLazily() (*Lazy, error)
  • func (q *DocumentQuery) Distinct() *DocumentQuery
  • func (q DocumentQuery) Err() error
  • func (q *DocumentQuery) Exact() *DocumentQuery
  • func (q DocumentQuery) First(result interface{}) error
  • func (q *DocumentQuery) Fuzzy(fuzzy float64) *DocumentQuery
  • func (q DocumentQuery) GetIndexQuery() (*IndexQuery, error)
  • func (q DocumentQuery) GetResults(results interface{}) error
  • func (q *DocumentQuery) GroupBy(fieldName string, fieldNames ...string) *GroupByDocumentQuery
  • func (q *DocumentQuery) GroupByFieldWithMethod(field *GroupBy, fields ...*GroupBy) *GroupByDocumentQuery
  • func (q *DocumentQuery) Include(path string) *DocumentQuery
  • func (q *DocumentQuery) Intersect() *DocumentQuery
  • func (q DocumentQuery) Lazily() (*Lazy, error)
  • func (q *DocumentQuery) MoreLikeThis(moreLikeThis MoreLikeThisBase) *DocumentQuery
  • func (q *DocumentQuery) MoreLikeThisWithBuilder(builder func(IMoreLikeThisBuilderForDocumentQuery)) *DocumentQuery
  • func (q *DocumentQuery) NoCaching() *DocumentQuery
  • func (q *DocumentQuery) NoTracking() *DocumentQuery
  • func (q *DocumentQuery) Not() *DocumentQuery
  • func (q *DocumentQuery) OpenSubclause() *DocumentQuery
  • func (q *DocumentQuery) OrElse() *DocumentQuery
  • func (q *DocumentQuery) OrderBy(field string) *DocumentQuery
  • func (q *DocumentQuery) OrderByDescending(field string) *DocumentQuery
  • func (q *DocumentQuery) OrderByDescendingWithOrdering(field string, ordering OrderingType) *DocumentQuery
  • func (q *DocumentQuery) OrderByDistanceDescendingLatLong(fieldName string, latitude float64, longitude float64) *DocumentQuery
  • func (q *DocumentQuery) OrderByDistanceDescendingLatLongDynamic(field DynamicSpatialField, latitude float64, longitude float64) *DocumentQuery
  • func (q *DocumentQuery) OrderByDistanceDescendingWkt(fieldName string, shapeWkt string) *DocumentQuery
  • func (q *DocumentQuery) OrderByDistanceDescendingWktDynamic(field DynamicSpatialField, shapeWkt string) *DocumentQuery
  • func (q *DocumentQuery) OrderByDistanceLatLong(fieldName string, latitude float64, longitude float64) *DocumentQuery
  • func (q *DocumentQuery) OrderByDistanceLatLongDynamic(field DynamicSpatialField, latitude float64, longitude float64) *DocumentQuery
  • func (q *DocumentQuery) OrderByDistanceWkt(fieldName string, shapeWkt string) *DocumentQuery
  • func (q *DocumentQuery) OrderByDistanceWktDynamic(field DynamicSpatialField, shapeWkt string) *DocumentQuery
  • func (q *DocumentQuery) OrderByScore() *DocumentQuery
  • func (q *DocumentQuery) OrderByScoreDescending() *DocumentQuery
  • func (q *DocumentQuery) OrderByWithOrdering(field string, ordering OrderingType) *DocumentQuery
  • func (q *DocumentQuery) Proximity(proximity int) *DocumentQuery
  • func (q *DocumentQuery) RandomOrdering() *DocumentQuery
  • func (q *DocumentQuery) RandomOrderingWithSeed(seed string) *DocumentQuery
  • func (q *DocumentQuery) RelatesToShape(fieldName string, shapeWkt string, relation SpatialRelation) *DocumentQuery
  • func (q *DocumentQuery) RelatesToShapeWithError(fieldName string, shapeWkt string, relation SpatialRelation, ...) *DocumentQuery
  • func (q *DocumentQuery) RemoveBeforeQueryExecutedListener(idx int) *DocumentQuery
  • func (q *DocumentQuery) Search(fieldName string, searchTerms string) *DocumentQuery
  • func (q *DocumentQuery) SearchWithOperator(fieldName string, searchTerms string, operator SearchOperator) *DocumentQuery
  • func (q *DocumentQuery) SelectFields(projectionType reflect.Type, fieldsIn ...string) *DocumentQuery
  • func (q *DocumentQuery) SelectFieldsWithQueryData(projectionType reflect.Type, queryData *QueryData) *DocumentQuery
  • func (q DocumentQuery) Single(result interface{}) error
  • func (q *DocumentQuery) Skip(count int) *DocumentQuery
  • func (q *DocumentQuery) Spatial2(field DynamicSpatialField, ...) *DocumentQuery
  • func (q *DocumentQuery) Spatial3(fieldName string, clause func(*SpatialCriteriaFactory) SpatialCriteria) *DocumentQuery
  • func (q *DocumentQuery) Statistics(stats **QueryStatistics) *DocumentQuery
  • func (q *DocumentQuery) SuggestUsing(suggestion SuggestionBase) *SuggestionDocumentQuery
  • func (q *DocumentQuery) Take(count int) *DocumentQuery
  • func (q *DocumentQuery) UsingDefaultOperator(queryOperator QueryOperator) *DocumentQuery
  • func (q *DocumentQuery) WaitForNonStaleResults(waitTimeout time.Duration) *DocumentQuery
  • func (q *DocumentQuery) Where(fieldName string, op string, value interface{}) *DocumentQuery
  • func (q *DocumentQuery) WhereBetween(fieldName string, start interface{}, end interface{}) *DocumentQuery
  • func (q *DocumentQuery) WhereEndsWith(fieldName string, value interface{}) *DocumentQuery
  • func (q *DocumentQuery) WhereEquals(fieldName string, value interface{}) *DocumentQuery
  • func (q *DocumentQuery) WhereEqualsWithMethodCall(fieldName string, method MethodCall) *DocumentQuery
  • func (q *DocumentQuery) WhereEqualsWithParams(whereParams *whereParams) *DocumentQuery
  • func (q *DocumentQuery) WhereExists(fieldName string) *DocumentQuery
  • func (q *DocumentQuery) WhereGreaterThan(fieldName string, value interface{}) *DocumentQuery
  • func (q *DocumentQuery) WhereGreaterThanOrEqual(fieldName string, value interface{}) *DocumentQuery
  • func (q *DocumentQuery) WhereIn(fieldName string, values []interface{}) *DocumentQuery
  • func (q *DocumentQuery) WhereLessThan(fieldName string, value interface{}) *DocumentQuery
  • func (q *DocumentQuery) WhereLessThanOrEqual(fieldName string, value interface{}) *DocumentQuery
  • func (q *DocumentQuery) WhereLucene(fieldName string, whereClause string) *DocumentQuery
  • func (q *DocumentQuery) WhereNotEquals(fieldName string, value interface{}) *DocumentQuery
  • func (q *DocumentQuery) WhereNotEqualsWithMethod(fieldName string, method MethodCall) *DocumentQuery
  • func (q *DocumentQuery) WhereNotEqualsWithParams(whereParams *whereParams) *DocumentQuery
  • func (q *DocumentQuery) WhereRegex(fieldName string, pattern string) *DocumentQuery
  • func (q *DocumentQuery) WhereStartsWith(fieldName string, value interface{}) *DocumentQuery
  • func (q *DocumentQuery) WithinRadiusOf(fieldName string, radius float64, latitude float64, longitude float64) *DocumentQuery
  • func (q *DocumentQuery) WithinRadiusOfWithUnits(fieldName string, radius float64, latitude float64, longitude float64, ...) *DocumentQuery
  • func (q *DocumentQuery) WithinRadiusOfWithUnitsAndError(fieldName string, radius float64, latitude float64, longitude float64, ...) *DocumentQuery
• type DocumentQueryCustomization
  • func (d *DocumentQueryCustomization) AddAfterQueryExecutedListener(action func(*QueryResult)) int
  • func (d *DocumentQueryCustomization) AddAfterStreamExecutedCallback(action func(map[string]interface{})) int
  • func (d *DocumentQueryCustomization) AddBeforeQueryExecutedListener(action func(*IndexQuery)) int
  • func (d *DocumentQueryCustomization) GetQueryOperation() *queryOperation
  • func (d *DocumentQueryCustomization) NoCaching()
  • func (d *DocumentQueryCustomization) NoTracking()
  • func (d *DocumentQueryCustomization) RandomOrdering()
  • func (d *DocumentQueryCustomization) RandomOrderingWithSeed(seed string)
  • func (d *DocumentQueryCustomization) RemoveAfterQueryExecutedListener(idx int)
  • func (d *DocumentQueryCustomization) RemoveAfterStreamExecutedCallback(idx int)
  • func (d *DocumentQueryCustomization) RemoveBeforeQueryExecutedListener(idx int)
  • func (d *DocumentQueryCustomization) WaitForNonStaleResults(waitTimeout time.Duration)
• type DocumentQueryOptions
• type DocumentSession
  • func NewDocumentSession(dbName string, documentStore *DocumentStore, id string, re *RequestExecutor) *DocumentSession
  • func (s *DocumentSession) Advanced() *AdvancedSessionOperations
  • func (s *DocumentSession) Attachments() *AttachmentsSessionOperations
  • func (s *DocumentSession) Eagerly() *EagerSessionOperations
  • func (s *DocumentSession) Exists(id string) (bool, error)
  • func (s *DocumentSession) Include(path string) *MultiLoaderWithInclude
  • func (s *DocumentSession) Increment(entity interface{}, path string, valueToAdd interface{}) error
  • func (s *DocumentSession) IncrementByID(id string, path string, valueToAdd interface{}) error
  • func (s *DocumentSession) Lazily() *LazySessionOperations
  • func (s *DocumentSession) Load(result interface{}, id string) error
  • func (s *DocumentSession) LoadIntoStream(ids []string, output io.Writer) error
  • func (s *DocumentSession) LoadMulti(results interface{}, ids []string) error
  • func (s *DocumentSession) LoadStartingWith(results interface{}, args *StartsWithArgs) error
  • func (s *DocumentSession) LoadStartingWithIntoStream(output io.Writer, args *StartsWithArgs) error
  • func (s *DocumentSession) Patch(entity interface{}, path string, value interface{}) error
  • func (s *DocumentSession) PatchArray(entity interface{}, pathToArray string, arrayAdder func(*JavaScriptArray)) error
  • func (s *DocumentSession) PatchArrayByID(id string, pathToArray string, arrayAdder func(*JavaScriptArray)) error
  • func (s *DocumentSession) PatchByID(id string, path string, value interface{}) error
  • func (s *DocumentSession) Query(opts *DocumentQueryOptions) *DocumentQuery
  • func (s *DocumentSession) QueryCollection(collectionName string) *DocumentQuery
  • func (s *DocumentSession) QueryCollectionForType(typ reflect.Type) *DocumentQuery
  • func (s *DocumentSession) QueryIndex(indexName string) *DocumentQuery
  • func (s *DocumentSession) RawQuery(rawQuery string) *RawDocumentQuery
  • func (s *DocumentSession) Refresh(entity interface{}) error
  • func (s *DocumentSession) Revisions() *RevisionsSessionOperations
  • func (s *DocumentSession) SaveChanges() error
  • func (s *DocumentSession) Stream(args *StartsWithArgs) (*StreamIterator, error)
  • func (s *DocumentSession) StreamQuery(query *DocumentQuery, streamQueryStats *StreamQueryStatistics) (*StreamIterator, error)
  • func (s *DocumentSession) StreamQueryInto(query *DocumentQuery, output io.Writer) error
  • func (s *DocumentSession) StreamRawQuery(query *RawDocumentQuery, streamQueryStats *StreamQueryStatistics) (*StreamIterator, error)
  • func (s *DocumentSession) StreamRawQueryInto(query *RawDocumentQuery, output io.Writer) error
• type DocumentSessionAttachments
  • func NewDocumentSessionAttachments(session *InMemoryDocumentSessionOperations) *DocumentSessionAttachments
  • func (s *DocumentSessionAttachments) Exists(documentID string, name string) (bool, error)
  • func (s *DocumentSessionAttachments) Get(entity interface{}, name string) (*AttachmentResult, error)
  • func (s *DocumentSessionAttachments) GetByID(documentID string, name string) (*AttachmentResult, error)
  • func (s *DocumentSessionAttachments) GetRevision(documentID string, name string, changeVector *string) (*AttachmentResult, error)
• type DocumentSessionAttachmentsBase
  • func NewDocumentSessionAttachmentsBase(session *InMemoryDocumentSessionOperations) *DocumentSessionAttachmentsBase
  • func (s *DocumentSessionAttachmentsBase) Delete(entity interface{}, name string) error
  • func (s *DocumentSessionAttachmentsBase) DeleteByID(documentID string, name string) error
  • func (s *DocumentSessionAttachmentsBase) GetNames(entity interface{}) ([]*AttachmentName, error)
  • func (s *DocumentSessionAttachmentsBase) Store(entity interface{}, name string, stream io.Reader, contentType string) error
  • func (s *DocumentSessionAttachmentsBase) StoreByID(documentID string, name string, stream io.Reader, contentType string) error
• type DocumentSessionRevisions
  • func (r *DocumentSessionRevisions) Get(result interface{}, changeVector string) error
  • func (r *DocumentSessionRevisions) GetFor(results interface{}, id string) error
  • func (r *DocumentSessionRevisions) GetForPaged(results interface{}, id string, start int, pageSize int) error
  • func (r *DocumentSessionRevisions) GetForStartAt(results interface{}, id string, start int) error
  • func (r *DocumentSessionRevisions) GetMetadataFor(id string) ([]*MetadataAsDictionary, error)
  • func (r *DocumentSessionRevisions) GetMetadataForPaged(id string, start int, pageSize int) ([]*MetadataAsDictionary, error)
  • func (r *DocumentSessionRevisions) GetMetadataForStartAt(id string, start int) ([]*MetadataAsDictionary, error)
  • func (r *DocumentSessionRevisions) GetRevisions(results interface{}, changeVectors []string) error
• type DocumentStore
  • func NewDocumentStore(urls []string, database string) *DocumentStore
  • func (s *DocumentStore) AddAfterCloseListener(fn func(*DocumentStore)) int
  • func (s *DocumentStore) AddAfterSaveChangesListener(handler func(*AfterSaveChangesEventArgs)) int
  • func (s *DocumentStore) AddBeforeCloseListener(fn func(*DocumentStore)) int
  • func (s *DocumentStore) AddBeforeDeleteListener(handler func(*BeforeDeleteEventArgs)) int
  • func (s *DocumentStore) AddBeforeQueryListener(handler func(*BeforeQueryEventArgs)) int
  • func (s *DocumentStore) AddBeforeStoreListener(handler func(*BeforeStoreEventArgs)) int
  • func (s *DocumentStore) AggressivelyCache(database string) (CancelFunc, error)
  • func (s *DocumentStore) AggressivelyCacheFor(cacheDuration time.Duration) (CancelFunc, error)
  • func (s *DocumentStore) AggressivelyCacheForDatabase(cacheDuration time.Duration, database string) (CancelFunc, error)
  • func (s *DocumentStore) BulkInsert(database string) *BulkInsertOperation
  • func (s *DocumentStore) Changes(database string) *DatabaseChanges
  • func (s *DocumentStore) Close()
  • func (s *DocumentStore) DisableAggressiveCaching(databaseName string) *RestoreCaching
  • func (s *DocumentStore) ExecuteIndex(task *IndexCreationTask, database string) error
  • func (s *DocumentStore) ExecuteIndexes(tasks []*IndexCreationTask, database string) error
  • func (s *DocumentStore) GetConventions() *DocumentConventions
  • func (s *DocumentStore) GetDatabase() string
  • func (s *DocumentStore) GetIdentifier() string
  • func (s *DocumentStore) GetLastDatabaseChangesStateError(database string) error
  • func (s *DocumentStore) GetRequestExecutor(database string) *RequestExecutor
  • func (s *DocumentStore) GetUrls() []string
  • func (s *DocumentStore) Initialize() error
  • func (s *DocumentStore) Maintenance() *MaintenanceOperationExecutor
  • func (s *DocumentStore) OpenSession(database string) (*DocumentSession, error)
  • func (s *DocumentStore) OpenSessionWithOptions(options *SessionOptions) (*DocumentSession, error)
  • func (s *DocumentStore) Operations() *OperationExecutor
  • func (s *DocumentStore) RemoveAfterCloseListener(idx int)
  • func (s *DocumentStore) RemoveAfterSaveChangesListener(handlerID int)
  • func (s *DocumentStore) RemoveBeforeCloseListener(idx int)
  • func (s *DocumentStore) RemoveBeforeDeleteListener(handlerID int)
  • func (s *DocumentStore) RemoveBeforeQueryListener(handlerID int)
  • func (s *DocumentStore) RemoveBeforeStoreListener(handlerID int)
  • func (s *DocumentStore) SetConventions(conventions *DocumentConventions)
  • func (s *DocumentStore) SetDatabase(database string)
  • func (s *DocumentStore) SetIdentifier(identifier string)
  • func (s *DocumentStore) SetUrls(urls []string)
  • func (s *DocumentStore) Subscriptions() *DocumentSubscriptions
• type DocumentSubscriptions
  • func (s *DocumentSubscriptions) Close() error
  • func (s *DocumentSubscriptions) Create(options *SubscriptionCreationOptions, database string) (string, error)
  • func (s *DocumentSubscriptions) CreateForRevisions(clazz reflect.Type, options *SubscriptionCreationOptions, database string) (string, error)
  • func (s *DocumentSubscriptions) CreateForType(clazz reflect.Type, options *SubscriptionCreationOptions, database string) (string, error)
  • func (s *DocumentSubscriptions) Delete(name string, database string) error
  • func (s *DocumentSubscriptions) DropConnection(name string, database string) error
  • func (s *DocumentSubscriptions) GetSubscriptionState(subscriptionName string, database string) (*SubscriptionState, error)
  • func (s *DocumentSubscriptions) GetSubscriptionWorker(clazz reflect.Type, options *SubscriptionWorkerOptions, database string) (*SubscriptionWorker, error)
  • func (s *DocumentSubscriptions) GetSubscriptionWorkerForRevisions(clazz reflect.Type, options *SubscriptionWorkerOptions, database string) (*SubscriptionWorker, error)
  • func (s *DocumentSubscriptions) GetSubscriptions(start int, take int, database string) ([]*SubscriptionState, error)
• type DocumentsChanges
• type DropSubscriptionConnectionCommand
  • func (c *DropSubscriptionConnectionCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type Duration
  • func (d Duration) MarshalJSON() ([]byte, error)
  • func (d *Duration) UnmarshalJSON(data []byte) error
• type DynamicSpatialField
• type EagerSessionOperations
  • func (s *EagerSessionOperations) ExecuteAllPendingLazyOperations() (*ResponseTimeInformation, error)
• type EnableIndexCommand
  • func NewEnableIndexCommand(indexName string) (*EnableIndexCommand, error)
  • func (c *EnableIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type EnableIndexOperation
  • func NewEnableIndexOperation(indexName string) (*EnableIndexOperation, error)
  • func (o *EnableIndexOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type EventHandler
• type ExplainQueryCommand
  • func NewExplainQueryCommand(conventions *DocumentConventions, indexQuery *IndexQuery) *ExplainQueryCommand
  • func (c *ExplainQueryCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *ExplainQueryCommand) SetResponse(response []byte, fromCache bool) error
• type ExplainQueryResult
• type ExternalReplication
  • func NewExternalReplication(database string, connectionStringName string) *ExternalReplication
• type Facet
  • func NewFacet() *Facet
  • func (f *Facet) ToFacetToken(addQueryParameter func(interface{}) string) (*facetToken, error)
• type FacetAggregation
• type FacetBase
• type FacetBaseCommon
  • func NewFacetBaseCommon() FacetBaseCommon
  • func (f *FacetBaseCommon) GetAggregations() map[FacetAggregation]string
  • func (f *FacetBaseCommon) GetOptions() *FacetOptions
  • func (f *FacetBaseCommon) SetDisplayFieldName(displayFieldName string)
  • func (f *FacetBaseCommon) SetOptions(options *FacetOptions)
• type FacetBuilder
  • func NewFacetBuilder() *FacetBuilder
  • func (b *FacetBuilder) AllResults() *FacetBuilder
  • func (b *FacetBuilder) AverageOn(path string) *FacetBuilder
  • func (b *FacetBuilder) ByField(fieldName string) *FacetBuilder
  • func (b *FacetBuilder) ByRanges(rng *RangeBuilder, ranges ...*RangeBuilder) *FacetBuilder
  • func (b *FacetBuilder) GetFacet() FacetBase
  • func (b *FacetBuilder) MaxOn(path string) *FacetBuilder
  • func (b *FacetBuilder) MinOn(path string) *FacetBuilder
  • func (b *FacetBuilder) SumOn(path string) *FacetBuilder
  • func (b *FacetBuilder) WithDisplayName(displayName string) *FacetBuilder
  • func (b *FacetBuilder) WithOptions(options *FacetOptions) *FacetBuilder
• type FacetOptions
  • func NewFacetOptions() *FacetOptions
• type FacetResult
• type FacetSetup
• type FacetTermSortMode
• type FacetValue
  • func (v *FacetValue) SetAverage(average float64)
  • func (v *FacetValue) SetMax(max float64)
  • func (v *FacetValue) SetMin(min float64)
  • func (v *FacetValue) SetSum(sum float64)
  • func (v *FacetValue) String() string
• type FieldIndexing
• type FieldStorage
• type FieldTermVector
• type GenericQueryResult
• type GenericRangeFacet
  • func NewGenericRangeFacet(parent FacetBase) *GenericRangeFacet
  • func (f *GenericRangeFacet) ToFacetToken(addQueryParameter func(interface{}) string) (*facetToken, error)
• type GetAttachmentCommand
  • func NewGetAttachmentCommand(documentID string, name string, typ AttachmentType, changeVector *string) (*GetAttachmentCommand, error)
  • func (c *GetAttachmentCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type GetAttachmentOperation
  • func NewGetAttachmentOperation(documentID string, name string, typ AttachmentType, contentType string, ...) *GetAttachmentOperation
  • func (o *GetAttachmentOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)
• type GetClientConfigurationCommand
  • func NewGetClientConfigurationCommand() *GetClientConfigurationCommand
  • func (c *GetClientConfigurationCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetClientConfigurationCommand) SetResponse(response []byte, fromCache bool) error
• type GetClientConfigurationCommandResult
• type GetClientConfigurationOperation
  • func NewGetClientConfigurationOperation() *GetClientConfigurationOperation
  • func (o *GetClientConfigurationOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetCollectionStatisticsCommand
  • func NewGetCollectionStatisticsCommand() *GetCollectionStatisticsCommand
  • func (c *GetCollectionStatisticsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetCollectionStatisticsCommand) SetResponse(response []byte, fromCache bool) error
• type GetCollectionStatisticsOperation
  • func NewGetCollectionStatisticsOperation() *GetCollectionStatisticsOperation
  • func (o *GetCollectionStatisticsOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetCompareExchangeValueCommand
  • func NewGetCompareExchangeValueCommand(clazz reflect.Type, key string, conventions *DocumentConventions) (*GetCompareExchangeValueCommand, error)
  • func (c *GetCompareExchangeValueCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetCompareExchangeValueCommand) SetResponse(response []byte, fromCache bool) error
• type GetCompareExchangeValueOperation
  • func NewGetCompareExchangeValueOperation(clazz reflect.Type, key string) (*GetCompareExchangeValueOperation, error)
  • func (o *GetCompareExchangeValueOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)
• type GetCompareExchangeValuesCommand
  • func NewGetCompareExchangeValuesCommand(operation *GetCompareExchangeValuesOperation, conventions *DocumentConventions) (*GetCompareExchangeValuesCommand, error)
  • func (c *GetCompareExchangeValuesCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetCompareExchangeValuesCommand) SetResponse(response []byte, fromCache bool) error
• type GetCompareExchangeValuesOperation
  • func NewGetCompareExchangeValuesOperation(clazz reflect.Type, startWith string, start int, pageSize int) (*GetCompareExchangeValuesOperation, error)
  • func NewGetCompareExchangeValuesOperationWithKeys(clazz reflect.Type, keys []string) (*GetCompareExchangeValuesOperation, error)
  • func (o *GetCompareExchangeValuesOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)
• type GetConflictsCommand
  • func NewGetConflictsCommand(id string) *GetConflictsCommand
  • func (c *GetConflictsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetConflictsCommand) SetResponse(response []byte, fromCache bool) error
• type GetConflictsResult
• type GetDatabaseNamesCommand
  • func NewGetDatabaseNamesCommand(_start int, _pageSize int) *GetDatabaseNamesCommand
  • func (c *GetDatabaseNamesCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetDatabaseNamesCommand) SetResponse(response []byte, fromCache bool) error
• type GetDatabaseNamesOperation
  • func NewGetDatabaseNamesOperation(_start int, _pageSize int) *GetDatabaseNamesOperation
  • func (o *GetDatabaseNamesOperation) GetCommand(conventions *DocumentConventions) *GetDatabaseNamesCommand
• type GetDatabaseNamesResult
• type GetDatabaseRecordCommand
  • func NewGetDatabaseRecordCommand(conventions *DocumentConventions, database string) *GetDatabaseRecordCommand
  • func (c *GetDatabaseRecordCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetDatabaseRecordCommand) SetResponse(response []byte, fromCache bool) error
• type GetDatabaseRecordOperation
  • func NewGetDatabaseRecordOperation(database string) *GetDatabaseRecordOperation
  • func (o *GetDatabaseRecordOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetDatabaseTopologyCommand
  • func NewGetDatabaseTopologyCommand() *GetDatabaseTopologyCommand
  • func (c *GetDatabaseTopologyCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetDatabaseTopologyCommand) SetResponse(response []byte, fromCache bool) error
• type GetDocumentsCommand
  • func NewGetDocumentsCommand(ids []string, includes []string, metadataOnly bool) (*GetDocumentsCommand, error)
  • func NewGetDocumentsCommandFull(startWith string, startAfter string, matches string, exclude string, start int, ...) (*GetDocumentsCommand, error)
  • func (c *GetDocumentsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetDocumentsCommand) SetResponse(response []byte, fromCache bool) error
• type GetDocumentsResult
• type GetIdentitiesCommand
  • func NewGetIdentitiesCommand() *GetIdentitiesCommand
  • func (c *GetIdentitiesCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetIdentitiesCommand) SetResponse(response []byte, fromCache bool) error
• type GetIdentitiesOperation
  • func NewGetIdentitiesOperation() *GetIdentitiesOperation
  • func (o *GetIdentitiesOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetIndexCommand
  • func NewGetIndexCommand(indexName string) (*GetIndexCommand, error)
  • func (c *GetIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetIndexCommand) SetResponse(response []byte, fromCache bool) error
• type GetIndexErrorsCommand
  • func NewGetIndexErrorsCommand(indexNames []string) *GetIndexErrorsCommand
  • func (c *GetIndexErrorsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetIndexErrorsCommand) SetResponse(response []byte, fromCache bool) error
• type GetIndexErrorsOperation
  • func NewGetIndexErrorsOperation(indexNames []string) *GetIndexErrorsOperation
  • func (o *GetIndexErrorsOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetIndexNamesCommand
  • func NewGetIndexNamesCommand(start int, pageSize int) *GetIndexNamesCommand
  • func (c *GetIndexNamesCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetIndexNamesCommand) SetResponse(response []byte, fromCache bool) error
• type GetIndexNamesOperation
  • func NewGetIndexNamesOperation(start int, pageSize int) *GetIndexNamesOperation
  • func (o *GetIndexNamesOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetIndexOperation
  • func NewGetIndexOperation(indexName string) *GetIndexOperation
  • func (o *GetIndexOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetIndexStatisticsCommand
  • func NewGetIndexStatisticsCommand(indexName string) (*GetIndexStatisticsCommand, error)
  • func (c *GetIndexStatisticsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetIndexStatisticsCommand) SetResponse(response []byte, fromCache bool) error
• type GetIndexStatisticsOperation
  • func NewGetIndexStatisticsOperation(indexName string) *GetIndexStatisticsOperation
  • func (o *GetIndexStatisticsOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetIndexesCommand
  • func NewGetIndexesCommand(_start int, _pageSize int) *GetIndexesCommand
  • func (c *GetIndexesCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetIndexesCommand) SetResponse(response []byte, fromCache bool) error
• type GetIndexesOperation
  • func NewGetIndexesOperation(_start int, _pageSize int) *GetIndexesOperation
  • func (o *GetIndexesOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetIndexesStatisticsCommand
  • func NewGetIndexesStatisticsCommand() *GetIndexesStatisticsCommand
  • func (c *GetIndexesStatisticsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetIndexesStatisticsCommand) SetResponse(response []byte, fromCache bool) error
• type GetIndexesStatisticsOperation
  • func NewGetIndexesStatisticsOperation() *GetIndexesStatisticsOperation
  • func (o *GetIndexesStatisticsOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetIndexingStatusCommand
  • func NewGetIndexingStatusCommand() *GetIndexingStatusCommand
  • func (c *GetIndexingStatusCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetIndexingStatusCommand) SetResponse(response []byte, fromCache bool) error
• type GetIndexingStatusOperation
  • func NewGetIndexingStatusOperation() *GetIndexingStatusOperation
  • func (o *GetIndexingStatusOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetNextOperationIDCommand
  • func NewGetNextOperationIDCommand() *GetNextOperationIDCommand
  • func (c *GetNextOperationIDCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetNextOperationIDCommand) SetResponse(response []byte, fromCache bool) error
• type GetOperationStateCommand
  • func NewGetOperationStateCommand(conventions *DocumentConventions, id int64) *GetOperationStateCommand
  • func (c *GetOperationStateCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetOperationStateCommand) SetResponse(response []byte, fromCache bool) error
• type GetOperationStateOperation
  • func (o *GetOperationStateOperation) GetCommand(conventions *DocumentConventions) *GetOperationStateCommand
• type GetResponse
• type GetRevisionOperation
  • func NewGetRevisionOperationRange(session *InMemoryDocumentSessionOperations, id string, start int, pageSize int, ...) (*GetRevisionOperation, error)
  • func NewGetRevisionOperationWithChangeVectors(session *InMemoryDocumentSessionOperations, changeVectors []string) *GetRevisionOperation
  • func (o *GetRevisionOperation) GetRevision(result interface{}) error
  • func (o *GetRevisionOperation) GetRevisionWithDocument(result interface{}, document map[string]interface{}) error
  • func (o *GetRevisionOperation) GetRevisions(results interface{}) error
  • func (o *GetRevisionOperation) GetRevisionsFor(results interface{}) error
  • func (o *GetRevisionOperation) GetRevisionsMetadataFor() []*MetadataAsDictionary
• type GetRevisionsBinEntryCommand
  • func NewGetRevisionsBinEntryCommand(etag int64, pageSize int) *GetRevisionsBinEntryCommand
  • func (c *GetRevisionsBinEntryCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetRevisionsBinEntryCommand) SetResponse(response []byte, fromCache bool) error
• type GetRevisionsCommand
  • func NewGetRevisionsCommand(changeVectors []string, metadataOnly bool) *GetRevisionsCommand
  • func NewGetRevisionsCommandRange(id string, start int, pageSize int, metadataOnly bool) *GetRevisionsCommand
  • func (c *GetRevisionsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetRevisionsCommand) GetChangeVectors() []string
  • func (c *GetRevisionsCommand) SetResponse(response []byte, fromCache bool) error
• type GetServerWideOperationStateCommand
  • func NewGetServerWideOperationStateCommand(conventions *DocumentConventions, id int64) *GetServerWideOperationStateCommand
  • func (c *GetServerWideOperationStateCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetServerWideOperationStateCommand) SetResponse(response []byte, fromCache bool) error
• type GetServerWideOperationStateOperation
  • func (o *GetServerWideOperationStateOperation) GetCommand(conventions *DocumentConventions) *GetServerWideOperationStateCommand
• type GetStatisticsCommand
  • func NewGetStatisticsCommand(debugTag string) *GetStatisticsCommand
  • func (c *GetStatisticsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetStatisticsCommand) SetResponse(response []byte, fromCache bool) error
• type GetStatisticsOperation
  • func NewGetStatisticsOperation(debugTag string) *GetStatisticsOperation
  • func (o *GetStatisticsOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GetSubscriptionStateCommand
  • func (c *GetSubscriptionStateCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetSubscriptionStateCommand) SetResponse(response []byte, fromCache bool) error
• type GetSubscriptionsCommand
  • func (c *GetSubscriptionsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetSubscriptionsCommand) SetResponse(response []byte, fromCache bool) error
• type GetSubscriptionsResult
• type GetTcpInfoCommand
  • func NewGetTcpInfoCommand(tag, dbName string) *GetTcpInfoCommand
  • func (c *GetTcpInfoCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetTcpInfoCommand) SetResponse(response []byte, fromCache bool) error
• type GetTermsCommand
  • func NewGetTermsCommand(indexName string, field string, fromValue string, pageSize int) (*GetTermsCommand, error)
  • func (c *GetTermsCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *GetTermsCommand) SetResponse(response []byte, fromCache bool) error
• type GetTermsOperation
  • func NewGetTermsOperation(indexName string, field string, fromValue string, pageSize int) (*GetTermsOperation, error)
  • func (o *GetTermsOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type GroupBy
  • func NewGroupByArray(fieldName string) *GroupBy
  • func NewGroupByField(fieldName string) *GroupBy
• type GroupByDocumentQuery
  • func (q *GroupByDocumentQuery) SelectCount() *DocumentQuery
  • func (q *GroupByDocumentQuery) SelectCountWithName(projectedName string) *DocumentQuery
  • func (q *GroupByDocumentQuery) SelectKey() *GroupByDocumentQuery
  • func (q *GroupByDocumentQuery) SelectKeyWithName(fieldName string) *GroupByDocumentQuery
  • func (q *GroupByDocumentQuery) SelectKeyWithNameAndProjectedName(fieldName string, projectedName string) *GroupByDocumentQuery
  • func (q *GroupByDocumentQuery) SelectSum(field *GroupByField, fields ...*GroupByField) *DocumentQuery
• type GroupByField
• type GroupByMethod
• type HashCalculator
• type HeadAttachmentCommand
  • func NewHeadAttachmentCommand(documentID string, name string, changeVector *string) (*HeadAttachmentCommand, error)
  • func (c *HeadAttachmentCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *HeadAttachmentCommand) SetResponse(response []byte, fromCache bool) error
• type HeadDocumentCommand
  • func NewHeadDocumentCommand(id string, changeVector *string) *HeadDocumentCommand
  • func (c *HeadDocumentCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *HeadDocumentCommand) Exists() bool
  • func (c *HeadDocumentCommand) ProcessResponse(cache *httpCache, response *http.Response, url string) (responseDisposeHandling, error)
  • func (c *HeadDocumentCommand) SetResponse(response []byte, fromCache bool) error
• type HiLoIDGenerator
  • func NewHiLoIDGenerator(tag string, store *DocumentStore, dbName string, identityPartsSeparator string) *HiLoIDGenerator
  • func (g *HiLoIDGenerator) GenerateDocumentID(entity interface{}) (string, error)
  • func (g *HiLoIDGenerator) GetDocumentIDFromID(nextID int64) string
  • func (g *HiLoIDGenerator) GetNextRange() error
  • func (g *HiLoIDGenerator) NextID() (int64, error)
  • func (g *HiLoIDGenerator) ReturnUnusedRange() error
• type HiLoResult
• type HiLoReturnCommand
  • func NewHiLoReturnCommand(tag string, last int64, end int64) (*HiLoReturnCommand, error)
  • func (c *HiLoReturnCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type ICommandData
  • func NewDeleteCommandData(id string, changeVector string) ICommandData
  • func NewPatchCommandData(id string, changeVector *string, patch *PatchRequest, ...) ICommandData
• type IContent
• type ILazyOperation
• type IMaintenanceOperation
• type IMoreLikeThisBuilderBase
• type IMoreLikeThisBuilderForDocumentQuery
• type IMoreLikeThisOperations
• type IOperation
• type IRaftCommand
• type IServerOperation
• type IVoidMaintenanceOperation
• type IllegalArgumentError
  • func (e *IllegalArgumentError) Error() string
  • func (e *IllegalArgumentError) WrappedError() error
• type IllegalStateError
  • func (e *IllegalStateError) Error() string
  • func (e *IllegalStateError) WrappedError() error
• type InMemoryDocumentSessionOperations
  • func (s *InMemoryDocumentSessionOperations) AddAfterSaveChangesListener(handler func(*AfterSaveChangesEventArgs)) int
  • func (s *InMemoryDocumentSessionOperations) AddBeforeDeleteListener(handler func(*BeforeDeleteEventArgs)) int
  • func (s *InMemoryDocumentSessionOperations) AddBeforeQueryListener(handler func(*BeforeQueryEventArgs)) int
  • func (s *InMemoryDocumentSessionOperations) AddBeforeStoreListener(handler func(*BeforeStoreEventArgs)) int
  • func (s *InMemoryDocumentSessionOperations) Clear()
  • func (s *InMemoryDocumentSessionOperations) Close()
  • func (s *InMemoryDocumentSessionOperations) Defer(commands ...ICommandData)
  • func (s *InMemoryDocumentSessionOperations) Delete(entity interface{}) error
  • func (s *InMemoryDocumentSessionOperations) DeleteByID(id string, expectedChangeVector string) error
  • func (s *InMemoryDocumentSessionOperations) Evict(entity interface{}) error
  • func (s *InMemoryDocumentSessionOperations) GenerateID(entity interface{}) (string, error)
  • func (s *InMemoryDocumentSessionOperations) GetChangeVectorFor(instance interface{}) (*string, error)
  • func (s *InMemoryDocumentSessionOperations) GetConventions() *DocumentConventions
  • func (s *InMemoryDocumentSessionOperations) GetCurrentSessionNode() (*ServerNode, error)
  • func (s *InMemoryDocumentSessionOperations) GetDeferredCommandsCount() int
  • func (s *InMemoryDocumentSessionOperations) GetDocumentID(instance interface{}) string
  • func (s *InMemoryDocumentSessionOperations) GetDocumentStore() *DocumentStore
  • func (s *InMemoryDocumentSessionOperations) GetLastModifiedFor(instance interface{}) (*time.Time, error)
  • func (s *InMemoryDocumentSessionOperations) GetMetadataFor(instance interface{}) (*MetadataAsDictionary, error)
  • func (s *InMemoryDocumentSessionOperations) GetNumberOfEntitiesInUnitOfWork() int
  • func (s *InMemoryDocumentSessionOperations) GetNumberOfRequests() int
  • func (s *InMemoryDocumentSessionOperations) GetOperations() *OperationExecutor
  • func (s *InMemoryDocumentSessionOperations) GetRequestExecutor() *RequestExecutor
  • func (s *InMemoryDocumentSessionOperations) HasChanged(entity interface{}) (bool, error)
  • func (s *InMemoryDocumentSessionOperations) HasChanges() bool
  • func (s *InMemoryDocumentSessionOperations) IgnoreChangesFor(entity interface{}) error
  • func (s *InMemoryDocumentSessionOperations) IsDeleted(id string) bool
  • func (s *InMemoryDocumentSessionOperations) IsLoaded(id string) bool
  • func (s *InMemoryDocumentSessionOperations) IsLoadedOrDeleted(id string) bool
  • func (s *InMemoryDocumentSessionOperations) RemoveAfterSaveChangesListener(handlerID int)
  • func (s *InMemoryDocumentSessionOperations) RemoveBeforeDeleteListener(handlerID int)
  • func (s *InMemoryDocumentSessionOperations) RemoveBeforeQueryListener(handlerID int)
  • func (s *InMemoryDocumentSessionOperations) RemoveBeforeStoreListener(handlerID int)
  • func (s *InMemoryDocumentSessionOperations) Store(entity interface{}) error
  • func (s *InMemoryDocumentSessionOperations) StoreWithChangeVectorAndID(entity interface{}, changeVector string, id string) error
  • func (s *InMemoryDocumentSessionOperations) StoreWithID(entity interface{}, id string) error
  • func (s *InMemoryDocumentSessionOperations) TrackEntity(result interface{}, id string, document map[string]interface{}, ...) error
  • func (s *InMemoryDocumentSessionOperations) TrackEntityInDocumentInfo(result interface{}, documentFound *documentInfo) error
  • func (s *InMemoryDocumentSessionOperations) UpdateMetadataModifications(documentInfo *documentInfo) bool
  • func (s *InMemoryDocumentSessionOperations) WaitForIndexesAfterSaveChanges(options func(*IndexesWaitOptsBuilder))
  • func (s *InMemoryDocumentSessionOperations) WaitForReplicationAfterSaveChanges(options func(*ReplicationWaitOptsBuilder))
  • func (s *InMemoryDocumentSessionOperations) WhatChanged() (map[string][]*DocumentsChanges, error)
• type IndexAlreadyExistError
  • func (e *IndexAlreadyExistError) Error() string
  • func (e *IndexAlreadyExistError) WrappedError() error
• type IndexChange
• type IndexChangeTypes
• type IndexCompilationError
  • func (e *IndexCompilationError) Error() string
  • func (e *IndexCompilationError) WrappedError() error
• type IndexConfiguration
  • func NewIndexConfiguration() IndexConfiguration
• type IndexCreationError
  • func (e *IndexCreationError) Error() string
  • func (e *IndexCreationError) WrappedError() error
• type IndexCreationTask
  • func NewIndexCreationTask(indexName string) *IndexCreationTask
  • func (t *IndexCreationTask) Analyze(field string, analyzer string)
  • func (t *IndexCreationTask) CreateIndexDefinition() *IndexDefinition
  • func (t *IndexCreationTask) Execute(store *DocumentStore, conventions *DocumentConventions, database string) error
  • func (t *IndexCreationTask) Index(field string, indexing FieldIndexing)
  • func (t *IndexCreationTask) IsMapReduce() bool
  • func (t *IndexCreationTask) Spatial(field string, indexing func() *SpatialOptions)
  • func (t *IndexCreationTask) Store(field string, storage FieldStorage)
  • func (t *IndexCreationTask) StoreAllFields(storage FieldStorage)
  • func (t *IndexCreationTask) Suggestion(field string)
  • func (t *IndexCreationTask) TermVector(field string, termVector FieldTermVector)
• type IndexDefinition
  • func NewIndexDefinition() *IndexDefinition
  • func (d *IndexDefinition) GetAdditionalSources() map[string]string
  • func (d *IndexDefinition) GetConfiguration() IndexConfiguration
  • func (d *IndexDefinition) GetFields() map[string]*IndexFieldOptions
  • func (d *IndexDefinition) GetOutputReduceToCollection() *string
  • func (d *IndexDefinition) GetType() IndexType
  • func (d *IndexDefinition) SetAdditionalSources(additionalSources map[string]string)
  • func (d *IndexDefinition) SetConfiguration(configuration IndexConfiguration)
  • func (d *IndexDefinition) SetOutputReduceToCollection(outputReduceToCollection string)
  • func (d *IndexDefinition) SetType(indexType IndexType)
  • func (d *IndexDefinition) String() string
• type IndexDefinitionBuilder
  • func NewIndexDefinitionBuilder(indexName string) *IndexDefinitionBuilder
• type IndexDeletionError
  • func (e *IndexDeletionError) Error() string
  • func (e *IndexDeletionError) WrappedError() error
• type IndexDoesNotExistError
  • func (e *IndexDoesNotExistError) Error() string
  • func (e *IndexDoesNotExistError) WrappedError() error
• type IndexErrors
• type IndexFieldOptions
  • func NewIndexFieldOptions() *IndexFieldOptions
• type IndexHasChangedCommand
  • func NewIndexHasChangedCommand(conventions *DocumentConventions, definition *IndexDefinition) (*IndexHasChangedCommand, error)
  • func (c *IndexHasChangedCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *IndexHasChangedCommand) SetResponse(response []byte, fromCache bool) error
• type IndexHasChangedOperation
  • func NewIndexHasChangedOperation(definition *IndexDefinition) *IndexHasChangedOperation
  • func (o *IndexHasChangedOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type IndexInformation
  • func (i *IndexInformation) GetLastIndexingTime() time.Time
• type IndexInvalidError
  • func (e *IndexInvalidError) Error() string
  • func (e *IndexInvalidError) WrappedError() error
• type IndexLockMode
• type IndexPriority
• type IndexQuery
  • func NewIndexQuery(query string) *IndexQuery
  • func (q *IndexQuery) GetQuery() string
  • func (q *IndexQuery) GetQueryHash() string
  • func (q *IndexQuery) GetQueryParameters() Parameters
  • func (q *IndexQuery) String() string
• type IndexQueryContent
  • func NewIndexQueryContent(conventions *DocumentConventions, query *IndexQuery) *IndexQueryContent
• type IndexRunningStatus
• type IndexState
• type IndexStats
• type IndexStatus
• type IndexType
• type IndexesWaitOptsBuilder
  • func (b *IndexesWaitOptsBuilder) ThrowOnTimeout(shouldThrow bool) *IndexesWaitOptsBuilder
  • func (b *IndexesWaitOptsBuilder) WaitForIndexes(indexes ...string) *IndexesWaitOptsBuilder
  • func (b *IndexesWaitOptsBuilder) WithTimeout(timeout time.Duration) *IndexesWaitOptsBuilder
• type IndexingError
  • func (e *IndexingError) String() string
• type IndexingStatus
• type InvalidQueryError
  • func (e *InvalidQueryError) Error() string
  • func (e *InvalidQueryError) WrappedError() error
• type JSONArrayResult
• type JavaScriptArray
  • func NewJavaScriptArray(suffix int, pathToArray string) *JavaScriptArray
  • func (a *JavaScriptArray) Add(args ...interface{}) *JavaScriptArray
  • func (a *JavaScriptArray) GetScript() string
  • func (a *JavaScriptArray) RemoveAt(index int) *JavaScriptArray
• type JavaScriptError
  • func (e *JavaScriptError) Error() string
  • func (e *JavaScriptError) WrappedError() error
• type KillOperationCommand
  • func NewKillOperationCommand(id string) (*KillOperationCommand, error)
  • func (c *KillOperationCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type Lazy
  • func (l *Lazy) GetValue(result interface{}) error
  • func (l *Lazy) IsValueCreated() bool
• type LazyAggregationQueryOperation
• type LazyLoadOperation
• type LazyMultiLoaderWithInclude
  • func NewLazyMultiLoaderWithInclude(session *DocumentSession) *LazyMultiLoaderWithInclude
  • func (l *LazyMultiLoaderWithInclude) Include(path string) *LazyMultiLoaderWithInclude
  • func (l *LazyMultiLoaderWithInclude) Load(id string) (*Lazy, error)
  • func (l *LazyMultiLoaderWithInclude) LoadMulti(ids []string) (*Lazy, error)
• type LazyQueryOperation
• type LazySessionOperations
  • func (o *LazySessionOperations) Include(path string) *LazyMultiLoaderWithInclude
  • func (o *LazySessionOperations) Load(id string) (*Lazy, error)
  • func (o *LazySessionOperations) LoadMulti(ids []string) (*Lazy, error)
  • func (o *LazySessionOperations) LoadMultiWithEval(ids []string, onEval func(), onEvalResult interface{}) (*Lazy, error)
  • func (o *LazySessionOperations) LoadStartingWith(args *StartsWithArgs) *Lazy
  • func (o *LazySessionOperations) LoadWithEval(id string, onEval func(), onEvalResult interface{}) (*Lazy, error)
• type LazyStartsWithOperation
  • func NewLazyStartsWithOperation(idPrefix string, matches string, exclude string, start int, pageSize int, ...) *LazyStartsWithOperation
• type LazySuggestionQueryOperation
• type LeaderStamp
• type LicenseActivationError
  • func (e *LicenseActivationError) Error() string
  • func (e *LicenseActivationError) WrappedError() error
• type LoadOperation
  • func NewLoadOperation(session *InMemoryDocumentSessionOperations) *LoadOperation
• type LoadStartingWithOperation
  • func NewLoadStartingWithOperation(session *InMemoryDocumentSessionOperations) *LoadStartingWithOperation
• type MaintenanceOperationExecutor
  • func NewMaintenanceOperationExecutor(store *DocumentStore, databaseName string) *MaintenanceOperationExecutor
  • func (e *MaintenanceOperationExecutor) ForDatabase(databaseName string) *MaintenanceOperationExecutor
  • func (e *MaintenanceOperationExecutor) GetRequestExecutor() *RequestExecutor
  • func (e *MaintenanceOperationExecutor) Send(operation IMaintenanceOperation) error
  • func (e *MaintenanceOperationExecutor) SendAsync(operation IMaintenanceOperation) (*Operation, error)
  • func (e *MaintenanceOperationExecutor) Server() *ServerOperationExecutor
• type MetadataAsDictionary
  • func NewMetadataAsDictionary(metadata map[string]interface{}, parent *MetadataAsDictionary, ...) *MetadataAsDictionary
  • func NewMetadataAsDictionaryWithMetadata(metadata map[string]interface{}) *MetadataAsDictionary
  • func NewMetadataAsDictionaryWithSource(metadata map[string]interface{}) *MetadataAsDictionary
  • func (d *MetadataAsDictionary) Clear()
  • func (d *MetadataAsDictionary) ContainsKey(key string) bool
  • func (d *MetadataAsDictionary) ConvertValue(key string, value interface{}) interface{}
  • func (d *MetadataAsDictionary) EntrySet() map[string]interface{}
  • func (d *MetadataAsDictionary) Get(key string) (interface{}, bool)
  • func (d *MetadataAsDictionary) GetObjects(key string) []*MetadataAsDictionary
  • func (d *MetadataAsDictionary) Init()
  • func (d *MetadataAsDictionary) IsDirty() bool
  • func (d *MetadataAsDictionary) IsEmpty() bool
  • func (d *MetadataAsDictionary) KeySet() []string
  • func (d *MetadataAsDictionary) MarkDirty()
  • func (d *MetadataAsDictionary) Put(key string, value interface{}) interface{}
  • func (d *MetadataAsDictionary) Remove(key string)
  • func (d *MetadataAsDictionary) Size() int
• type MethodCall
• type MethodCallData
• type MethodsType
• type ModifyOngoingTaskResult
• type MoreLikeThisBase
• type MoreLikeThisBuilder
  • func NewMoreLikeThisBuilder() *MoreLikeThisBuilder
  • func (b *MoreLikeThisBuilder) GetMoreLikeThis() MoreLikeThisBase
  • func (b *MoreLikeThisBuilder) UsingAnyDocument() IMoreLikeThisOperations
  • func (b *MoreLikeThisBuilder) UsingDocument(documentJSON string) IMoreLikeThisOperations
  • func (b *MoreLikeThisBuilder) UsingDocumentWithBuilder(builder func(*DocumentQuery)) IMoreLikeThisOperations
  • func (b *MoreLikeThisBuilder) WithOptions(options *MoreLikeThisOptions) IMoreLikeThisOperations
• type MoreLikeThisCommon
  • func (c *MoreLikeThisCommon) GetOptions() *MoreLikeThisOptions
  • func (c *MoreLikeThisCommon) SetOptions(options *MoreLikeThisOptions)
• type MoreLikeThisOptions
  • func NewMoreLikeThisOptions() *MoreLikeThisOptions
  • func (o *MoreLikeThisOptions) SetBoost(boost bool)
  • func (o *MoreLikeThisOptions) SetBoostFactor(boostFactor float32)
  • func (o *MoreLikeThisOptions) SetMaximumDocumentFrequency(maximumDocumentFrequency int)
  • func (o *MoreLikeThisOptions) SetMaximumDocumentFrequencyPercentage(maximumDocumentFrequencyPercentage int)
  • func (o *MoreLikeThisOptions) SetMaximumNumberOfTokensParsed(maximumNumberOfTokensParsed int)
  • func (o *MoreLikeThisOptions) SetMaximumQueryTerms(maximumQueryTerms int)
  • func (o *MoreLikeThisOptions) SetMaximumWordLength(maximumWordLength int)
  • func (o *MoreLikeThisOptions) SetMinimumDocumentFrequency(minimumDocumentFrequency int)
  • func (o *MoreLikeThisOptions) SetMinimumTermFrequency(minimumTermFrequency int)
  • func (o *MoreLikeThisOptions) SetMinimumWordLength(minimumWordLength int)
  • func (o *MoreLikeThisOptions) SetStopWordsDocumentID(stopWordsDocumentID string)
• type MoreLikeThisQueryResult
• type MoreLikeThisStopWords
• type MoreLikeThisUsingAnyDocument
  • func NewMoreLikeThisUsingAnyDocument() *MoreLikeThisUsingAnyDocument
• type MoreLikeThisUsingDocument
• type MoreLikeThisUsingDocumentForDocumentQuery
  • func NewMoreLikeThisUsingDocumentForDocumentQuery() *MoreLikeThisUsingDocumentForDocumentQuery
  • func (m *MoreLikeThisUsingDocumentForDocumentQuery) GetForDocumentQuery() func(*DocumentQuery)
• type MultiDatabaseHiLoIDGenerator
  • func NewMultiDatabaseHiLoIDGenerator(store *DocumentStore, conventions *DocumentConventions) *MultiDatabaseHiLoIDGenerator
  • func (g *MultiDatabaseHiLoIDGenerator) GenerateDocumentID(dbName string, entity interface{}) (string, error)
  • func (g *MultiDatabaseHiLoIDGenerator) ReturnUnusedRange()
• type MultiGetCommand
  • func (c *MultiGetCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *MultiGetCommand) SetResponseRaw(response *http.Response, stream io.Reader) error
• type MultiGetOperation
• type MultiLoaderWithInclude
  • func NewMultiLoaderWithInclude(session *DocumentSession) *MultiLoaderWithInclude
  • func (l *MultiLoaderWithInclude) Include(path string) *MultiLoaderWithInclude
  • func (l *MultiLoaderWithInclude) Load(result interface{}, id string) error
  • func (l *MultiLoaderWithInclude) LoadMulti(results interface{}, ids []string) error
• type MultiTypeHiLoIDGenerator
  • func NewMultiTypeHiLoIDGenerator(store *DocumentStore, dbName string, conventions *DocumentConventions) *MultiTypeHiLoIDGenerator
  • func (g *MultiTypeHiLoIDGenerator) GenerateDocumentID(entity interface{}) (string, error)
  • func (g *MultiTypeHiLoIDGenerator) ReturnUnusedRange()
• type NextHiLoCommand
  • func NewNextHiLoCommand(tag string, lastBatchSize int64, lastRangeAt *time.Time, ...) *NextHiLoCommand
  • func (c *NextHiLoCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *NextHiLoCommand) SetResponse(response []byte, fromCache bool) error
• type NextIdentityForCommand
  • func NewNextIdentityForCommand(id string) *NextIdentityForCommand
  • func (c *NextIdentityForCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *NextIdentityForCommand) SetResponse(response []byte, fromCache bool) error
• type NoLeaderError
  • func (e *NoLeaderError) Error() string
  • func (e *NoLeaderError) WrappedError() error
• type NodeID
• type NodeIsPassiveError
  • func (e *NodeIsPassiveError) Error() string
  • func (e *NodeIsPassiveError) WrappedError() error
• type NodeSelector
  • func NewNodeSelector(t *Topology) *NodeSelector
  • func (s *NodeSelector) Close()
• type NodeSelectorState
  • func NewNodeSelectorState(topology *Topology) *NodeSelectorState
• type NodeStatus
  • func NewNodeStatus(requestExecutor *RequestExecutor, nodeIndex int, node *ServerNode) *NodeStatus
  • func (s *NodeStatus) Close()
• type NonUniqueObjectError
  • func (e *NonUniqueObjectError) Error() string
  • func (e *NonUniqueObjectError) WrappedError() error
• type NotImplementedError
  • func (e *NotImplementedError) Error() string
  • func (e *NotImplementedError) WrappedError() error
• type Operation
  • func NewOperation(requestExecutor *RequestExecutor, changes func() *DatabaseChanges, ...) *Operation
  • func NewServerWideOperation(requestExecutor *RequestExecutor, conventions *DocumentConventions, id int64) *Operation
  • func (o *Operation) GetID() int64
  • func (o *Operation) WaitForCompletion() error
• type OperationCancelledError
  • func (e *OperationCancelledError) Error() string
  • func (e *OperationCancelledError) WrappedError() error
• type OperationExceptionResult
• type OperationExecutor
  • func NewOperationExecutor(store *DocumentStore, databaseName string) *OperationExecutor
  • func (e *OperationExecutor) ForDatabase(databaseName string) *OperationExecutor
  • func (e *OperationExecutor) Send(operation IOperation, sessionInfo *SessionInfo) error
  • func (e *OperationExecutor) SendAsync(operation IOperation, sessionInfo *SessionInfo) (*Operation, error)
  • func (e *OperationExecutor) SendPatchOperation(operation *PatchOperation, sessionInfo *SessionInfo) (*PatchOperationResult, error)
• type OperationIDResult
• type OperationStatusChange
• type OrderingType
• type Parameters
• type PatchByQueryCommand
  • func NewPatchByQueryCommand(conventions *DocumentConventions, queryToUpdate *IndexQuery, ...) (*PatchByQueryCommand, error)
  • func (c *PatchByQueryCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *PatchByQueryCommand) SetResponse(response []byte, fromCache bool) error
• type PatchByQueryOperation
  • func NewPatchByQueryOperation(queryToUpdate string) *PatchByQueryOperation
  • func (o *PatchByQueryOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)
• type PatchCommand
  • func NewPatchCommand(conventions *DocumentConventions, id string, changeVector *string, ...) (*PatchCommand, error)
  • func (c *PatchCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *PatchCommand) SetResponse(response []byte, fromCache bool) error
• type PatchCommandData
• type PatchOperation
  • func NewPatchOperation(id string, changeVector *string, patch *PatchRequest, ...) (*PatchOperation, error)
  • func (o *PatchOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)
• type PatchOperationPayload
• type PatchOperationResult
  • func (r *PatchOperationResult) GetResult(result interface{}) error
• type PatchRequest
  • func (r *PatchRequest) Serialize() map[string]interface{}
• type PatchResult
• type PatchStatus
• type PointField
  • func NewPointField(latitude string, longitude string) *PointField
  • func (f *PointField) ToField(ensureValidFieldName func(string, bool) (string, error)) (string, error)
• type PutAttachmentCommand
  • func NewPutAttachmentCommand(documentID string, name string, stream io.Reader, contentType string, ...) (*PutAttachmentCommand, error)
  • func (c *PutAttachmentCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *PutAttachmentCommand) SetResponse(response []byte, fromCache bool) error
• type PutAttachmentCommandData
  • func NewPutAttachmentCommandData(documentID string, name string, stream io.Reader, contentType string, ...) (*PutAttachmentCommandData, error)
  • func (d *PutAttachmentCommandData) GetContentType() string
• type PutAttachmentOperation
  • func NewPutAttachmentOperation(documentID string, name string, stream io.Reader, contentType string, ...) *PutAttachmentOperation
  • func (o *PutAttachmentOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)
• type PutClientConfigurationCommand
  • func NewPutClientConfigurationCommand(conventions *DocumentConventions, configuration *ClientConfiguration) (*PutClientConfigurationCommand, error)
  • func (c *PutClientConfigurationCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type PutClientConfigurationOperation
  • func NewPutClientConfigurationOperation(configuration *ClientConfiguration) (*PutClientConfigurationOperation, error)
  • func (o *PutClientConfigurationOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type PutCommandDataWithJSON
• type PutCompareExchangeValueCommand
  • func NewPutCompareExchangeValueCommand(key string, value interface{}, index int64, conventions *DocumentConventions) (*PutCompareExchangeValueCommand, error)
  • func (c *PutCompareExchangeValueCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *PutCompareExchangeValueCommand) SetResponse(response []byte, fromCache bool) error
• type PutCompareExchangeValueOperation
  • func NewPutCompareExchangeValueOperation(key string, value interface{}, index int64) (*PutCompareExchangeValueOperation, error)
  • func (o *PutCompareExchangeValueOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)
• type PutConnectionStringCommand
  • func NewPutConnectionStringCommand(connectionString interface{}) *PutConnectionStringCommand
  • func (c *PutConnectionStringCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *PutConnectionStringCommand) SetResponse(response []byte, fromCache bool) error
• type PutConnectionStringOperation
  • func NewPutConnectionStringOperation(connectionString interface{}) *PutConnectionStringOperation
  • func (o *PutConnectionStringOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type PutConnectionStringResult
• type PutDocumentCommand
  • func NewPutDocumentCommand(id string, changeVector *string, document map[string]interface{}) *PutDocumentCommand
  • func (c *PutDocumentCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *PutDocumentCommand) SetResponse(response []byte, fromCache bool) error
• type PutIndexResult
• type PutIndexesCommand
  • func NewPutIndexesCommand(conventions *DocumentConventions, indexesToAdd []*IndexDefinition) (*PutIndexesCommand, error)
  • func (c *PutIndexesCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *PutIndexesCommand) SetResponse(response []byte, fromCache bool) error
• type PutIndexesOperation
  • func NewPutIndexesOperation(indexToAdd ...*IndexDefinition) *PutIndexesOperation
  • func (o *PutIndexesOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type PutIndexesResponse
• type PutResult
• type QueryCommand
  • func NewQueryCommand(conventions *DocumentConventions, indexQuery *IndexQuery, metadataOnly bool, ...) (*QueryCommand, error)
  • func (c *QueryCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *QueryCommand) SetResponse(response []byte, fromCache bool) error
• type QueryData
• type QueryOperationOptions
• type QueryOperator
• type QueryResult
• type QueryStatistics
  • func NewQueryStatistics() *QueryStatistics
  • func (s *QueryStatistics) UpdateQueryStats(qr *QueryResult)
• type QueryStreamCommand
  • func NewQueryStreamCommand(conventions *DocumentConventions, indexQuery *IndexQuery) *QueryStreamCommand
  • func (c *QueryStreamCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type RaftCommandBase
  • func (cmd *RaftCommandBase) RaftUniqueRequestId() (string, error)
• type RangeBuilder
  • func NewRangeBuilder(path string) *RangeBuilder
  • func (b *RangeBuilder) Err() error
  • func (b *RangeBuilder) GetStringRepresentation(addQueryParameter func(interface{}) string) (string, error)
  • func (b *RangeBuilder) IsGreaterThan(value interface{}) *RangeBuilder
  • func (b *RangeBuilder) IsGreaterThanOrEqualTo(value interface{}) *RangeBuilder
  • func (b *RangeBuilder) IsLessThan(value interface{}) *RangeBuilder
  • func (b *RangeBuilder) IsLessThanOrEqualTo(value interface{}) *RangeBuilder
• type RangeFacet
  • func NewRangeFacet(parent FacetBase) *RangeFacet
  • func (f *RangeFacet) ToFacetToken(addQueryParameter func(interface{}) string) (*facetToken, error)
• type RangeValue
  • func NewRangeValue(min int64, max int64) *RangeValue
• type RavenCommand
• type RavenCommandBase
  • func NewRavenCommandBase() RavenCommandBase
  • func (c *RavenCommandBase) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *RavenCommandBase) GetBase() *RavenCommandBase
  • func (c *RavenCommandBase) Send(client *http.Client, req *http.Request) (*http.Response, error)
  • func (c *RavenCommandBase) SetResponse(response []byte, fromCache bool) error
  • func (c *RavenCommandBase) SetResponseRaw(response *http.Response, stream io.Reader) error
• type RavenCommandResponseType
• type RavenConnectionString
  • func NewRavenConnectionString() *RavenConnectionString
• type RavenError
  • func (e *RavenError) Error() string
  • func (e *RavenError) WrappedError() error
• type RawDocumentQuery
  • func (q *RawDocumentQuery) AddAfterQueryExecutedListener(action func(*QueryResult)) int
  • func (q *RawDocumentQuery) AddAfterStreamExecutedListener(action func(map[string]interface{})) int
  • func (q *RawDocumentQuery) AddBeforeQueryExecutedListener(action func(*IndexQuery)) int
  • func (q *RawDocumentQuery) AddParameter(name string, value interface{}) *RawDocumentQuery
  • func (q RawDocumentQuery) Any() (bool, error)
  • func (q RawDocumentQuery) Count() (int, error)
  • func (q RawDocumentQuery) CountLazily() (*Lazy, error)
  • func (q RawDocumentQuery) Err() error
  • func (q RawDocumentQuery) First(result interface{}) error
  • func (q RawDocumentQuery) GetIndexQuery() (*IndexQuery, error)
  • func (q RawDocumentQuery) GetResults(results interface{}) error
  • func (q RawDocumentQuery) Lazily() (*Lazy, error)
  • func (q *RawDocumentQuery) NoCaching() *RawDocumentQuery
  • func (q *RawDocumentQuery) NoTracking() *RawDocumentQuery
  • func (q *RawDocumentQuery) RemoveAfterQueryExecutedListener(idx int) *RawDocumentQuery
  • func (q *RawDocumentQuery) RemoveAfterStreamExecutedListener(idx int) *RawDocumentQuery
  • func (q *RawDocumentQuery) RemoveBeforeQueryExecutedListener(idx int) *RawDocumentQuery
  • func (q RawDocumentQuery) Single(result interface{}) error
  • func (q *RawDocumentQuery) Skip(count int) *RawDocumentQuery
  • func (q *RawDocumentQuery) Statistics(stats **QueryStatistics) *RawDocumentQuery
  • func (q *RawDocumentQuery) Take(count int) *RawDocumentQuery
  • func (q *RawDocumentQuery) UsingDefaultOperator(queryOperator QueryOperator) *RawDocumentQuery
  • func (q *RawDocumentQuery) WaitForNonStaleResults() *RawDocumentQuery
  • func (q *RawDocumentQuery) WaitForNonStaleResultsWithTimeout(waitTimeout time.Duration) *RawDocumentQuery
• type ReadBalanceBehavior
• type RemoveCompareExchangeValueCommand
  • func NewRemoveCompareExchangeValueCommand(clazz reflect.Type, key string, index int64, conventions *DocumentConventions) (*RemoveCompareExchangeValueCommand, error)
  • func (c *RemoveCompareExchangeValueCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *RemoveCompareExchangeValueCommand) SetResponse(response []byte, fromCache bool) error
• type ReplicationNode
• type ReplicationWaitOptsBuilder
  • func (b *ReplicationWaitOptsBuilder) Majority(waitForMajority bool) *ReplicationWaitOptsBuilder
  • func (b *ReplicationWaitOptsBuilder) NumberOfReplicas(replicas int) *ReplicationWaitOptsBuilder
  • func (b *ReplicationWaitOptsBuilder) ThrowOnTimeout(shouldThrow bool) *ReplicationWaitOptsBuilder
  • func (b *ReplicationWaitOptsBuilder) WithTimeout(timeout time.Duration) *ReplicationWaitOptsBuilder
• type RequestExecutor
  • func ClusterRequestExecutorCreate(initialUrls []string, certificate *tls.Certificate, ...) *RequestExecutor
  • func ClusterRequestExecutorCreateForSingleNode(url string, certificate *tls.Certificate, trustStore *x509.Certificate, ...) *RequestExecutor
  • func NewClusterRequestExecutor(certificate *tls.Certificate, trustStore *x509.Certificate, ...) *RequestExecutor
  • func NewRequestExecutor(databaseName string, certificate *tls.Certificate, ...) *RequestExecutor
  • func RequestExecutorCreate(initialUrls []string, databaseName string, certificate *tls.Certificate, ...) *RequestExecutor
  • func RequestExecutorCreateForSingleNodeWithConfigurationUpdates(url string, databaseName string, certificate *tls.Certificate, ...) *RequestExecutor
  • func RequestExecutorCreateForSingleNodeWithoutConfigurationUpdates(url string, databaseName string, certificate *tls.Certificate, ...) *RequestExecutor
  • func (re *RequestExecutor) Close()
  • func (re *RequestExecutor) Execute(chosenNode *ServerNode, nodeIndex int, command RavenCommand, shouldRetry bool, ...) error
  • func (re *RequestExecutor) ExecuteCommand(command RavenCommand, sessionInfo *SessionInfo) error
  • func (re *RequestExecutor) GetConventions() *DocumentConventions
  • func (re *RequestExecutor) GetHTTPClient() (*http.Client, error)
  • func (re *RequestExecutor) GetTopology() *Topology
  • func (re *RequestExecutor) GetTopologyNodes() []*ServerNode
  • func (re *RequestExecutor) GetURL() (string, error)
  • func (re *RequestExecutor) MakeCluster()
  • func (re *RequestExecutor) UpdateTopologyAsync(node *ServerNode, timeout int) chan *clusterUpdateAsyncResult
• type ResetIndexCommand
  • func NewResetIndexCommand(indexName string) (*ResetIndexCommand, error)
  • func (c *ResetIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type ResetIndexOperation
  • func NewResetIndexOperation(indexName string) (*ResetIndexOperation, error)
  • func (o *ResetIndexOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type ResponseTimeInformation
• type ResponseTimeItem
• type RestoreCaching
  • func (r *RestoreCaching) Close() error
• type Revision
• type RevisionsCollectionConfiguration
• type RevisionsConfiguration
• type RevisionsDisabledError
  • func (e *RevisionsDisabledError) Error() string
  • func (e *RevisionsDisabledError) WrappedError() error
• type RevisionsSessionOperations
• type RouteNotFoundError
  • func (e *RouteNotFoundError) Error() string
  • func (e *RouteNotFoundError) WrappedError() error
• type RuntimeError
  • func (e *RuntimeError) Error() string
  • func (e *RuntimeError) WrappedError() error
• type ScriptResolver
• type SearchOperator
• type SecurityError
  • func (e *SecurityError) Error() string
  • func (e *SecurityError) WrappedError() error
• type SeedIdentityForCommand
  • func NewSeedIdentityForCommand(id string, value int64, forced bool) (*SeedIdentityForCommand, error)
  • func (c *SeedIdentityForCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *SeedIdentityForCommand) SetResponse(response []byte, fromCache bool) error
• type Semaphore
  • func NewSemaphore(cap int) *Semaphore
• type ServerLoadFailureError
  • func (e *ServerLoadFailureError) Error() string
  • func (e *ServerLoadFailureError) WrappedError() error
• type ServerNode
  • func NewServerNode() *ServerNode
• type ServerOperationExecutor
  • func NewServerOperationExecutor(store *DocumentStore) *ServerOperationExecutor
  • func (e *ServerOperationExecutor) Close()
  • func (e *ServerOperationExecutor) Send(operation IServerOperation) error
  • func (e *ServerOperationExecutor) SendAsync(operation IServerOperation) (*Operation, error)
• type SessionCreatedEventArgs
• type SessionInfo
• type SessionOptions
• type SetIndexesLockCommand
  • func NewSetIndexesLockCommand(conventions *DocumentConventions, parameters *SetIndexesLockParameters) (*SetIndexesLockCommand, error)
  • func (c *SetIndexesLockCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type SetIndexesLockOperation
  • func NewSetIndexesLockOperation(indexName string, mode IndexLockMode) (*SetIndexesLockOperation, error)
  • func NewSetIndexesLockOperationWithParameters(parameters *SetIndexesLockParameters) (*SetIndexesLockOperation, error)
  • func (o *SetIndexesLockOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type SetIndexesLockParameters
• type SetIndexesPriorityCommand
  • func NewSetIndexesPriorityCommand(conventions *DocumentConventions, parameters *SetIndexesPriorityParameters) (*SetIndexesPriorityCommand, error)
  • func (c *SetIndexesPriorityCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type SetIndexesPriorityOperation
  • func NewSetIndexesPriorityOperation(indexName string, priority IndexPriority) (*SetIndexesPriorityOperation, error)
  • func (o *SetIndexesPriorityOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type SetIndexesPriorityParameters
• type Size
• type SpatialBounds
  • func NewSpatialBounds(minX float64, minY float64, maxX float64, maxY float64) *SpatialBounds
• type SpatialCriteria
• type SpatialCriteriaCommon
  • func NewSpatialCriteria(relation SpatialRelation, distanceErrorPct float64) SpatialCriteriaCommon
• type SpatialCriteriaFactory
  • func NewSpatialCriteriaFactory() *SpatialCriteriaFactory
  • func (f *SpatialCriteriaFactory) Contains(shapeWkt string) *WktCriteria
  • func (f *SpatialCriteriaFactory) ContainsWithError(shapeWkt string, distErrorPercent float64) *WktCriteria
  • func (f *SpatialCriteriaFactory) Disjoint(shapeWkt string) *WktCriteria
  • func (f *SpatialCriteriaFactory) DisjointWithError(shapeWkt string, distErrorPercent float64) *WktCriteria
  • func (f *SpatialCriteriaFactory) Intersects(shapeWkt string) *WktCriteria
  • func (f *SpatialCriteriaFactory) IntersectsWithError(shapeWkt string, distErrorPercent float64) *WktCriteria
  • func (f *SpatialCriteriaFactory) RelatesToShape(shapeWkt string, relation SpatialRelation) *WktCriteria
  • func (f *SpatialCriteriaFactory) RelatesToShapeWithError(shapeWkt string, relation SpatialRelation, distErrorPercent float64) *WktCriteria
  • func (f *SpatialCriteriaFactory) Within(shapeWkt string) *WktCriteria
  • func (f *SpatialCriteriaFactory) WithinRadius(radius float64, latitude float64, longitude float64) *CircleCriteria
  • func (f *SpatialCriteriaFactory) WithinRadiusWithUnits(radius float64, latitude float64, longitude float64, radiusUnits SpatialUnits) *CircleCriteria
  • func (f *SpatialCriteriaFactory) WithinRadiusWithUnitsAndError(radius float64, latitude float64, longitude float64, radiusUnits SpatialUnits, ...) *CircleCriteria
  • func (f *SpatialCriteriaFactory) WithinWithError(shapeWkt string, distErrorPercent float64) *WktCriteria
• type SpatialFieldType
• type SpatialOptions
  • func NewCartesianBoundingBoxIndex() *SpatialOptions
  • func NewCartesianQuadPrefixTreeIndex(maxTreeLevel int, bounds *SpatialBounds) *SpatialOptions
  • func NewGeographyBoundingBoxIndexWithRadius(circleRadiusUnits SpatialUnits) *SpatialOptions
  • func NewGeographyDefaultOptions() *SpatialOptions
  • func NewGeographyDefaultOptionsWithRadius(circleRadiusUnits SpatialUnits) *SpatialOptions
  • func NewGeographyGeohashPrefixTreeIndex(maxTreeLevel int) *SpatialOptions
  • func NewGeographyGeohashPrefixTreeIndexWithRadius(maxTreeLevel int, circleRadiusUnits SpatialUnits) *SpatialOptions
  • func NewGeographyQuadPrefixTreeIndex(maxTreeLevel int) *SpatialOptions
  • func NewGeographyQuadPrefixTreeIndexWithRadius(maxTreeLevel int, circleRadiusUnits SpatialUnits) *SpatialOptions
  • func NewGeograpyboundingBoxIndex() *SpatialOptions
  • func NewSpatialOptions() *SpatialOptions
• type SpatialRelation
• type SpatialSearchStrategy
• type SpatialUnits
• type StartIndexCommand
  • func NewStartIndexCommand(indexName string) (*StartIndexCommand, error)
  • func (c *StartIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type StartIndexOperation
  • func NewStartIndexOperation(indexName string) (*StartIndexOperation, error)
  • func (o *StartIndexOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type StartIndexingCommand
  • func NewStartIndexingCommand() *StartIndexingCommand
  • func (c *StartIndexingCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type StartIndexingOperation
  • func NewStartIndexingOperation() *StartIndexingOperation
  • func (o *StartIndexingOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type StartsWithArgs
• type StopIndexCommand
  • func NewStopIndexCommand(indexName string) (*StopIndexCommand, error)
  • func (c *StopIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type StopIndexOperation
  • func NewStopIndexOperation(indexName string) (*StopIndexOperation, error)
  • func (o *StopIndexOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type StopIndexingCommand
  • func NewStopIndexingCommand() *StopIndexingCommand
  • func (c *StopIndexingCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type StopIndexingOperation
  • func NewStopIndexingOperation() *StopIndexingOperation
  • func (o *StopIndexingOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type StreamCommand
  • func NewStreamCommand(url string) *StreamCommand
  • func (c *StreamCommand) CreateRequest(node *ServerNode) (*http.Request, error)
• type StreamIterator
  • func (i *StreamIterator) Close() error
  • func (i *StreamIterator) Next(v interface{}) (*StreamResult, error)
• type StreamOperation
  • func NewStreamOperation(session *InMemoryDocumentSessionOperations, statistics *StreamQueryStatistics) *StreamOperation
• type StreamQueryStatistics
• type StreamResult
• type StreamResultResponse
• type StringDistanceTypes
• type SubscriberErrorError
  • func (e *SubscriberErrorError) Error() string
  • func (e *SubscriberErrorError) WrappedError() error
• type SubscriptionBatch
  • func (b *SubscriptionBatch) OpenSession() (*DocumentSession, error)
• type SubscriptionBatchItem
  • func (i *SubscriptionBatchItem) GetMetadata() *MetadataAsDictionary
  • func (i *SubscriptionBatchItem) GetResult(result interface{}) error
• type SubscriptionChangeVectorUpdateConcurrencyError
  • func (e *SubscriptionChangeVectorUpdateConcurrencyError) Error() string
  • func (e *SubscriptionChangeVectorUpdateConcurrencyError) WrappedError() error
• type SubscriptionClientMessageType
• type SubscriptionClosedError
  • func (e *SubscriptionClosedError) Error() string
  • func (e *SubscriptionClosedError) WrappedError() error
• type SubscriptionConnectionClientMessage
• type SubscriptionCreationOptions
• type SubscriptionDoesNotBelongToNodeError
  • func (e *SubscriptionDoesNotBelongToNodeError) Error() string
  • func (e *SubscriptionDoesNotBelongToNodeError) WrappedError() error
• type SubscriptionDoesNotExistError
  • func (e *SubscriptionDoesNotExistError) Error() string
  • func (e *SubscriptionDoesNotExistError) WrappedError() error
• type SubscriptionError
  • func (e *SubscriptionError) Error() string
  • func (e *SubscriptionError) WrappedError() error
• type SubscriptionInUseError
  • func (e *SubscriptionInUseError) Error() string
  • func (e *SubscriptionInUseError) WrappedError() error
• type SubscriptionInvalidStateError
  • func (e *SubscriptionInvalidStateError) Error() string
  • func (e *SubscriptionInvalidStateError) WrappedError() error
• type SubscriptionOpeningStrategy
• type SubscriptionState
• type SubscriptionStateWithNodeDetails
• type SubscriptionTryout
• type SubscriptionWorker
  • func NewSubscriptionWorker(clazz reflect.Type, options *SubscriptionWorkerOptions, withRevisions bool, ...) (*SubscriptionWorker, error)
  • func (w *SubscriptionWorker) AddAfterAcknowledgmentListener(handler func(*SubscriptionBatch)) int
  • func (w *SubscriptionWorker) AddOnSubscriptionConnectionRetry(handler func(error)) int
  • func (w *SubscriptionWorker) Cancel()
  • func (w *SubscriptionWorker) Close() error
  • func (w *SubscriptionWorker) Err() error
  • func (w *SubscriptionWorker) IsDone() bool
  • func (w *SubscriptionWorker) RemoveAfterAcknowledgmentListener(id int)
  • func (w *SubscriptionWorker) RemoveOnSubscriptionConnectionRetry(id int)
  • func (w *SubscriptionWorker) Run(cb func(*SubscriptionBatch) error) error
  • func (w *SubscriptionWorker) WaitUntilFinished(timeout time.Duration) error
• type SubscriptionWorkerOptions
  • func NewSubscriptionWorkerOptions(subscriptionName string) *SubscriptionWorkerOptions
• type SuggestionBase
• type SuggestionBuilder
  • func NewSuggestionBuilder() *SuggestionBuilder
  • func (b *SuggestionBuilder) ByField(fieldName string, term string, terms ...string) *SuggestionBuilder
  • func (b *SuggestionBuilder) GetSuggestion() SuggestionBase
  • func (b *SuggestionBuilder) WithOptions(options *SuggestionOptions) *SuggestionBuilder
• type SuggestionCommon
  • func (s *SuggestionCommon) SetOptions(options *SuggestionOptions)
• type SuggestionDocumentQuery
  • func (q *SuggestionDocumentQuery) Execute() (map[string]*SuggestionResult, error)
  • func (q *SuggestionDocumentQuery) ExecuteLazy() (*Lazy, error)
  • func (q *SuggestionDocumentQuery) InvokeAfterQueryExecuted(result *QueryResult)
• type SuggestionOptions
  • func NewSuggestionOptions() *SuggestionOptions
• type SuggestionResult
• type SuggestionSortMode
• type SuggestionWithTerm
  • func NewSuggestionWithTerm(field string) *SuggestionWithTerm
• type SuggestionWithTerms
  • func NewSuggestionWithTerms(field string) *SuggestionWithTerms
• type TcpConnectionInfo
• type TermsQueryResult
• type Time
  • func (t Time) Format() string
  • func (t Time) MarshalJSON() ([]byte, error)
  • func (t *Time) UnmarshalJSON(d []byte) error
• type TimeoutError
  • func NewTimeoutError(format string, args ...interface{}) *TimeoutError
  • func (e *TimeoutError) Error() string
  • func (e *TimeoutError) WrappedError() error
• type Topology
• type UUID
  • func NewUUID() *UUID
  • func (u *UUID) Hex() string
  • func (u *UUID) String() string
• type UnsuccessfulRequestError
  • func (e *UnsuccessfulRequestError) Error() string
  • func (e *UnsuccessfulRequestError) WrappedError() error
• type UnsupportedOperationError
  • func (e *UnsupportedOperationError) Error() string
  • func (e *UnsupportedOperationError) WrappedError() error
• type UpdateExternalReplicationCommand
  • func NewUpdateExternalReplicationCommand(newWatcher *ExternalReplication) *UpdateExternalReplicationCommand
  • func (c *UpdateExternalReplicationCommand) CreateRequest(node *ServerNode) (*http.Request, error)
  • func (c *UpdateExternalReplicationCommand) SetResponse(response []byte, fromCache bool) error
• type UpdateExternalReplicationOperation
  • func NewUpdateExternalReplicationOperation(newWatcher *ExternalReplication) *UpdateExternalReplicationOperation
  • func (o *UpdateExternalReplicationOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)
• type WktCriteria
  • func NewWktCriteria(shapeWkt string, relation SpatialRelation, distErrorPercent float64) *WktCriteria
  • func (c *WktCriteria) GetShapeToken(addQueryParameter func(interface{}) string) *shapeToken
  • func (c *WktCriteria) ToQueryToken(fieldName string, addQueryParameter func(interface{}) string) queryToken
• type WktField
  • func NewWktField(wkt string) *WktField
  • func (f *WktField) ToField(ensureValidFieldName func(string, bool) (string, error)) (string, error)

Constants

const (
	AttachmentDocument = "Document"
	AttachmentRevision = "Revision"
)

const (
	//CommandNone                = "NONE"
	CommandPut                 = "PUT"
	CommandPatch               = "PATCH"
	CommandDelete              = "DELETE"
	CommandAttachmentPut       = "ATTACHMENT_PUT"
	CommandAttachmentDelete    = "ATTACHMENT_DELETE"
	CommandClientAnyCommand    = "CLIENT_ANY_COMMAND"
	CommandClientNotAttachment = "CLIENT_NOT_ATTACHMENT"
)

Note: this is enum in Java but those are serialized to json as strings so making them strings is better in Go

const (
	ConnectionStringTypeNone  = "None"
	ConnectionStringTypeRaven = "Raven"
	ConnectionStringTypeSQL   = "Sql"
)

const (
	// Name of struct field that represents identity property
	IdentityProperty = "ID"

	MetadataCollection             = "@collection"
	MetadataProjection             = "@projection"
	MetadataKey                    = "@metadata"
	MetadataID                     = "@id"
	MetadataConflict               = "@conflict"
	MetadataIDProperty             = "Id"
	MetadataFlags                  = "@flags"
	MetadataAttachments            = "@attachments"
	MetadataInddexScore            = "@index-score"
	MetadataLastModified           = "@last-modified"
	MetadataRavenGoType            = "Raven-Go-Type"
	MetadataChangeVector           = "@change-vector"
	MetadataExpires                = "@expires"
	MetadataAllDocumentsCollection = "@all_docs"

	IndexingSideBySideIndexNamePrefix = "ReplacementOf/"
	IndexingFieldNameDocumentID       = "id()"
	IndexingFieldNameReduceKeyHash    = "hash(key())"
	IndexingFieldNameReduceKeyValue   = "key()"
	IndexingFieldAllFields            = "__all_fields"
	IndexingFieldsNameSpatialShare    = "spatial(shape)"
	//TBD CUSTOM_SORT_FIELD_NAME = "__customSort";
	IndexingSpatialDefaultDistnaceErrorPct = 0.025
)

const (
	DatabasePromotionStatusWaitingForFirstPromotion = "WaitingForFirstPromotion"
	DatabasePromotionStatusNotResponding            = "NotResponding"
	DatabasePromotionStatusIndexNotUpToDate         = "IndexNotUpToDate"
	DatabasePromotionStatusChangeVectorNotMerged    = "ChangeVectorNotMerged"
	DatabasePromotionStatusWaitingForResponse       = "WaitingForResponse"
	DatabasePromotionStatusOk                       = "Ok"
)

const (
	DocumentChangeNone     = "None"
	DocumentChangePut      = "Put"
	DocumentChangeDelete   = "Delete"
	DocumentChangeConflict = "Conflict"
	DocumentChangeCommon   = "Common"
)

const (
	FacetAggregationNone    = "None"
	FacetAggregationMax     = "Max"
	FacetAggregationMin     = "Min"
	FacetAggregationAverage = "Average"
	FacetAggregationSum     = "Sum"
)

const (
	FacetTermSortModeValueAsc  = "ValueAsc"
	FacetTermSortModeValueDesc = "ValueDesc"
	FacetTermSortModeCountAsc  = "CountAsc"
	FacetTermSortModeCountDesc = "CountDesc"
)

const (
	FieldIndexingNo      = "No"
	FieldIndexingSearch  = "Search"
	FieldIndexingExact   = "Exact"
	FieldIndexingDefault = "Default"
)

const (
	FieldStorageYes = "Yes"
	FieldStorageNo  = "No"
)

const (
	FieldTermVectorNo                      = "No"
	FieldTermVectorYes                     = "Yes"
	FieldTermVectorWithPositions           = "WithPositions"
	FieldTermVectorWithOffsets             = "WithOffsets"
	FieldTermVectorWithPositionsAndOffsets = "WithPositionsAndOffsets"
)

const (
	GroupByMethodNone  = "None"
	GroupByMethodArray = "Array"
)

const (
	IndexChangeNone                   = "None"
	IndexChangeBatchCompleted         = "BatchCompleted"
	IndexChangeIndexAdded             = "IndexAdded"
	IndexChangeIndexRemoved           = "IndexRemoved"
	IndexChangeIndexDemotedToIdle     = "IndexDemotedToIdle"
	IndexChangeIndexPromotedFromIdle  = "IndexPromotedFromIdle"
	IndexChangeIndexDemotedToDisabled = "IndexDemotedToDisabled"
	IndexChangeIndexMarkedAsErrored   = "IndexMarkedAsErrored"
	IndexChangeSideBySideReplace      = "SideBySideReplace"
	IndexChangeRenamed                = "Renamed"
	IndexChangeIndexPaused            = "IndexPaused"
	IndexChangeLockModeChanged        = "LockModeChanged"
	IndexChangePriorityChanged        = "PriorityChanged"
)

const (
	IndexLockModeUnlock       = "Unlock"
	IndexLockModeLockedIgnore = "LockedIgnore"
	IndexLockModeLockedError  = "LockedError"
)

const (
	IndexPriorityLow    = "Low"
	IndexPriorityNormal = "Normal"
	IndexPriorityHigh   = "High"
)

const (
	IndexRunningStatusRunning  = "Running"
	IndexRunningStatusPaused   = "Paused"
	IndexRunningStatusDisabled = "Disabled"
)

const (
	IndexStateNormal   = "Normal"
	IndexStateDisabled = "Disabled"
	IndexStateIdle     = "Idle"
	IndexStateError    = "Error"
)

const (
	IndexTypeNone          = "None"
	IndexTypeAutoMap       = "AutoMap"
	IndexTypeAutoMapReduce = "AutoMapReduce"
	IndexTypeMap           = "Map"
	IndexTypeMapReduce     = "MapReduce"
	IndexTypeFaulty        = "Faulty"
)

const (
	MoreLikeThisOptionsDefaultMaximumNumberOfTokensParsed = 5000
	MoreLikeThisOptionsDefaultMinimumTermFrequency        = 2
	MoreLikeThisOptionsDefaultMinimumDocumentFrequency    = 5
	MoreLikeThisOptionsDefaultMaximumDocumentFrequence    = math.MaxInt32
	MoreLikeThisOptionsDefaultBoost                       = false
	MoreLikeThisOptionsDefaultBoostFactor                 = 1
	MoreLikeThisOptionsDefaultMinimumWordLength           = 0
	MoreLikeThisOptionsDefaultMaximumWordLength           = 0
	MoreLikeThisOptionsDefaultMaximumQueryTerms           = 25
)

const (
	OrderingTypeString       = "STRING"
	OrderingTypeLong         = "LONG"
	OrderingTypeDouble       = "DOUBLE"
	OrderingTypeAlphaNumeric = "ALPHA_NUMERIC"
)

const (
	PatchStatusDocumentDoesNotExist = "DocumentDoesNotExist"
	PatchStatusCreated              = "Created"
	PatchStatusPatched              = "Patched"
	PatchStatusSkipped              = "Skipped"
	PatchStatusNotModified          = "NotModified"
)

const (
	QueryOperatorAnd = "And"
	QueryOperatorOr  = "Or"
)

const (
	RavenCommandResponseTypeEmpty  = "EMPTY"
	RavenCommandResponseTypeObject = "OBJECT"
	RavenCommandResponseTypeRaw    = "RAW"
)

const (
	ReadBalanceBehaviorNone        = "None"
	ReadBalanceBehaviorRoundRobin  = "RoundRobin"
	ReadBalanceBehaviorFastestNode = "FastestNode"
)

const (
	ServerNodeRoleNone       = "None"
	ServerNodeRolePromotable = "Promotable"
	ServerNodeRoleMember     = "Member"
	ServerNodeRoleRehab      = "Rehab"
)

const (
	SpatialFieldGeography = "Geography"
	SpatialFieldCartesian = "Cartesian"
)

const (
	//about 4.78 meters at equator, should be good enough (see: http://unterbahn.com/2009/11/metric-dimensions-of-geohash-partitions-at-the-equator/)
	SpatialOptionsDefaultGeohashLevel = 9
	//about 4.78 meters at equator, should be good enough
	SpatialOptionsDefaultQuadTreeLevel = 23
)

const (
	SpatialRelationWithin     = "Within"
	SpatialRelationContains   = "Contains"
	SpatialRelationDisjoin    = "Disjoint"
	SpatialRelationIntersects = "Intersects"
)

const (
	SpatialSearchStrategyGeohashPrefixTree = "GeohashPrefixTree"
	SpatialSearchStrategyQuadPrefixTree    = "QuadPrefixTree"
	SpatialSearchStrategyBoundingBox       = "BoundingBox"
)

const (
	SpatialUnitsKilometers = "Kilometers"
	SpatialUnitsMiles      = "Miles"
)

const (
	StringDistanceNone        = "None"
	StringDistanceDefault     = "Default"
	StringDistanceLevenshtein = "Levenshtein"
	StringDistanceJaroWinkler = "JaroWinkler"
	StringDistanceNGram       = "NGram"
)

const (
	SubscriptionClientMessageNone                 = "None"
	SubscriptionClientMessageAcknowledge          = "Acknowledge"
	SubscriptionClientMessageDisposedNotification = "DisposedNotification"
)

const (
	// SubscriptionOpeningStrategyOpenIfFree:
	// The client will successfully open a subscription only if there isn't any other currently connected client.
	// Otherwise it will end up with SubscriptionInUseError
	SubscriptionOpeningStrategyOpenIfFree = "OpenIfFree"
	// SubscriptionOpeningStrategyTakeOver:
	// The connecting client will successfully open a subscription even if there is another active subscription's consumer.
	// If the new client takes over an existing client then the existing one will get a SubscriptionInUseException.
	//
	// The subscription will always be held by the last connected client.
	SubscriptionOpeningStrategyTakeOver = "TakeOver"
	// SubscriptionOpeningStrategyWaitForFree:
	// If the client currently cannot open the subscription because it is used by another client but it will wait for that client
	// to complete and keep attempting to gain the subscription
	SubscriptionOpeningStrategyWaitForFree = "WaitForFree"
)

const (
	SuggestionSortModeNone       = "None"
	SuggestionSortModePopularity = "Popularity"
)

const (
	MethodsTypeCmpXChg = "CmpXChg"
)

Variables

var (

	// HTTPClientPostProcessor allows to tweak http client after it has been created
	// this allows replacing Transport with a custom transport that does logging,
	// proxying or tweaks each http request
	HTTPClientPostProcessor func(*http.Client)

	// if true, adds lots of logging to track bugs in request executor
	DebugLogRequestExecutor bool = false
	DebugTopology           bool = false
)

var (
	SuggestionOptionsDefaultOptions  = NewSuggestionOptions()
	SuggestionOptionsDefaultAccuracy = float32(0.5)
	SuggestionOptionsDefaultPageSize = 15
	SuggestionOptionsDefaultDistance = StringDistanceLevenshtein
	SuggestionOptionsDefaultSortMode = SuggestionSortModePopularity
)

var (
	// DefaultFacetOptions are default facet options
	DefaultFacetOptions = &FacetOptions{}
)

var (
	// LogSubscriptions allows to monitor read/writes made by SubscriptionWorker to a tcp connection. For debugging.
	LogSubscriptionWorker func(op string, d []byte) = func(op string, d []byte) {

	}
)

var (
	// if true, does verbose logging.
	LogVerbose = false
)

Functions

func FieldsFor

func FieldsFor(s interface{}) []string

FieldsFor returns names of all fields for the value of a struct type. They can be used in e.g. DocumentQuery.SelectFields: fields := ravendb.FieldsFor(&MyType{}) q = q.SelectFields(fields...)

func GetCollectionNameDefault

func GetCollectionNameDefault(entityOrType interface{}) string

GetCollectionNameDefault is a default way of

func GetWrappedError

func GetWrappedError(err error) error

GetWrappedError returns an error wrapped by this error If no error is wrapped, returns nil

func IsPlural

func IsPlural(word string) bool

IsPlural retruns true if word is plural

func IsSingular

func IsSingular(word string) bool

IsSingular returns true if a word is singular

func NewHttpPost

func NewHttpPost(uri string, data []byte) (*http.Request, error)

func ParseTime

func ParseTime(s string) (time.Time, error)

ParseTime parses string time value returned by RavenDB server The value can't be parsed with a single string format

func Pluralize

func Pluralize(word string, count int, inclusive bool) string

Pluralize or singularize a word based on the passed in count.

func RoundToServerTime

func RoundToServerTime(t time.Time) time.Time

RoundToServerTime rounds t to the same precision as round-tripping to the server and back. Useful for comparing time.Time values for equality with values returned by the server

func ToPlural

func ToPlural(word string) string

ToPlural makes a pluralized version of a word

func ToSingular

func ToSingular(word string) string

ToSingular singularizes a word.

Types

type AdvancedSessionExtensionBase

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

AdvancedSessionExtensionBase implements common advanced session operations

func (*AdvancedSessionExtensionBase) Defer

func (e *AdvancedSessionExtensionBase) Defer(commands ...ICommandData)

Defer defers multiple commands to be executed on SaveChnages

type AdvancedSessionOperations

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

AdvancedSessionOperations exposes advanced session operations

func (*AdvancedSessionOperations) AddAfterSaveChangesListener

func (o *AdvancedSessionOperations) AddAfterSaveChangesListener(handler func(*AfterSaveChangesEventArgs)) int

func (*AdvancedSessionOperations) AddBeforeDeleteListener

func (o *AdvancedSessionOperations) AddBeforeDeleteListener(handler func(*BeforeDeleteEventArgs)) int

func (*AdvancedSessionOperations) AddBeforeQueryListener

func (o *AdvancedSessionOperations) AddBeforeQueryListener(handler func(*BeforeQueryEventArgs)) int

func (*AdvancedSessionOperations) AddBeforeStoreListener

func (o *AdvancedSessionOperations) AddBeforeStoreListener(handler func(*BeforeStoreEventArgs)) int

func (*AdvancedSessionOperations) Attachments

func (o *AdvancedSessionOperations) Attachments() *AttachmentsSessionOperations

func (*AdvancedSessionOperations) Clear

func (o *AdvancedSessionOperations) Clear()

func (*AdvancedSessionOperations) Defer

func (o *AdvancedSessionOperations) Defer(commands ...ICommandData)

func (*AdvancedSessionOperations) Eagerly

func (o *AdvancedSessionOperations) Eagerly() *EagerSessionOperations

func (*AdvancedSessionOperations) Evict

func (o *AdvancedSessionOperations) Evict(entity interface{}) error

func (*AdvancedSessionOperations) Exists

func (o *AdvancedSessionOperations) Exists(id string) (bool, error)

func (*AdvancedSessionOperations) GetChangeVectorFor

func (o *AdvancedSessionOperations) GetChangeVectorFor(instance interface{}) (*string, error)

func (*AdvancedSessionOperations) GetCurrentSessionNode

func (o *AdvancedSessionOperations) GetCurrentSessionNode() (*ServerNode, error)

func (*AdvancedSessionOperations) GetDocumentID

func (o *AdvancedSessionOperations) GetDocumentID(instance interface{}) string

func (*AdvancedSessionOperations) GetDocumentStore

func (o *AdvancedSessionOperations) GetDocumentStore() *DocumentStore

func (*AdvancedSessionOperations) GetLastModifiedFor

func (o *AdvancedSessionOperations) GetLastModifiedFor(instance interface{}) (*time.Time, error)

func (*AdvancedSessionOperations) GetMaxNumberOfRequestsPerSession

func (o *AdvancedSessionOperations) GetMaxNumberOfRequestsPerSession() int

func (*AdvancedSessionOperations) GetMetadataFor

func (o *AdvancedSessionOperations) GetMetadataFor(instance interface{}) (*MetadataAsDictionary, error)

func (*AdvancedSessionOperations) GetNumberOfRequests

func (o *AdvancedSessionOperations) GetNumberOfRequests() int

GetNumberOfRequests returns number of requests sent to the server

func (*AdvancedSessionOperations) GetRequestExecutor

func (o *AdvancedSessionOperations) GetRequestExecutor() *RequestExecutor

func (*AdvancedSessionOperations) HasChanged

func (o *AdvancedSessionOperations) HasChanged(entity interface{}) (bool, error)

func (*AdvancedSessionOperations) HasChanges

func (o *AdvancedSessionOperations) HasChanges() bool

func (*AdvancedSessionOperations) IgnoreChangesFor

func (o *AdvancedSessionOperations) IgnoreChangesFor(entity interface{}) error

func (*AdvancedSessionOperations) Increment

func (o *AdvancedSessionOperations) Increment(entity interface{}, path string, valueToAdd interface{}) error

func (*AdvancedSessionOperations) IncrementByID

func (o *AdvancedSessionOperations) IncrementByID(id string, path string, valueToAdd interface{}) error

func (*AdvancedSessionOperations) IsLoaded

func (o *AdvancedSessionOperations) IsLoaded(id string) bool

func (*AdvancedSessionOperations) Lazily

func (o *AdvancedSessionOperations) Lazily() *LazySessionOperations

func (*AdvancedSessionOperations) LoadIntoStream

func (o *AdvancedSessionOperations) LoadIntoStream(ids []string, output io.Writer) error

func (*AdvancedSessionOperations) LoadStartingWith

func (o *AdvancedSessionOperations) LoadStartingWith(results interface{}, args *StartsWithArgs) error

func (*AdvancedSessionOperations) LoadStartingWithIntoStream

func (o *AdvancedSessionOperations) LoadStartingWithIntoStream(output io.Writer, args *StartsWithArgs) error

func (*AdvancedSessionOperations) Patch

func (o *AdvancedSessionOperations) Patch(entity interface{}, path string, value interface{}) error

func (*AdvancedSessionOperations) PatchArray

func (o *AdvancedSessionOperations) PatchArray(entity interface{}, pathToArray string, arrayAdder func(*JavaScriptArray)) error

func (*AdvancedSessionOperations) PatchArrayByID

func (o *AdvancedSessionOperations) PatchArrayByID(id string, pathToArray string, arrayAdder func(*JavaScriptArray)) error

func (*AdvancedSessionOperations) PatchByID

func (o *AdvancedSessionOperations) PatchByID(id string, path string, value interface{}) error

func (*AdvancedSessionOperations) Query

func (o *AdvancedSessionOperations) Query(opts *DocumentQueryOptions) *DocumentQuery

func (*AdvancedSessionOperations) QueryCollection

func (o *AdvancedSessionOperations) QueryCollection(collectionName string) *DocumentQuery

func (*AdvancedSessionOperations) QueryCollectionForType

func (o *AdvancedSessionOperations) QueryCollectionForType(typ reflect.Type) *DocumentQuery

func (*AdvancedSessionOperations) QueryIndex

func (o *AdvancedSessionOperations) QueryIndex(indexName string) *DocumentQuery

func (*AdvancedSessionOperations) RawQuery

func (o *AdvancedSessionOperations) RawQuery(rawQuery string) *RawDocumentQuery

func (*AdvancedSessionOperations) Refresh

func (o *AdvancedSessionOperations) Refresh(entity interface{}) error

func (*AdvancedSessionOperations) RemoveAfterSaveChangesListener

func (o *AdvancedSessionOperations) RemoveAfterSaveChangesListener(handlerID int)

func (*AdvancedSessionOperations) RemoveBeforeDeleteListener

func (o *AdvancedSessionOperations) RemoveBeforeDeleteListener(handlerID int)

func (*AdvancedSessionOperations) RemoveBeforeQueryListener

func (o *AdvancedSessionOperations) RemoveBeforeQueryListener(handlerID int)

func (*AdvancedSessionOperations) RemoveBeforeStoreListener

func (o *AdvancedSessionOperations) RemoveBeforeStoreListener(handlerID int)

func (*AdvancedSessionOperations) Revisions

func (o *AdvancedSessionOperations) Revisions() *RevisionsSessionOperations

func (*AdvancedSessionOperations) SetMaxNumberOfRequestsPerSession

func (o *AdvancedSessionOperations) SetMaxNumberOfRequestsPerSession(n int)

func (*AdvancedSessionOperations) Stream

func (o *AdvancedSessionOperations) Stream(args *StartsWithArgs) (*StreamIterator, error)

func (*AdvancedSessionOperations) StreamQuery

func (o *AdvancedSessionOperations) StreamQuery(query *DocumentQuery, streamQueryStats *StreamQueryStatistics) (*StreamIterator, error)

func (*AdvancedSessionOperations) StreamQueryInto

func (o *AdvancedSessionOperations) StreamQueryInto(query *DocumentQuery, output io.Writer) error

func (*AdvancedSessionOperations) StreamRawQuery

func (o *AdvancedSessionOperations) StreamRawQuery(query *RawDocumentQuery, streamQueryStats *StreamQueryStatistics) (*StreamIterator, error)

func (*AdvancedSessionOperations) StreamRawQueryInto

func (o *AdvancedSessionOperations) StreamRawQueryInto(query *RawDocumentQuery, output io.Writer) error

func (*AdvancedSessionOperations) WaitForIndexesAfterSaveChanges

func (o *AdvancedSessionOperations) WaitForIndexesAfterSaveChanges(options func(*IndexesWaitOptsBuilder))

func (*AdvancedSessionOperations) WaitForReplicationAfterSaveChanges

func (o *AdvancedSessionOperations) WaitForReplicationAfterSaveChanges(options func(*ReplicationWaitOptsBuilder))

func (*AdvancedSessionOperations) WhatChanged

func (o *AdvancedSessionOperations) WhatChanged() (map[string][]*DocumentsChanges, error)

type AfterSaveChangesEventArgs

type AfterSaveChangesEventArgs struct {
	Session    *InMemoryDocumentSessionOperations
	DocumentID string
	Entity     interface{}
	// contains filtered or unexported fields
}

AfterSaveChangesEventArgs describes arguments for "after save changes" listener

func (*AfterSaveChangesEventArgs) GetDocumentMetadata

func (a *AfterSaveChangesEventArgs) GetDocumentMetadata() *MetadataAsDictionary

GetDocumentMetadata returns metadata for the entity represented by this event

type AggregationDocumentQuery

type AggregationDocumentQuery = aggregationQueryBase

Note: AggregationDocumentQuery is fused into AggregationQueryBase because in Java AggregationQueryBase calls functions implemented in AggregationDocumentQuery and that doesn't translate to Go's embedding

func (*AggregationDocumentQuery) AndAggregateByFacet

func (q *AggregationDocumentQuery) AndAggregateByFacet(facet FacetBase) *AggregationDocumentQuery

from AggregationDocumentQuery

func (*AggregationDocumentQuery) GetIndexQuery

func (q *AggregationDocumentQuery) GetIndexQuery() (*IndexQuery, error)

type AggressiveCacheOptions

type AggressiveCacheOptions struct {
	Duration time.Duration
}

TODO: should this be exported?

type AllTopologyNodesDownError

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

AllTopologyNodesDownError represents "all topology nodes are down" error

func (*AllTopologyNodesDownError) Error

func (e *AllTopologyNodesDownError) Error() string

Error makes it conform to error interface

func (*AllTopologyNodesDownError) WrappedError

func (e *AllTopologyNodesDownError) WrappedError() error

hackish way to get a wrapped error

type AttachmentDetails

type AttachmentDetails struct {
	AttachmentName
	ChangeVector *string `json:"ChangeVector"`
	DocumentID   string  `json:"DocumentId"`
}

AttachmentDetails represents details of an attachment

type AttachmentName

type AttachmentName struct {
	Name        string `json:"Name"`
	Hash        string `json:"Hash"`
	ContentType string `json:"ContentType"`
	Size        int64  `json:"Size"`
}

AttachmentName represents infor about an attachment

type AttachmentResult

type AttachmentResult struct {
	Data    io.Reader
	Details *AttachmentDetails
	// contains filtered or unexported fields
}

AttachmentResult represents an attachment

func (*AttachmentResult) Close

func (r *AttachmentResult) Close() error

Close closes the attachment

type AttachmentType

type AttachmentType = string

type AttachmentsSessionOperations

type AttachmentsSessionOperations = DocumentSessionAttachments

TODO: make a unique wrapper type

type AuthorizationError

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

AuthorizationError represents authorization error

func (*AuthorizationError) Error

func (e *AuthorizationError) Error() string

Error makes it conform to error interface

func (*AuthorizationError) WrappedError

func (e *AuthorizationError) WrappedError() error

hackish way to get a wrapped error

type BadRequestError

type BadRequestError struct {
	RavenError
}

BadRequestError maps to server's 400 Bad Request response This is additional information sent by the server

func (*BadRequestError) Error

func (e *BadRequestError) Error() string

Error makes it conform to error interface

func (*BadRequestError) WrappedError

func (e *BadRequestError) WrappedError() error

hackish way to get a wrapped error

type BadResponseError

type BadResponseError struct {
	RavenError
}

BadResponseError represents "bad response" error

func (*BadResponseError) Error

func (e *BadResponseError) Error() string

Error makes it conform to error interface

func (*BadResponseError) WrappedError

func (e *BadResponseError) WrappedError() error

hackish way to get a wrapped error

type BatchCommand

type BatchCommand struct {
	RavenCommandBase

	Result *JSONArrayResult
	// contains filtered or unexported fields
}

BatchCommand represents batch command

func (*BatchCommand) Close

func (c *BatchCommand) Close() error

func (*BatchCommand) CreateRequest

func (c *BatchCommand) CreateRequest(node *ServerNode) (*http.Request, error)

func (*BatchCommand) SetResponse

func (c *BatchCommand) SetResponse(response []byte, fromCache bool) error

type BatchOperation

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

BatchOperation represents a batch operation

type BatchOptions

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

BatchOptions describes options for batch operations

func NewBatchOptions

func NewBatchOptions() *BatchOptions

NewBatchOptions returns new BatchOptions

type BeforeDeleteEventArgs

type BeforeDeleteEventArgs struct {
	Session    *InMemoryDocumentSessionOperations
	DocumentID string
	Entity     interface{}
	// contains filtered or unexported fields
}

BeforeDeleteEventArgs describes arguments for "before delete" listener

func (*BeforeDeleteEventArgs) GetDocumentMetadata

func (a *BeforeDeleteEventArgs) GetDocumentMetadata() *MetadataAsDictionary

GetDocumentMetadata returns metadata for the entity being deleted

type BeforeQueryEventArgs

type BeforeQueryEventArgs struct {
	Session            *InMemoryDocumentSessionOperations
	QueryCustomization *DocumentQueryCustomization
}

BeforeQueryEventArgs describes arguments for "before query" event

type BeforeStoreEventArgs

type BeforeStoreEventArgs struct {
	Session    *InMemoryDocumentSessionOperations
	DocumentID string
	Entity     interface{}
	// contains filtered or unexported fields
}

BeforeStoreEventArgs describe arguments for "before store" listener

func (*BeforeStoreEventArgs) GetDocumentMetadata

func (a *BeforeStoreEventArgs) GetDocumentMetadata() *MetadataAsDictionary

GetDocumentMetadata returns metadata for entity represented by this event

type BulkInsertAbortedError

type BulkInsertAbortedError struct {
	RavenError
}

BulkInsertAbortedError represents "bulk insert aborted" error

func (*BulkInsertAbortedError) Error

func (e *BulkInsertAbortedError) Error() string

Error makes it conform to error interface

func (*BulkInsertAbortedError) WrappedError

func (e *BulkInsertAbortedError) WrappedError() error

hackish way to get a wrapped error

type BulkInsertCommand

type BulkInsertCommand struct {
	RavenCommandBase

	Result *http.Response
	// contains filtered or unexported fields
}

BulkInsertCommand describes build insert command

func NewBulkInsertCommand

func NewBulkInsertCommand(id int64, stream io.Reader, useCompression bool) *BulkInsertCommand

NewBulkInsertCommand returns new BulkInsertCommand

func (*BulkInsertCommand) CreateRequest

func (c *BulkInsertCommand) CreateRequest(node *ServerNode) (*http.Request, error)

func (*BulkInsertCommand) Send

func (c *BulkInsertCommand) Send(client *http.Client, req *http.Request) (*http.Response, error)

func (*BulkInsertCommand) SetResponse

func (c *BulkInsertCommand) SetResponse(response []byte, fromCache bool) error

type BulkInsertOperation

type BulkInsertOperation struct {
	Command *BulkInsertCommand
	// contains filtered or unexported fields
}

BulkInsertOperation represents bulk insert operation

func NewBulkInsertOperation

func NewBulkInsertOperation(database string, store *DocumentStore) *BulkInsertOperation

NewBulkInsertOperation returns new BulkInsertOperation

func (*BulkInsertOperation) Abort

func (o *BulkInsertOperation) Abort() error

Abort aborts insert operation

func (*BulkInsertOperation) Close

func (o *BulkInsertOperation) Close() error

Close closes operation

func (*BulkInsertOperation) GetID

func (o *BulkInsertOperation) GetID(entity interface{}) (string, error)

GetID returns id for an entity

func (*BulkInsertOperation) Store

func (o *BulkInsertOperation) Store(entity interface{}, metadata *MetadataAsDictionary) (string, error)

Store schedules entity for storing and returns its id. metadata can be nil

func (*BulkInsertOperation) StoreWithID

func (o *BulkInsertOperation) StoreWithID(entity interface{}, id string, metadata *MetadataAsDictionary) error

StoreWithID stores an entity with a given id

func (*BulkInsertOperation) WaitForID

func (o *BulkInsertOperation) WaitForID() error

WaitForID waits for operation id to finish

type BulkInsertProtocolViolationError

type BulkInsertProtocolViolationError struct {
	RavenError
}

func (*BulkInsertProtocolViolationError) Error

func (e *BulkInsertProtocolViolationError) Error() string

Error makes it conform to error interface

func (*BulkInsertProtocolViolationError) WrappedError

func (e *BulkInsertProtocolViolationError) WrappedError() error

hackish way to get a wrapped error

type CancelFunc

type CancelFunc func()

type CancellationError

type CancellationError struct {
}

func (*CancellationError) Error

func (e *CancellationError) Error() string

type CertificateNameMismatchError

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

CertificateNameMismatchError is returned when subscription is in use

func (*CertificateNameMismatchError) Error

func (e *CertificateNameMismatchError) Error() string

Error makes it conform to error interface

func (*CertificateNameMismatchError) WrappedError

func (e *CertificateNameMismatchError) WrappedError() error

hackish way to get a wrapped error

type ChangeProcessingError

type ChangeProcessingError struct {
	RavenError
}

func (*ChangeProcessingError) Error

func (e *ChangeProcessingError) Error() string

Error makes it conform to error interface

func (*ChangeProcessingError) WrappedError

func (e *ChangeProcessingError) WrappedError() error

hackish way to get a wrapped error

type ChangeType

type ChangeType int

ChangeType describes a type of a change in a document

const (
	// TODO: make those into a string?
	DocumentChangeDocumentDeleted ChangeType = iota
	DocumentChangeDocumentAdded
	DocumentChangeFieldChanged
	DocumentChangeNewField
	DocumentChangeRemovedField
	DocumentChangeArrayValueChanged
	DocumentChangeArrayValueAdded
	DocumentChangeArrayValueRemoved
	DocumentChangeFieldTypeChanged
	DocumentChangeEntityTypeChanged
)

type CircleCriteria

type CircleCriteria struct {
	SpatialCriteriaCommon
	// contains filtered or unexported fields
}

CircleCriteria describes circle criteria

func NewCircleCriteria

func NewCircleCriteria(radius float64, latitude float64, longitude float64, radiusUnits SpatialUnits, relation SpatialRelation, distErrorPercent float64) *CircleCriteria

NewCircleCriteria returns new CircleCriteria

func (*CircleCriteria) GetShapeToken

func (c *CircleCriteria) GetShapeToken(addQueryParameter func(interface{}) string) *shapeToken

GetShapeToken returns shapeToken

func (*CircleCriteria) ToQueryToken

func (c *CircleCriteria) ToQueryToken(fieldName string, addQueryParameter func(interface{}) string) queryToken

ToQueryToken creates a token

type ClientConfiguration

type ClientConfiguration struct {
	Etag       int64 `json:"Etag"`
	IsDisabled bool  `json:"Disabled"`
	// TODO: should this be *int ?
	MaxNumberOfRequestsPerSession int                 `json:"MaxNumberOfRequestsPerSession"`
	ReadBalanceBehavior           ReadBalanceBehavior `json:"ReadBalanceBehavior"`
}

ClientConfiguration represents client configuration

type ClientVersionMismatchError

type ClientVersionMismatchError struct {
	RavenError
}

ClientVersionMismatchError is returned when subscription is in use

func (*ClientVersionMismatchError) Error

func (e *ClientVersionMismatchError) Error() string

Error makes it conform to error interface

func (*ClientVersionMismatchError) WrappedError

func (e *ClientVersionMismatchError) WrappedError() error

hackish way to get a wrapped error

type ClusterRequestExecutor

type ClusterRequestExecutor = RequestExecutor

Note: for simplicity ClusterRequestExecutor logic is implemented in RequestExecutor because Go doesn't support inheritance

type ClusterTopology

type ClusterTopology struct {
	TopologyID string            `json:"TopologyId"`
	AllNodes   map[string]string `json:"AllNodes"`
	// Those map name like A to server url like http://localhost:9999
	Members     map[string]string `json:"Members"`
	Promotables map[string]string `json:"Promotables"`
	Watchers    map[string]string `json:"Watchers"`
	LastNodeId  string            `json:"LastNodeId"`
	Etag        int               `json:"Etag"`
}

ClusterTopology is a part of ClusterTopologyResponse

type CmpXchg

type CmpXchg struct {
	MethodCallData
}

CmpXchg represents data for cmp xchg method

func CmpXchgValue

func CmpXchgValue(key string) *CmpXchg

CmpXchgValue returns CmpXchg for a given key

type CollectionStatistics

type CollectionStatistics struct {
	CountOfDocuments int            `json:"CountOfDocuments"`
	CountOfConflicts int            `json:"CountOfConflicts"`
	Collections      map[string]int `json:"Collections"`
}

CollectionStatistics describes collection statistics

type CollectionStats

type CollectionStats struct {
	LastProcessedDocumentEtag  int64 `json:"LastProcessedDocumentEtag"`
	LastProcessedTombstoneEtag int64 `json:"LastProcessedTombstoneEtag"`
	DocumentLag                int64 `json:"DocumentLag"`
	TombstoneLag               int64 `json:"TombstoneLag"`
}

func NewCollectionStats

func NewCollectionStats() *CollectionStats

type CommandData

type CommandData struct {
	ID           string
	Name         string
	ChangeVector *string
	Type         CommandType
}

CommandData describes common data for commands

type CommandExecutionError

type CommandExecutionError struct {
	RavenError
}

func (*CommandExecutionError) Error

func (e *CommandExecutionError) Error() string

Error makes it conform to error interface

func (*CommandExecutionError) WrappedError

func (e *CommandExecutionError) WrappedError() error

hackish way to get a wrapped error

type CommandType

type CommandType = string

using type alias for easy json serialization

type CompactDatabaseCommand

type CompactDatabaseCommand struct {
	RavenCommandBase

	Result *OperationIDResult
	// contains filtered or unexported fields
}

CompactDatabaseCommand describes "compact database" command

func NewCompactDatabaseCommand

func NewCompactDatabaseCommand(conventions *DocumentConventions, compactSettings *CompactSettings) (*CompactDatabaseCommand, error)

NewCompactDatabaseCommand returns new CompactDatabaseCommand

func (*CompactDatabaseCommand) CreateRequest

func (c *CompactDatabaseCommand) CreateRequest(node *ServerNode) (*http.Request, error)

func (*CompactDatabaseCommand) SetResponse

func (c *CompactDatabaseCommand) SetResponse(response []byte, fromCache bool) error

type CompactDatabaseOperation

type CompactDatabaseOperation struct {
	Command *CompactDatabaseCommand
	// contains filtered or unexported fields
}

CompactDatabaseOperation describes "compact database" operation

func NewCompactDatabaseOperation

func NewCompactDatabaseOperation(compactSettings *CompactSettings) *CompactDatabaseOperation

NewCompactDatabaseOperation returns new CompactDatabaseOperation

func (*CompactDatabaseOperation) GetCommand

func (o *CompactDatabaseOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)

GetCommand returns a command

type CompactSettings

type CompactSettings struct {
	DatabaseName string   `json:"DatabaseName"`
	Documents    bool     `json:"Documents"`
	Indexes      []string `json:"Indexes,omitempty"`
}

CompactSettings is an argument to CompactDatabaseOperation

type CompareExchangeResult

type CompareExchangeResult struct {
	Value        interface{}
	Index        int64
	IsSuccessful bool
}

CompareExchangeResult describes result of compare exchange

type CompareExchangeValue

type CompareExchangeValue struct {
	Key   string
	Index int64
	Value interface{}
}

CompareExchangeValue represents value for compare exchange

func NewCompareExchangeValue

func NewCompareExchangeValue(key string, index int64, value interface{}) *CompareExchangeValue

NewCompareExchangeValue returns new CompareExchangeValue

type CompilationError

type CompilationError struct {
	RavenError
}

func (*CompilationError) Error

func (e *CompilationError) Error() string

Error makes it conform to error interface

func (*CompilationError) WrappedError

func (e *CompilationError) WrappedError() error

hackish way to get a wrapped error

type ConcurrencyCheckMode

type ConcurrencyCheckMode int

ConcurrencyCheckMode describes concurrency check

const (
	// ConcurrencyCheckAuto is automatic optimistic concurrency check depending on UseOptimisticConcurrency setting or provided Change Vector
	ConcurrencyCheckAuto ConcurrencyCheckMode = iota
	// ConcurrencyCheckForced forces optimistic concurrency check even if UseOptimisticConcurrency is not set
	ConcurrencyCheckForced
	// ConcurrencyCheckDisabled disables optimistic concurrency check even if UseOptimisticConcurrency is set
	ConcurrencyCheckDisabled
)

type ConcurrencyError

type ConcurrencyError struct {
	RavenError

	ExpectedETag         int64
	ActualETag           int64
	ExpectedChangeVector string
	ActualChangeVector   string
}

ConcurrencyError represents concurrency error

func (*ConcurrencyError) Error

func (e *ConcurrencyError) Error() string

Error makes it conform to error interface

func (*ConcurrencyError) WrappedError

func (e *ConcurrencyError) WrappedError() error

hackish way to get a wrapped error

type ConfigureRevisionsCommand

type ConfigureRevisionsCommand struct {
	RavenCommandBase

	Result *ConfigureRevisionsOperationResult
	// contains filtered or unexported fields
}

ConfigureRevisionsCommand represents configure revisions command

func NewConfigureRevisionsCommand

func NewConfigureRevisionsCommand(configuration *RevisionsConfiguration) *ConfigureRevisionsCommand

NewConfigureRevisionsCommand returns new ConfigureRevisionsCommand

func (*ConfigureRevisionsCommand) CreateRequest

func (c *ConfigureRevisionsCommand) CreateRequest(node *ServerNode) (*http.Request, error)

func (*ConfigureRevisionsCommand) SetResponse

func (c *ConfigureRevisionsCommand) SetResponse(response []byte, fromCache bool) error

type ConfigureRevisionsOperation

type ConfigureRevisionsOperation struct {
	Command *ConfigureRevisionsCommand
	// contains filtered or unexported fields
}

ConfigureRevisionsOperation represents configure revisions operation

func NewConfigureRevisionsOperation

func NewConfigureRevisionsOperation(configuration *RevisionsConfiguration) *ConfigureRevisionsOperation

NewConfigureRevisionsOperation returns new ConfigureRevisionsOperation

func (*ConfigureRevisionsOperation) GetCommand

func (o *ConfigureRevisionsOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)

GetCommand returns new RavenCommand for this operation

type ConfigureRevisionsOperationResult

type ConfigureRevisionsOperationResult struct {
	RaftCommandIndex int64 `json:"RaftCommandIndex"`
}

ConfigureRevisionsOperationResult represents result of configure revisions operation

type Conflict

type Conflict struct {
	LastModified Time                   `json:"LastModified"`
	ChangeVector string                 `json:"ChangeVector"`
	Doc          map[string]interface{} `json:"Doc"`
}

Conflict represents conflict

type ConflictError

type ConflictError struct {
	RavenError
}

ConflictError maps to server's 409 Conflict response

func (*ConflictError) Error

func (e *ConflictError) Error() string

Error makes it conform to error interface

func (*ConflictError) WrappedError

func (e *ConflictError) WrappedError() error

hackish way to get a wrapped error

type ConflictSolver

type ConflictSolver struct {
	ResolveByCollection map[string]*ScriptResolver `json:"ResolveByCollection"`
	ResolveToLatest     bool                       `json:"ResolveToLatest"`
}

ConflictSolver describes how to resolve conflicts

type ConnectionString

type ConnectionString struct {
	Name string `json:"Name"`
	// Note: Java has this as a virtual function getType()
	Type ConnectionStringType `json:"Type"`
}

ConnectionString represents connection string used as argument to PutConnectionStringCommand

type ConnectionStringType

type ConnectionStringType = string

TODO: only used in ConnectionString which is unused

type CreateDatabaseCommand

type CreateDatabaseCommand struct {
	RavenCommandBase

	Result *DatabasePutResult
	// contains filtered or unexported fields
}

CreateDatabaseCommand represents "create database" command

func NewCreateDatabaseCommand

func NewCreateDatabaseCommand(conventions *DocumentConventions, databaseRecord *DatabaseRecord, replicationFactor int) (*CreateDatabaseCommand, error)

NewCreateDatabaseCommand returns new CreateDatabaseCommand

func (*CreateDatabaseCommand) CreateRequest

func (c *CreateDatabaseCommand) CreateRequest(node *ServerNode) (*http.Request, error)

func (*CreateDatabaseCommand) SetResponse

func (c *CreateDatabaseCommand) SetResponse(response []byte, fromCache bool) error

type CreateDatabaseOperation

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

CreateDatabaseOperation represents "create database" operation

func NewCreateDatabaseOperation

func NewCreateDatabaseOperation(databaseRecord *DatabaseRecord, replicationFactor int) *CreateDatabaseOperation

NewCreateDatabaseOperation returns CreateDatabaseOperation

func (*CreateDatabaseOperation) GetCommand

func (o *CreateDatabaseOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)

GetCommand returns command for this operation

type CreateSampleDataCommand

type CreateSampleDataCommand struct {
	RavenCommandBase
}

CreateSampleDataCommand represents command for creating sample data

func NewCreateSampleDataCommand

func NewCreateSampleDataCommand(conventions *DocumentConventions) *CreateSampleDataCommand

NewCreateSampleDataCommand returns new CreateSampleDataCommand

func (*CreateSampleDataCommand) CreateRequest

func (c *CreateSampleDataCommand) CreateRequest(node *ServerNode) (*http.Request, error)

type CreateSampleDataOperation

type CreateSampleDataOperation struct {
	Command *CreateSampleDataCommand
}

CreateSampleDataOperation represents operation to create sample data

func NewCreateSampleDataOperation

func NewCreateSampleDataOperation() *CreateSampleDataOperation

NewCreateSampleDataOperation

func (*CreateSampleDataOperation) GetCommand

func (o *CreateSampleDataOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)

GetCommand returns a comman

type CreateSubscriptionCommand

type CreateSubscriptionCommand struct {
	RavenCommandBase

	Result *CreateSubscriptionResult
	// contains filtered or unexported fields
}

CreateSubscriptionCommand represents "create subscription" command

func (*CreateSubscriptionCommand) CreateRequest

func (c *CreateSubscriptionCommand) CreateRequest(node *ServerNode) (*http.Request, error)

func (*CreateSubscriptionCommand) SetResponse

func (c *CreateSubscriptionCommand) SetResponse(response []byte, fromCache bool) error

type CreateSubscriptionResult

type CreateSubscriptionResult struct {
	Name string `json:"Name"`
}

CreateSubscriptionResult represents result for "create subscription" command

type CurrentIndexAndNode

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

func NewCurrentIndexAndNode

func NewCurrentIndexAndNode(currentIndex int, currentNode *ServerNode) *CurrentIndexAndNode

type DatabaseChanges

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

DatabaseChanges notifies about changes to a database

func (*DatabaseChanges) AddConnectionStatusChanged

func (c *DatabaseChanges) AddConnectionStatusChanged(handler func()) int

func (*DatabaseChanges) AddOnError

func (c *DatabaseChanges) AddOnError(handler func(error)) int

func (*DatabaseChanges) Close

func (c *DatabaseChanges) Close()

Close closes DatabaseChanges and release its resources

func (*DatabaseChanges) EnsureConnectedNow

func (c *DatabaseChanges) EnsureConnectedNow() error

func (*DatabaseChanges) ForAllDocuments

func (c *DatabaseChanges) ForAllDocuments(cb func(*DocumentChange)) (CancelFunc, error)

ForAllDocuments registers a callback that will be called for changes on all documents. It returns a function to call to unregister the callback.

func (*DatabaseChanges) ForAllIndexes

func (c *DatabaseChanges) ForAllIndexes(cb func(*IndexChange)) (CancelFunc, error)

ForAllIndexes registers a callback that will be called when a change on any index happens. It returns a function to call to unregister the callback.

func (*DatabaseChanges) ForAllOperations

func (c *DatabaseChanges) ForAllOperations(cb func(change *OperationStatusChange)) (CancelFunc, error)

ForAllOperations registers a callback that will be called when any operation changes status. It returns a function to call to unregister the callback.

func (*DatabaseChanges) ForDocument

func (c *DatabaseChanges) ForDocument(docID string, cb func(*DocumentChange)) (CancelFunc, error)

ForDocument registers a callback that will be called for changes on a ocument with a given id It returns a function to call to unregister the callback.

func (*DatabaseChanges) ForDocumentsInCollection

func (c *DatabaseChanges) ForDocumentsInCollection(collectionName string, cb func(*DocumentChange)) (CancelFunc, error)

ForDocumentsInCollection registers a callback that will be called on changes for documents in a given collection. It returns a function to call to unregister the callback.

func (*DatabaseChanges) ForDocumentsInCollectionOfType

func (c *DatabaseChanges) ForDocumentsInCollectionOfType(clazz reflect.Type, cb func(*DocumentChange)) (CancelFunc, error)

ForDocumentsInCollectionOfType registers a callback that will be called on changes for documents of a given type. It returns a function to call to unregister the callback.

func (*DatabaseChanges) ForDocumentsStartingWith

func (c *DatabaseChanges) ForDocumentsStartingWith(docIDPrefix string, cb func(*DocumentChange)) (CancelFunc, error)

ForDocumentsStartingWith registers a callback that will be called for changes on documents whose id starts with a given prefix. It returns a function to call to unregister the callback.

func (*DatabaseChanges) ForIndex

func (c *DatabaseChanges) ForIndex(indexName string, cb func(*IndexChange)) (CancelFunc, error)

ForIndex registers a callback that will be called for changes in an index with a given name. It returns a function to call to unregister the callback.

func (*DatabaseChanges) ForOperationID

func (c *DatabaseChanges) ForOperationID(operationID int64, cb func(*OperationStatusChange)) (CancelFunc, error)

ForOperationID registers a callback that will be called when a change happens to operation with a given id. It returns a function to call to unregister the callback.

func (*DatabaseChanges) RemoveConnectionStatusChanged

func (c *DatabaseChanges) RemoveConnectionStatusChanged(handlerID int)

func (*DatabaseChanges) RemoveOnError

func (c *DatabaseChanges) RemoveOnError(handlerID int)

type DatabaseConcurrentLoadTimeoutError

type DatabaseConcurrentLoadTimeoutError struct {
	RavenError
}

func (*DatabaseConcurrentLoadTimeoutError) Error

func (e *DatabaseConcurrentLoadTimeoutError) Error() string

Error makes it conform to error interface

func (*DatabaseConcurrentLoadTimeoutError) WrappedError

func (e *DatabaseConcurrentLoadTimeoutError) WrappedError() error

hackish way to get a wrapped error

type DatabaseDisabledError

type DatabaseDisabledError struct {
	RavenError
}

func (*DatabaseDisabledError) Error

func (e *DatabaseDisabledError) Error() string

Error makes it conform to error interface

func (*DatabaseDisabledError) WrappedError

func (e *DatabaseDisabledError) WrappedError() error

hackish way to get a wrapped error

type DatabaseDoesNotExistError

type DatabaseDoesNotExistError struct {
	RavenError
}

DatabaseDoesNotExistError represents "database not not exist" error

func (*DatabaseDoesNotExistError) Error

func (e *DatabaseDoesNotExistError) Error() string

Error makes it conform to error interface

func (*DatabaseDoesNotExistError) WrappedError

func (e *DatabaseDoesNotExistError) WrappedError() error

hackish way to get a wrapped error

type DatabaseLoadFailureError

type DatabaseLoadFailureError struct {
	RavenError
}

func (*DatabaseLoadFailureError) Error

func (e *DatabaseLoadFailureError) Error() string

Error makes it conform to error interface

func (*DatabaseLoadFailureError) WrappedError

func (e *DatabaseLoadFailureError) WrappedError() error

hackish way to get a wrapped error

type DatabaseLoadTimeoutError

type DatabaseLoadTimeoutError struct {
	RavenError
}

func (*DatabaseLoadTimeoutError) Error

func (e *DatabaseLoadTimeoutError) Error() string

Error makes it conform to error interface

func (*DatabaseLoadTimeoutError) WrappedError

func (e *DatabaseLoadTimeoutError) WrappedError() error

hackish way to get a wrapped error

type DatabaseNotRelevantError

type DatabaseNotRelevantError struct {
	RavenError
}

func (*DatabaseNotRelevantError) Error

func (e *DatabaseNotRelevantError) Error() string

Error makes it conform to error interface

func (*DatabaseNotRelevantError) WrappedError

func (e *DatabaseNotRelevantError) WrappedError() error

hackish way to get a wrapped error

type DatabasePromotionStatus

type DatabasePromotionStatus = string

type DatabasePutResult

type DatabasePutResult struct {
	RaftCommandIndex int64    `json:"RaftCommandIndex"`
	Name             string   `json:"Name"`
	DatabaseTopology Topology `json:"Topology"`
	NodesAddedTo     []string `json:"NodesAddedTo"`
}

DatabasePutResult describes server response for e.g. CreateDatabaseCommand

type DatabaseRecord

type DatabaseRecord struct {
	DatabaseName         string            `json:"DatabaseName"`
	Disabled             bool              `json:"Disabled"`
	DataDirectory        string            `json:"DataDirectory,omitempty"`
	Settings             map[string]string `json:"Settings"`
	ConflictSolverConfig *ConflictSolver   `json:"ConflictSolverConfig"`
	Encrypted            bool              `json:"Encrypted"`
	DatabaseTopology     *DatabaseTopology `json:"DatabaseTopology"`
}

DatabaseRecord represents database record

func NewDatabaseRecord

func NewDatabaseRecord() *DatabaseRecord

NewDatabaseRecord returns new database record

type DatabaseRecordWithEtag

type DatabaseRecordWithEtag struct {
	DatabaseRecord
	Etag int64 `json:"Etag"`
}

DatabaseRecordWithEtag represents database record with etag

type DatabaseStatistics

type DatabaseStatistics struct {
	LastDocEtag               int64 `json:"LastDocEtag"`
	CountOfIndexes            int   `json:"CountOfIndexes"`
	CountOfDocuments          int64 `json:"CountOfDocuments"`
	CountOfRevisionDocuments  int64 `json:"CountOfRevisionDocuments"` // TODO: present in Java, not seen in JSON
	CountOfDocumentsConflicts int64 `json:"CountOfDocumentsConflicts"`
	CountOfTombstones         int64 `json:"CountOfTombstones"`
	CountOfConflicts          int64 `json:"CountOfConflicts"`
	CountOfAttachments        int64 `json:"CountOfAttachments"`
	CountOfUniqueAttachments  int64 `json:"CountOfUniqueAttachments"`

	Indexes []*IndexInformation `json:"Indexes"`

	DatabaseChangeVector                     string `json:"DatabaseChangeVector"`
	DatabaseID                               string `json:"DatabaseId"`
	Is64Bit                                  bool   `json:"Is64Bit"`
	Pager                                    string `json:"Pager"`
	LastIndexingTime                         *Time  `json:"LastIndexingTime"`
	SizeOnDisk                               *Size  `json:"SizeOnDisk"`
	TempBuffersSizeOnDisk                    *Size  `json:"TempBuffersSizeOnDisk"`
	NumberOfTransactionMergerQueueOperations int    `json:"NumberOfTransactionMergerQueueOperations"`
}

DatabaseStatistics describes a result of GetStatisticsCommand

func (*DatabaseStatistics) GetLastIndexingTime

func (s *DatabaseStatistics) GetLastIndexingTime() *time.Time

GetLastIndexingTime returns last indexing time

type DatabaseTopology

type DatabaseTopology struct {
	Members                  []string          `json:"Members"`
	Promotables              []string          `json:"Promotables"`
	Rehabs                   []string          `json:"Rehabs"`
	PredefinedMentors        map[string]string `json:"PredefinedMentors"`
	DemotionReasons          map[string]string `json:"DemotionReasons"`
	PromotablesStatus        map[string]string `json:"PromotablesStatus"`
	ReplicationFactor        int               `json:"ReplicationFactor"`
	DynamicNodesDistribution bool              `json:"DynamicNodesDistribution"`
	Stamp                    LeaderStamp       `json:"Stamp"`
}

DatabaseTopology describes a topology of the database

type DeleteAttachmentCommand

type DeleteAttachmentCommand struct {
	RavenCommandBase
	// contains filtered or unexported fields
}

func NewDeleteAttachmentCommand

func NewDeleteAttachmentCommand(documentID string, name string, changeVector *string) (*DeleteAttachmentCommand, error)

func (*DeleteAttachmentCommand) CreateRequest

func (c *DeleteAttachmentCommand) CreateRequest(node *ServerNode) (*http.Request, error)

type DeleteAttachmentCommandData

type DeleteAttachmentCommandData struct {
	*CommandData
}

func NewDeleteAttachmentCommandData

func NewDeleteAttachmentCommandData(documentID string, name string, changeVector *string) (*DeleteAttachmentCommandData, error)

NewDeleteAttachmentCommandData creates CommandData for Delete Attachment command

type DeleteAttachmentOperation

type DeleteAttachmentOperation struct {
	Command *DeleteAttachmentCommand
	// contains filtered or unexported fields
}

func NewDeleteAttachmentOperation

func NewDeleteAttachmentOperation(documentID string, name string, changeVector *string) *DeleteAttachmentOperation

func (*DeleteAttachmentOperation) GetCommand

func (o *DeleteAttachmentOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)

type DeleteByIndexCommand

type DeleteByIndexCommand struct {
	RavenCommandBase

	Result *OperationIDResult
	// contains filtered or unexported fields
}

func NewDeleteByIndexCommand

func NewDeleteByIndexCommand(conventions *DocumentConventions, queryToDelete *IndexQuery, options *QueryOperationOptions) (*DeleteByIndexCommand, error)

func (*DeleteByIndexCommand) CreateRequest

func (c *DeleteByIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error)

func (*DeleteByIndexCommand) SetResponse

func (c *DeleteByIndexCommand) SetResponse(response []byte, fromCache bool) error

type DeleteByQueryOperation

type DeleteByQueryOperation struct {
	Command *DeleteByIndexCommand
	// contains filtered or unexported fields
}

func NewDeleteByQueryOperation

func NewDeleteByQueryOperation(queryToDelete *IndexQuery, options *QueryOperationOptions) (*DeleteByQueryOperation, error)

func (*DeleteByQueryOperation) GetCommand

func (o *DeleteByQueryOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)

type DeleteCommandData

type DeleteCommandData struct {
	CommandData
}

DeleteCommandData represents data for delete command

type DeleteCompareExchangeValueOperation

type DeleteCompareExchangeValueOperation struct {
	Command *RemoveCompareExchangeValueCommand
	// contains filtered or unexported fields
}

func NewDeleteCompareExchangeValueOperation

func NewDeleteCompareExchangeValueOperation(clazz reflect.Type, key string, index int64) (*DeleteCompareExchangeValueOperation, error)

func (*DeleteCompareExchangeValueOperation) GetCommand

func (o *DeleteCompareExchangeValueOperation) GetCommand(store *DocumentStore, conventions *DocumentConventions, cache *httpCache) (RavenCommand, error)

type DeleteDatabaseCommand

type DeleteDatabaseCommand struct {
	RavenCommandBase

	Result *DeleteDatabaseResult
	// contains filtered or unexported fields
}

func NewDeleteDatabaseCommand

func NewDeleteDatabaseCommand(conventions *DocumentConventions, parameters *DeleteDatabaseParameters) (*DeleteDatabaseCommand, error)

func (*DeleteDatabaseCommand) CreateRequest

func (c *DeleteDatabaseCommand) CreateRequest(node *ServerNode) (*http.Request, error)

func (*DeleteDatabaseCommand) SetResponse

func (c *DeleteDatabaseCommand) SetResponse(response []byte, fromCache bool) error

type DeleteDatabaseParameters

type DeleteDatabaseParameters struct {
	DatabaseNames             []string       `json:"DatabaseNames"`
	HardDelete                bool           `json:"HardDelete"`
	FromNodes                 []string       `json:"FromNodes"`
	TimeToWaitForConfirmation *time.Duration `json:"TimeToWaitForConfirmation"`
}

type DeleteDatabaseResult

type DeleteDatabaseResult struct {
	RaftCommandIndex int64    `json:"RaftCommandIndex"`
	PendingDeletes   []string `json:"PendingDeletes"`
}

DeleteDatabaseResult represents result of Delete Database command

type DeleteDatabasesOperation

type DeleteDatabasesOperation struct {
	Command *DeleteDatabaseCommand
	// contains filtered or unexported fields
}

func NewDeleteDatabasesOperation

func NewDeleteDatabasesOperation(databaseName string, hardDelete bool) *DeleteDatabasesOperation

func NewDeleteDatabasesOperation2

func NewDeleteDatabasesOperation2(databaseName string, hardDelete bool, fromNode string, timeToWaitForConfirmation time.Duration) *DeleteDatabasesOperation

func NewDeleteDatabasesOperationWithParameters

func NewDeleteDatabasesOperationWithParameters(parameters *DeleteDatabaseParameters) *DeleteDatabasesOperation

func (*DeleteDatabasesOperation) GetCommand

func (o *DeleteDatabasesOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)

type DeleteDocumentCommand

type DeleteDocumentCommand struct {
	RavenCommandBase
	// contains filtered or unexported fields
}

func NewDeleteDocumentCommand

func NewDeleteDocumentCommand(id string, changeVector *string) *DeleteDocumentCommand

func (*DeleteDocumentCommand) CreateRequest

func (c *DeleteDocumentCommand) CreateRequest(node *ServerNode) (*http.Request, error)

type DeleteIndexCommand

type DeleteIndexCommand struct {
	RavenCommandBase
	// contains filtered or unexported fields
}

func NewDeleteIndexCommand

func NewDeleteIndexCommand(indexName string) (*DeleteIndexCommand, error)

func (*DeleteIndexCommand) CreateRequest

func (c *DeleteIndexCommand) CreateRequest(node *ServerNode) (*http.Request, error)

type DeleteIndexOperation

type DeleteIndexOperation struct {
	Command *DeleteIndexCommand
	// contains filtered or unexported fields
}

func NewDeleteIndexOperation

func NewDeleteIndexOperation(indexName string) *DeleteIndexOperation

func (*DeleteIndexOperation) GetCommand

func (o *DeleteIndexOperation) GetCommand(conventions *DocumentConventions) (RavenCommand, error)

type DeleteSubscriptionCommand

type DeleteSubscriptionCommand struct {
	RavenCommandBase
	// contains filtered or unexported fields
}

DeleteSubscriptionCommand describes "delete subscription" command