nosqldb

package

Go to main page

Versions in this module

v1

v1.4.7

Aug 13, 2024

Changes in this version

type Client

+ func (c *Client) GetServerSerialVersion() int

v1.4.6

Aug 12, 2024

v1.4.5

Aug 12, 2024

v1.4.4

Aug 2, 2024

Changes in this version

type GetRequest

+ StructType reflect.Type

+ StructValue any

type GetResult

+ StructValue any

type PutRequest

+ StructValue any

type QueryRequest

+ StructType reflect.Type

type QueryResult

+ func (r *QueryResult) GetStructResults() (res []any, err error)

v1.4.3

Jul 1, 2024

Changes in this version

+ const INITIALIZED

+ const NEXT_START_TIME

+ const QUERY_NAME

+ const REGION

+ const REPLICAS

+ const REPLICA_LAG

+ const REPLICA_STATS

+ const SCHEMA_FROZEN

+ const SERVER_MEMORY_CONSUMPTION

+ const TIME

+ const TRACE_AT_LOG_FILES

+ const VSCAN

+ const VSCANS

+ const VSCAN_JOIN_DESC_RESUME_KEY

+ const VSCAN_JOIN_PATH_KEY

+ const VSCAN_JOIN_PATH_MATCHED

+ const VSCAN_JOIN_PATH_SEC_KEY

+ const VSCAN_JOIN_PATH_TABLES

+ const VSCAN_MOVE_AFTER

+ const VSCAN_PID

+ const VSCAN_PRIM_KEY

+ const VSCAN_SEC_KEY

+ const VSCAN_SID

+ type AddReplicaRequest struct

+ MatchETag string

+ ReadUnits int32

+ ReplicaName string

+ TableName string

+ Timeout time.Duration

+ WriteUnits int32

type AuthorizationProvider

+ GetLogger func() *logger.Logger

type Client

+ InTest bool

+ func (c *Client) AddReplica(req *AddReplicaRequest) (*TableResult, error)

+ func (c *Client) DropReplica(req *DropReplicaRequest) (*TableResult, error)

+ func (c *Client) GetQueryVersion() int16

+ func (c *Client) GetReplicaStats(req *ReplicaStatsRequest) (*ReplicaStatsResult, error)

+ func (c *Client) SetQueryVersion(qVer int16)

+ type DropReplicaRequest struct

+ MatchETag string

+ ReplicaName string

+ TableName string

+ Timeout time.Duration

type QueryRequest

+ MaxServerMemoryConsumption int64

+ func (r *QueryRequest) GetMaxServerMemoryConsumption() int64

+ type Replica struct

+ CapacityMode types.CapacityMode

+ Name string

+ State types.TableState

+ TableOcid string

+ WriteUnits int

+ type ReplicaStats struct

+ CollectionTime time.Time

+ Lag time.Duration

+ type ReplicaStatsRequest struct

+ Limit int32

+ ReplicaName string

+ StartTime *time.Time

+ TableName string

+ Timeout time.Duration

+ func (r *ReplicaStatsRequest) SetStartTime(startTime string) error

+ type ReplicaStatsResult struct

+ NextStartTime *time.Time

+ StatsRecords map[string][]*ReplicaStats

+ TableName string

+ func (r *ReplicaStatsResult) ConsumedCapacity() (*Capacity, error)

+ func (r ReplicaStatsResult) String() string

type Result

+ GetTopologyInfo func() *common.TopologyInfo

+ SetTopology func(*common.TopologyInfo)

type TableResult

+ IsLocalReplicaInitialized bool

+ Replicas []*Replica

+ SchemaFrozen bool

v1.4.2

Sep 25, 2023

Changes in this version

type DeleteRequest

+ Namespace string

type GetIndexesRequest

+ Namespace string

type GetRequest

+ Namespace string

type GetTableRequest

+ Namespace string

type MultiDeleteRequest

+ Namespace string

type PrepareRequest

+ Namespace string

type PutRequest

+ Namespace string

type QueryRequest

+ Namespace string

type RequestConfig

+ Namespace string

+ func (r *RequestConfig) DefaultNamespace() string

type TableRequest

+ Namespace string

type TableUsageRequest

+ Namespace string

type WriteMultipleRequest

+ Namespace string

v1.4.1

