Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion batch_command.go
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ func (cmd *batchCommand) setInDoubt(ifc batcher) {
}

func (cmd *batchCommand) inDoubt() {
// do nothing by defaut
// do nothing by default
}

func (cmd *batchCommand) prepareRetry(ifc command, isTimeout bool) bool {
Expand Down
4 changes: 2 additions & 2 deletions batch_record.go
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ type BatchRecordIfc interface {
equals(BatchRecordIfc) bool
}

// BatchRecord encasulates the Batch key and record result.
// BatchRecord encapsulates the Batch key and record result.
type BatchRecord struct {
// Key.
Key *Key
Expand All @@ -67,7 +67,7 @@ type BatchRecord struct {
// Err encapsulates the possible error chain for this key
Err Error

// InDoubt signifies the possiblity that the write command may have completed even though an error
// InDoubt signifies the possibility that the write command may have completed even though an error
// occurred for this record. This may be the case when a client error occurs (like timeout)
// after the command was sent to the server.
InDoubt bool
Expand Down
2 changes: 1 addition & 1 deletion bit_resize_flags.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@ package aerospike
type BitResizeFlags int

const (
// BitResizeFlagsDefault specifies the defalt flag.
// BitResizeFlagsDefault specifies the default flag.
BitResizeFlagsDefault BitResizeFlags = 0

// BitResizeFlagsFromFront Adds/removes bytes from the beginning instead of the end.
Expand Down
2 changes: 1 addition & 1 deletion cdt_bitwise_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -222,7 +222,7 @@ var _ = gg.Describe("CDT Bitwise Test", func() {
0xc1},
as.BitSetOp(putMode, cdtBinName, 1, 1, bit0),
as.BitSetOp(putMode, cdtBinName, 15, 1, bit0),
// SUM Offest Size
// SUM Offset Size
as.BitSetOp(putMode, cdtBinName, 16, 24, bits1), // Y Y Y
as.BitSetOp(putMode, cdtBinName, 40, 22, bits1), // N Y N
as.BitSetOp(putMode, cdtBinName, 73, 21, bits1), // N N N
Expand Down
4 changes: 2 additions & 2 deletions cdt_list.go
Original file line number Diff line number Diff line change
Expand Up @@ -160,7 +160,7 @@ const (
ListReturnTypeInverted ListReturnType = 0x10000
)

// ListSortFlags detemines sort flags for CDT lists
// ListSortFlags determines sort flags for CDT lists
type ListSortFlags int

const (
Expand All @@ -172,7 +172,7 @@ const (
ListSortFlagsDropDuplicates ListSortFlags = 2
)

// ListWriteFlags detemines write flags for CDT lists
// ListWriteFlags determines write flags for CDT lists
// type ListWriteFlags int

const (
Expand Down
2 changes: 1 addition & 1 deletion client_appengine_exclusions.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,7 +67,7 @@ func (clnt *Client) QueryAggregate(policy *QueryPolicy, statement *Statement, pa
inputChan := make(chan interface{}, 4096) // 4096 = number of partitions
istream := lualib.NewStream(luaInstance, inputChan)

// Output Channe;
// Output Channel;
outputChan := make(chan interface{})
ostream := lualib.NewStream(luaInstance, outputChan)

Expand Down
6 changes: 3 additions & 3 deletions command.go
Original file line number Diff line number Diff line change
Expand Up @@ -1192,7 +1192,7 @@ func (cmd *baseCommand) setBatchOperateIfcOffsets(
cmd.dataOffset++
} else {
// Must write full header and namespace/set/bin names.
cmd.dataOffset += 12 // header(4) + ttl(4) + fielCount(2) + opCount(2) = 12
cmd.dataOffset += 12 // header(4) + ttl(4) + fieldCount(2) + opCount(2) = 12
cmd.dataOffset += len(key.namespace) + int(_FIELD_HEADER_SIZE)
cmd.dataOffset += len(key.setName) + int(_FIELD_HEADER_SIZE)
cmd.sizeTxnBatch(txn, ver, record.BatchRec().hasWrite)
Expand Down Expand Up @@ -1379,7 +1379,7 @@ func (cmd *baseCommand) setBatchOperateReadOffsets(
cmd.dataOffset++
} else {
// Must write full header and namespace/set/bin names.
cmd.dataOffset += 12 // header(4) + ttl(4) + fielCount(2) + opCount(2) = 12
cmd.dataOffset += 12 // header(4) + ttl(4) + fieldCount(2) + opCount(2) = 12
cmd.dataOffset += len(key.namespace) + int(_FIELD_HEADER_SIZE)
cmd.dataOffset += len(key.setName) + int(_FIELD_HEADER_SIZE)
cmd.sizeTxnBatch(txn, ver, record.BatchRec().hasWrite)
Expand Down Expand Up @@ -1544,7 +1544,7 @@ func (cmd *baseCommand) setBatchOperateOffsets(
cmd.dataOffset++
} else {
// Must write full header and namespace/set/bin names.
cmd.dataOffset += 12 // header(4) + ttl(4) + fielCount(2) + opCount(2) = 12
cmd.dataOffset += 12 // header(4) + ttl(4) + fieldCount(2) + opCount(2) = 12
cmd.dataOffset += len(key.namespace) + int(_FIELD_HEADER_SIZE)
cmd.dataOffset += len(key.setName) + int(_FIELD_HEADER_SIZE)
cmd.sizeTxnBatch(txn, ver, attr.hasWrite)
Expand Down
2 changes: 1 addition & 1 deletion config.go
Original file line number Diff line number Diff line change
Expand Up @@ -450,7 +450,7 @@ func (dc *DynConfig) watchConfig(interval time.Duration) {
// This allows the config to be updated dynamically without restarting the client.
dc.lock.RLock()
var mergedConfigInterval time.Duration
// Handle the condition where dynamic config is eneabled but config was not loaded becuase
// Handle the condition where dynamic config is enabled but config was not loaded because
// the file could not be found or the url is not valid. In that case we will use the interval passed
// in or use the default interval of 1 second.
if dc.config == nil {
Expand Down
2 changes: 1 addition & 1 deletion docs/aerospike.md
Original file line number Diff line number Diff line change
Expand Up @@ -72,7 +72,7 @@ Example:
client, err := as.NewClient("127.0.0.1", 3000)
```

For detals, see [Client Class](client.md).
For details, see [Client Class](client.md).

<!--
################################################################################
Expand Down
2 changes: 1 addition & 1 deletion expression.go
Original file line number Diff line number Diff line change
Expand Up @@ -22,7 +22,7 @@ import (
)

// ExpressionArgument is used for passing arguments to filter expressions.
// The accptable arguments are:
// The acceptable arguments are:
// Value, ExpressionFilter, []*CDTContext
type ExpressionArgument interface {
pack(BufferEx) (int, Error)
Expand Down
2 changes: 1 addition & 1 deletion query_policy.go
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,7 @@ type QueryPolicy struct {
// Default: LONG
ExpectedDuration QueryDuration

// ShortQuery determines wether query expected to return less than 100 records.
// ShortQuery determines whether query expected to return less than 100 records.
// If true, the server will optimize the query for a small record set.
// This field is ignored for aggregation queries, background queries
// and server versions 6.0+.
Expand Down
4 changes: 2 additions & 2 deletions role.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,13 +41,13 @@ const (
// SysAdmin allows to manage indexes, user defined functions and server configuration.
SysAdmin privilegeCode = "sys-admin"

// DataAdmin allows to manage indicies and user defined functions.
// DataAdmin allows to manage indices and user defined functions.
DataAdmin privilegeCode = "data-admin"

// UDFAdmin allows to manage user defined functions.
UDFAdmin privilegeCode = "udf-admin"

// SIndexAdmin allows to manage indicies.
// SIndexAdmin allows to manage indices.
SIndexAdmin privilegeCode = "sindex-admin"

// ReadWriteUDF allows read, write and UDF transactions with the database.
Expand Down
4 changes: 2 additions & 2 deletions security_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -74,7 +74,7 @@ var _ = gg.Describe("Security tests", func() {
err = client.GrantPrivileges(nil, "role-read-test-test", []as.Privilege{{Code: as.ReadWrite, Namespace: ns, SetName: "bar"}, {Code: as.ReadWriteUDF, Namespace: ns, SetName: "test"}})
gm.Expect(err).ToNot(gm.HaveOccurred())

// Wait until servers syncronize
// Wait until servers synchronize
time.Sleep(1 * time.Second)

// Revoke privileges from the roles
Expand All @@ -90,7 +90,7 @@ var _ = gg.Describe("Security tests", func() {
err = client.DropRole(nil, "dummy-role")
gm.Expect(err).ToNot(gm.HaveOccurred())

// Wait until servers syncronize
// Wait until servers synchronize
time.Sleep(3 * time.Second)

roles, err := client.QueryRoles(nil)
Expand Down
2 changes: 1 addition & 1 deletion types/pool.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ type Pool struct {
New func(params ...interface{}) interface{}
// IsUsable checks if the object polled from the pool is still fresh and usable
IsUsable func(obj interface{}, params ...interface{}) bool
// CanReturn checkes if the object is eligible to go back to the pool
// CanReturn checks if the object is eligible to go back to the pool
CanReturn func(obj interface{}) bool
// Finalize will be called when an object is not eligible to go back to the pool.
// Usable to close connections, file handles, ...
Expand Down