Aug 22, 2023

v1.4.0

Dec 15, 2022

Changes in this version

+ const ABORT_ON_FAIL

+ const BIND_VARIABLES

+ const BadProtocol

+ const COMPARTMENT_OCID

+ const CONSISTENCY

+ const CONSUMED

+ const CONTINUATION_KEY

+ const DATA

+ const DEFINED_TAGS

+ const DRIVER_QUERY_PLAN

+ const DURABILITY

+ const END

+ const ERROR_CODE

+ const ETAG

+ const EXACT_MATCH

+ const EXCEPTION

+ const EXISTING_MOD_TIME

+ const EXISTING_VALUE

+ const EXISTING_VERSION

+ const EXPIRATION

+ const FIELDS

+ const FREE_FORM_TAGS

+ const GENERATED

+ const GET_QUERY_PLAN

+ const GET_QUERY_SCHEMA

+ const HEADER

+ const IDEMPOTENT

+ const IDENTITY_CACHE_SIZE

+ const INCLUSIVE

+ const INDEX

+ const INDEXES

+ const IS_JSON

+ const IS_PREPARED

+ const IS_SIMPLE_QUERY

+ const KEY

+ const KV_VERSION

+ const LAST_INDEX

+ const LIMITS

+ const LIMITS_MODE

+ const LIST_MAX_TO_READ

+ const LIST_START_INDEX

+ const MATCH_VERSION

+ const MATH_CONTEXT_CODE

+ const MATH_CONTEXT_PRECISION

+ const MATH_CONTEXT_ROUNDING_MODE

+ const MAX_READ_KB

+ const MAX_SHARD_USAGE_PERCENT

+ const MAX_WRITE_KB

+ const MODIFIED

+ const NAME

+ const NAMESPACE

+ const NOT_TARGET_TABLES

+ const NUMBER_LIMIT

+ const NUM_DELETIONS

+ const NUM_OPERATIONS

+ const NUM_RESULTS

+ const OPERATIONS

+ const OPERATION_ID

+ const OP_CODE

+ const PATH

+ const PAYLOAD

+ const PREPARE

+ const PREPARED_QUERY

+ const PREPARED_STATEMENT

+ const PROXY_TOPO_SEQNUM

+ const QUERY

+ const QUERY_OPERATION

+ const QUERY_PLAN_STRING

+ const QUERY_RESULTS

+ const QUERY_RESULT_SCHEMA

+ const QUERY_VERSION

+ const RANGE

+ const RANGE_PATH

+ const REACHED_LIMIT

+ const READ_KB

+ const READ_THROTTLE_COUNT

+ const READ_UNITS

+ const RETRY_HINT

+ const RETURN_INFO

+ const RETURN_ROW

+ const ROW

+ const ROW_VERSION

+ const SHARD_ID

+ const SHARD_IDS

+ const SORT_PHASE1_RESULTS

+ const START

+ const STATEMENT

+ const STORAGE_GB

+ const STORAGE_THROTTLE_COUNT

+ const SUCCESS

+ const SYSOP_RESULT

+ const SYSOP_STATE

+ const TABLES

+ const TABLE_ACCESS_INFO

+ const TABLE_DDL

+ const TABLE_NAME

+ const TABLE_OCID

+ const TABLE_SCHEMA

+ const TABLE_STATE

+ const TABLE_USAGE

+ const TABLE_USAGE_PERIOD

+ const TIMEOUT

+ const TOPOLOGY_INFO

+ const TOPO_SEQ_NUM

+ const TRACE_LEVEL

+ const TTL

+ const TYPE

+ const UPDATE_TTL

+ const UnsupportedProtocol

+ const VALUE

+ const VERSION

+ const WM_FAILURE

+ const WM_FAIL_INDEX

+ const WM_FAIL_RESULT

+ const WM_SUCCESS

+ const WRITE_KB

+ const WRITE_MULTIPLE

+ const WRITE_THROTTLE_COUNT

+ const WRITE_UNITS

+ var NsonFieldsMap = map[string]string

+ func SetNsonDebug(d bool)

type Client

+ func (c *Client) SetSerialVersion(sVer int16)

type IndexInfo

+ FieldTypes []string

+ type NsonSerializer struct

type PrepareRequest

+ GetQuerySchema bool

type PreparedStatement

+ func (p *PreparedStatement) GetQueryPlan() string

+ func (p *PreparedStatement) GetQuerySchema() string

type QueryRequest

+ Durability types.Durability

type TableRequest

+ DefinedTags *types.DefinedTags

+ FreeFormTags *types.FreeFormTags

+ MatchETag string

type TableResult

+ CompartmentOrNamespace string

+ DDL string

+ DefinedTags *types.DefinedTags

+ FreeFormTags *types.FreeFormTags

+ MatchETag string

+ TableOcid string

type TableUsage

+ MaxShardUsagePercent int

type TableUsageRequest

+ StartIndex int

type TableUsageResult

+ LastIndexReturned int

v1.3.2

Oct 18, 2022

v1.3.1

May 17, 2022

Changes in this version

+ const SessionCookieField

v1.3.0

Feb 24, 2022

Changes in this version

type Client

+ func (c *Client) GetSerialVersion() int16

+ func (c *Client) VerifyConnection() error

type DeleteRequest

+ Durability types.Durability

type GetResult

+ ModificationTime int64

type MultiDeleteRequest

+ Durability types.Durability

type PutRequest

+ Durability types.Durability

type TableLimits

+ CapacityMode types.CapacityMode

+ func OnDemandTableLimits(GB uint) *TableLimits

+ func ProvisionedTableLimits(RUs uint, WUs uint, GB uint) *TableLimits

type WriteMultipleRequest

+ Durability types.Durability

type WriteResult

+ ExistingModificationTime int64

v1.2.2

Jun 9, 2021

Changes in this version

+ const LimiterRefreshNanos

type Client

+ func (c *Client) EnableRateLimiting(enable bool, usePercent float64)

+ func (c *Client) ResetRateLimiters(tableName string)

type Config

+ RateLimiterPercentage float64

+ RateLimitingEnabled bool

+ type DelayInfo struct

+ RateLimitTime time.Duration

+ RetryTime time.Duration

+ func (d DelayInfo) Delayed() DelayInfo

type QueryRequest

+ TableName string

type Result

+ Delayed func() DelayInfo

v1.2.1

Aug 14, 2020

Changes in this version

+ var Decimal128 = FPArithSpec

+ var Decimal32 = FPArithSpec

+ var Decimal64 = FPArithSpec

+ var Unlimited = FPArithSpec

+ type AuthorizationProvider interface

+ AuthorizationScheme func() string

+ AuthorizationString func(req auth.Request) (string, error)

+ Close func() error

+ SignHTTPRequest func(httpReq *http.Request) error

+ type Capacity struct

+ ReadKB int

+ ReadUnits int

+ WriteKB int

+ func (r Capacity) ConsumedCapacity() (Capacity, error)

+ func (r Capacity) String() string

+ type Client struct

+ HTTPClient *httputil.HTTPClient

+ func NewClient(cfg Config) (*Client, error)

+ func (c *Client) Close() error

+ func (c *Client) Delete(req *DeleteRequest) (*DeleteResult, error)

+ func (c *Client) DoSystemRequest(req *SystemRequest) (*SystemResult, error)

+ func (c *Client) DoSystemRequestAndWait(statement string, timeout, pollInterval time.Duration) (*SystemResult, error)

+ func (c *Client) DoTableRequest(req *TableRequest) (*TableResult, error)

+ func (c *Client) DoTableRequestAndWait(req *TableRequest, timeout, pollInterval time.Duration) (*TableResult, error)

+ func (c *Client) Get(req *GetRequest) (*GetResult, error)

+ func (c *Client) GetIndexes(req *GetIndexesRequest) (*GetIndexesResult, error)

+ func (c *Client) GetSystemStatus(req *SystemStatusRequest) (*SystemResult, error)

+ func (c *Client) GetTable(req *GetTableRequest) (*TableResult, error)

+ func (c *Client) GetTableUsage(req *TableUsageRequest) (*TableUsageResult, error)

+ func (c *Client) ListNamespaces() ([]string, error)

+ func (c *Client) ListRoles() ([]string, error)

+ func (c *Client) ListTables(req *ListTablesRequest) (*ListTablesResult, error)

+ func (c *Client) ListUsers() ([]UserInfo, error)

+ func (c *Client) MultiDelete(req *MultiDeleteRequest) (*MultiDeleteResult, error)

+ func (c *Client) Prepare(req *PrepareRequest) (*PrepareResult, error)

+ func (c *Client) Put(req *PutRequest) (*PutResult, error)

+ func (c *Client) Query(req *QueryRequest) (*QueryResult, error)

+ func (c *Client) WriteMultiple(req *WriteMultipleRequest) (*WriteMultipleResult, error)

+ type Config struct

+ Endpoint string

+ Mode string

+ Password []byte

+ Region common.Region

+ Username string

+ func (c *Config) IsCloud() bool

+ func (c *Config) IsCloudSim() bool

+ type DefaultRetryHandler struct

+ func NewDefaultRetryHandler(maxNumRetries uint, retryInterval time.Duration) (*DefaultRetryHandler, error)

+ func (r DefaultRetryHandler) Delay(req Request, numRetries uint, err error)

+ func (r DefaultRetryHandler) MaxNumRetries() uint

+ func (r DefaultRetryHandler) ShouldRetry(req Request, numRetries uint, err error) bool

+ type DeleteRequest struct

+ Key *types.MapValue

+ MatchVersion types.Version

+ ReturnRow bool

+ TableName string

+ Timeout time.Duration

+ type DeleteResult struct

+ Success bool

+ func (r DeleteResult) String() string

+ type FPArithSpec struct

+ Precision uint

+ RoundingMode big.RoundingMode

+ type GetIndexesRequest struct

+ IndexName string

+ TableName string

+ Timeout time.Duration

+ type GetIndexesResult struct

+ Indexes []IndexInfo

+ func (r GetIndexesResult) ConsumedCapacity() (Capacity, error)

+ func (r GetIndexesResult) String() string

+ type GetRequest struct

+ Consistency types.Consistency

+ Key *types.MapValue

+ TableName string

+ Timeout time.Duration

+ type GetResult struct

+ ExpirationTime time.Time

+ Value *types.MapValue

+ Version types.Version

+ func (r GetResult) RowExists() bool

+ func (r GetResult) String() string

+ func (r GetResult) ValueAsJSON() string

+ type GetTableRequest struct

+ OperationID string

+ TableName string

+ Timeout time.Duration

+ type IndexInfo struct

+ FieldNames []string

+ IndexName string

+ func (r IndexInfo) String() string

+ type ListTablesRequest struct

+ Limit uint

+ Namespace string

+ StartIndex uint

+ Timeout time.Duration

+ type ListTablesResult struct

+ LastIndexReturned uint

+ Tables []string

+ func (r ListTablesResult) ConsumedCapacity() (Capacity, error)

+ func (r ListTablesResult) String() string

+ type LoggingConfig struct

+ DisableLogging bool

+ type MultiDeleteRequest struct

+ ContinuationKey []byte

+ FieldRange *types.FieldRange

+ Key *types.MapValue

+ MaxWriteKB uint

+ TableName string

+ Timeout time.Duration

+ type MultiDeleteResult struct

+ ContinuationKey []byte

+ NumDeleted int

+ func (r MultiDeleteResult) String() string

+ type OperationResult struct

+ GeneratedValue types.FieldValue

+ Success bool

+ Version types.Version

+ func (r OperationResult) String() string

+ type PrepareRequest struct

+ GetQueryPlan bool

+ Statement string

+ Timeout time.Duration

+ type PrepareResult struct

+ PreparedStatement PreparedStatement

+ func (r PrepareResult) String() string

+ type PreparedStatement struct

+ func (p *PreparedStatement) SetVariable(name string, value interface{}) error

+ type PutRequest struct

+ ExactMatch bool

+ IdentityCacheSize int

+ MatchVersion types.Version

+ PutOption types.PutOption

+ ReturnRow bool

+ TTL *types.TimeToLive

+ TableName string

+ Timeout time.Duration

+ UseTableTTL bool

+ Value *types.MapValue

+ type PutResult struct

+ GeneratedValue types.FieldValue

+ Version types.Version

+ func (r PutResult) String() string

+ func (r PutResult) Success() bool

+ type QueryRequest struct

+ Consistency types.Consistency

+ FPArithSpec *FPArithSpec

+ Limit uint

+ MaxMemoryConsumption int64

+ MaxReadKB uint

+ MaxWriteKB int

+ PreparedStatement *PreparedStatement

+ Statement string

+ Timeout time.Duration

+ func (r *QueryRequest) Close()

+ func (r *QueryRequest) GetMaxMemoryConsumption() int64

+ func (r *QueryRequest) IsDone() bool

+ type QueryResult struct

+ func (r *QueryResult) ConsumedCapacity() (Capacity, error)

+ func (r *QueryResult) GetResults() (res []*types.MapValue, err error)

+ func (r QueryResult) String() string

+ type Request interface

+ type RequestConfig struct

+ Consistency types.Consistency

+ RequestTimeout time.Duration

+ SecurityInfoTimeout time.Duration

+ TableRequestTimeout time.Duration

+ func (r *RequestConfig) DefaultConsistency() types.Consistency

+ func (r *RequestConfig) DefaultRequestTimeout() time.Duration

+ func (r *RequestConfig) DefaultSecurityInfoTimeout() time.Duration

+ func (r *RequestConfig) DefaultTableRequestTimeout() time.Duration

+ type Result interface

+ ConsumedCapacity func() (Capacity, error)

+ type RetryHandler interface

+ Delay func(req Request, numRetries uint, err error)

+ MaxNumRetries func() uint

+ ShouldRetry func(req Request, numRetries uint, err error) bool

+ type SystemRequest struct

+ Statement string

+ Timeout time.Duration

+ type SystemResult struct

+ OperationID string

+ ResultString string

+ State types.OperationState

+ Statement string

+ func (r *SystemResult) WaitForCompletion(client *Client, timeout, pollInterval time.Duration) (*SystemResult, error)

+ func (r SystemResult) ConsumedCapacity() (Capacity, error)

+ func (r SystemResult) String() string

+ type SystemStatusRequest struct

+ OperationID string

+ Statement string

+ Timeout time.Duration

+ type TableLimits struct

+ ReadUnits uint

+ StorageGB uint

+ WriteUnits uint

+ type TableRequest struct

+ Statement string

+ TableLimits *TableLimits

+ TableName string

+ Timeout time.Duration

+ type TableResult struct

+ Limits TableLimits

+ OperationID string

+ Schema string

+ State types.TableState

+ TableName string

+ func (r *TableResult) WaitForCompletion(client *Client, timeout, pollInterval time.Duration) (*TableResult, error)

+ func (r TableResult) ConsumedCapacity() (Capacity, error)

+ func (r TableResult) String() string

+ type TableUsage struct

+ EndTime time.Time

+ ReadThrottleCount int

+ ReadUnits int

+ StartTime time.Time

+ StorageGB int

+ StorageThrottleCount int

+ WriteThrottleCount int

+ WriteUnits int

+ func (r TableUsage) String() string

+ type TableUsageRequest struct

+ EndTime time.Time

+ Limit uint

+ StartTime time.Time

+ TableName string

+ Timeout time.Duration

+ type TableUsageResult struct

+ TableName string

+ UsageRecords []TableUsage

+ func (r TableUsageResult) ConsumedCapacity() (Capacity, error)

+ func (r TableUsageResult) String() string

+ type UserInfo struct

+ ID string

+ Name string

+ type WriteMultipleRequest struct

+ Operations []*WriteOperation

+ TableName string

+ Timeout time.Duration

+ func (r *WriteMultipleRequest) AddDeleteRequest(d *DeleteRequest, abortOnFail bool) error

+ func (r *WriteMultipleRequest) AddPutRequest(p *PutRequest, abortOnFail bool) error

+ func (r *WriteMultipleRequest) Clear()

+ type WriteMultipleResult struct

+ FailedOperationIndex int

+ ResultSet []OperationResult

+ func (r WriteMultipleResult) GetFailedOperationResult() *OperationResult

+ func (r WriteMultipleResult) IsSuccess() bool

+ func (r WriteMultipleResult) String() string

+ type WriteOperation struct

+ AbortOnFail bool

+ DeleteRequest *DeleteRequest

+ PutRequest *PutRequest

+ type WriteResult struct

+ ExistingValue *types.MapValue

+ ExistingVersion types.Version

+ func (r WriteResult) ExistingValueAsJSON() string

+ func (r WriteResult) String() string

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