| /dports/security/vault/vault-1.8.2/vendor/github.com/hashicorp/vault-plugin-database-couchbase/vendor/github.com/couchbase/gocb/v2/ |
| H A D | error.go | 7 gocbcore "github.com/couchbase/gocbcore/v9" packageName
51 ErrTimeout = gocbcore.ErrTimeout
75 ErrCasMismatch = gocbcore.ErrCasMismatch
110 ErrIndexExists = gocbcore.ErrIndexExists
164 ErrPathInvalid = gocbcore.ErrPathInvalid
167 ErrPathTooBig = gocbcore.ErrPathTooBig
171 ErrPathTooDeep = gocbcore.ErrPathTooDeep
194 ErrPathExists = gocbcore.ErrPathExists
274 ErrScopeExists = gocbcore.ErrScopeExists
286 ErrUserExists = gocbcore.ErrUserExists
[all …]
|
| H A D | transcoding.go | 71 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
74 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
82 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
143 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
146 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
149 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
152 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
155 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
158 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
221 flags = gocbcore.EncodeCommonFlags(gocbcore.StringType, gocbcore.NoCompression)
[all …]
|
| H A D | providers.go | 10 DoHTTPRequest(req *gocbcore.HTTPRequest) (*gocbcore.HTTPResponse, error)
36 cb gocbcore.WaitUntilReadyCallback) (gocbcore.PendingOp, error)
40 Diagnostics(opts gocbcore.DiagnosticsOptions) (*gocbcore.DiagnosticInfo, error)
41 Ping(opts gocbcore.PingOptions) (*gocbcore.PingResult, error)
45 Diagnostics(opts gocbcore.DiagnosticsOptions) (*gocbcore.DiagnosticInfo, error)
46 Ping(opts gocbcore.PingOptions, cb gocbcore.PingCallback) (gocbcore.PendingOp, error)
99 provider *gocbcore.AgentGroup
122 provider *gocbcore.AgentGroup
145 provider *gocbcore.AgentGroup
187 provider *gocbcore.AgentGroup
[all …]
|
| H A D | retry.go | 9 func translateCoreRetryReasons(reasons []gocbcore.RetryReason) []RetryReason {
33 req gocbcore.RetryRequest
61 UnknownRetryReason = RetryReason(gocbcore.UnknownRetryReason)
64 SocketNotAvailableRetryReason = RetryReason(gocbcore.SocketNotAvailableRetryReason)
70 NodeNotAvailableRetryReason = RetryReason(gocbcore.NodeNotAvailableRetryReason)
73 KVNotMyVBucketRetryReason = RetryReason(gocbcore.KVNotMyVBucketRetryReason)
80 KVErrMapRetryReason = RetryReason(gocbcore.KVErrMapRetryReason)
83 KVLockedRetryReason = RetryReason(gocbcore.KVLockedRetryReason)
86 KVTemporaryFailureRetryReason = RetryReason(gocbcore.KVTemporaryFailureRetryReason)
160 …unc (rs *retryStrategyWrapper) RetryAfter(req gocbcore.RetryRequest, reason gocbcore.RetryReason) …
[all …]
|
| H A D | logging.go | 8 gocbcore "github.com/couchbase/gocbcore/v9" packageName
12 type LogLevel gocbcore.LogLevel
17 LogError LogLevel = LogLevel(gocbcore.LogError)
18 LogWarn LogLevel = LogLevel(gocbcore.LogWarn)
19 LogInfo LogLevel = LogLevel(gocbcore.LogInfo)
20 LogDebug LogLevel = LogLevel(gocbcore.LogDebug)
43 gocbcore.SetLogRedactionLevel(gocbcore.LogRedactLevel(level))
63 wrapped gocbcore.Logger
74 wrapped: gocbcore.DefaultStdioLogger(),
84 wrapped: gocbcore.VerboseStdioLogger(),
[all …]
|
| H A D | collection_crud.go | 12 Add(opts gocbcore.AddOptions, cb gocbcore.StoreCallback) (gocbcore.PendingOp, error)
13 Set(opts gocbcore.SetOptions, cb gocbcore.StoreCallback) (gocbcore.PendingOp, error)
14 Replace(opts gocbcore.ReplaceOptions, cb gocbcore.StoreCallback) (gocbcore.PendingOp, error)
15 Get(opts gocbcore.GetOptions, cb gocbcore.GetCallback) (gocbcore.PendingOp, error)
17 Observe(opts gocbcore.ObserveOptions, cb gocbcore.ObserveCallback) (gocbcore.PendingOp, error)
19 GetMeta(opts gocbcore.GetMetaOptions, cb gocbcore.GetMetaCallback) (gocbcore.PendingOp, error)
20 Delete(opts gocbcore.DeleteOptions, cb gocbcore.DeleteCallback) (gocbcore.PendingOp, error)
25 Unlock(opts gocbcore.UnlockOptions, cb gocbcore.UnlockCallback) (gocbcore.PendingOp, error)
26 Touch(opts gocbcore.TouchOptions, cb gocbcore.TouchCallback) (gocbcore.PendingOp, error)
29 Append(opts gocbcore.AdjoinOptions, cb gocbcore.AdjoinCallback) (gocbcore.PendingOp, error)
[all …]
|
| H A D | constants.go | 4 gocbcore "github.com/couchbase/gocbcore/v9" packageName
59 type ServiceType gocbcore.ServiceType
63 ServiceTypeManagement ServiceType = ServiceType(gocbcore.MgmtService)
66 ServiceTypeKeyValue ServiceType = ServiceType(gocbcore.MemdService)
69 ServiceTypeViews ServiceType = ServiceType(gocbcore.CapiService)
72 ServiceTypeQuery ServiceType = ServiceType(gocbcore.N1qlService)
75 ServiceTypeSearch ServiceType = ServiceType(gocbcore.FtsService)
78 ServiceTypeAnalytics ServiceType = ServiceType(gocbcore.CbasService)
|
| H A D | collection_dura.go | 6 gocbcore "github.com/couchbase/gocbcore/v9" packageName
12 mt gocbcore.MutationToken,
28 err = opm.Wait(agent.ObserveVb(gocbcore.ObserveVbOptions{
34 }, func(res *gocbcore.ObserveVbResult, err error) {
55 mt gocbcore.MutationToken,
64 calc := gocbcore.ExponentialBackoff(10*time.Microsecond, 100*time.Millisecond, 0)
97 waitTmr := gocbcore.AcquireTimer(calc(retries))
101 gocbcore.ReleaseTimer(waitTmr, true)
103 gocbcore.ReleaseTimer(waitTmr, false)
111 mt gocbcore.MutationToken,
|
| /dports/security/vault/vault-1.8.2/vendor/github.com/couchbase/gocb/v2/ |
| H A D | error.go | 7 gocbcore "github.com/couchbase/gocbcore/v9" packageName
51 ErrTimeout = gocbcore.ErrTimeout
75 ErrCasMismatch = gocbcore.ErrCasMismatch
110 ErrIndexExists = gocbcore.ErrIndexExists
164 ErrPathInvalid = gocbcore.ErrPathInvalid
167 ErrPathTooBig = gocbcore.ErrPathTooBig
171 ErrPathTooDeep = gocbcore.ErrPathTooDeep
194 ErrPathExists = gocbcore.ErrPathExists
274 ErrScopeExists = gocbcore.ErrScopeExists
286 ErrUserExists = gocbcore.ErrUserExists
[all …]
|
| H A D | mock_kvProvider_test.go | 16 func (_m *mockKvProvider) Add(opts gocbcore.AddOptions, cb gocbcore.StoreCallback) (gocbcore.Pendin…
20 …if rf, ok := ret.Get(0).(func(gocbcore.AddOptions, gocbcore.StoreCallback) gocbcore.PendingOp); ok…
43 …if rf, ok := ret.Get(0).(func(gocbcore.AdjoinOptions, gocbcore.AdjoinCallback) gocbcore.PendingOp)…
89 …if rf, ok := ret.Get(0).(func(gocbcore.CounterOptions, gocbcore.CounterCallback) gocbcore.PendingO…
112 …if rf, ok := ret.Get(0).(func(gocbcore.DeleteOptions, gocbcore.DeleteCallback) gocbcore.PendingOp)…
131 func (_m *mockKvProvider) Get(opts gocbcore.GetOptions, cb gocbcore.GetCallback) (gocbcore.PendingO…
135 if rf, ok := ret.Get(0).(func(gocbcore.GetOptions, gocbcore.GetCallback) gocbcore.PendingOp); ok {
204 …if rf, ok := ret.Get(0).(func(gocbcore.GetMetaOptions, gocbcore.GetMetaCallback) gocbcore.PendingO…
365 …if rf, ok := ret.Get(0).(func(gocbcore.AdjoinOptions, gocbcore.AdjoinCallback) gocbcore.PendingOp)…
411 …if rf, ok := ret.Get(0).(func(gocbcore.SetOptions, gocbcore.StoreCallback) gocbcore.PendingOp); ok…
[all …]
|
| H A D | transcoding.go | 71 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
74 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
82 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
143 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
146 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
149 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
152 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
155 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
158 flags = gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression)
221 flags = gocbcore.EncodeCommonFlags(gocbcore.StringType, gocbcore.NoCompression)
[all …]
|
| H A D | transcoding_test.go | 60 expectedFlags: gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression),
67 expectedFlags: gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression),
74 expectedFlags: gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression),
81 expectedFlags: gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression),
88 expectedFlags: gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression),
95 expectedFlags: gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression),
102 expectedFlags: gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression),
109 expectedFlags: gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression),
116 expectedFlags: gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression),
123 expectedFlags: gocbcore.EncodeCommonFlags(gocbcore.JSONType, gocbcore.NoCompression),
[all …]
|
| H A D | providers.go | 10 DoHTTPRequest(req *gocbcore.HTTPRequest) (*gocbcore.HTTPResponse, error)
36 cb gocbcore.WaitUntilReadyCallback) (gocbcore.PendingOp, error)
40 Diagnostics(opts gocbcore.DiagnosticsOptions) (*gocbcore.DiagnosticInfo, error)
41 Ping(opts gocbcore.PingOptions) (*gocbcore.PingResult, error)
45 Diagnostics(opts gocbcore.DiagnosticsOptions) (*gocbcore.DiagnosticInfo, error)
46 Ping(opts gocbcore.PingOptions, cb gocbcore.PingCallback) (gocbcore.PendingOp, error)
99 provider *gocbcore.AgentGroup
122 provider *gocbcore.AgentGroup
145 provider *gocbcore.AgentGroup
187 provider *gocbcore.AgentGroup
[all …]
|
| H A D | retry.go | 9 func translateCoreRetryReasons(reasons []gocbcore.RetryReason) []RetryReason {
33 req gocbcore.RetryRequest
61 UnknownRetryReason = RetryReason(gocbcore.UnknownRetryReason)
64 SocketNotAvailableRetryReason = RetryReason(gocbcore.SocketNotAvailableRetryReason)
70 NodeNotAvailableRetryReason = RetryReason(gocbcore.NodeNotAvailableRetryReason)
73 KVNotMyVBucketRetryReason = RetryReason(gocbcore.KVNotMyVBucketRetryReason)
80 KVErrMapRetryReason = RetryReason(gocbcore.KVErrMapRetryReason)
83 KVLockedRetryReason = RetryReason(gocbcore.KVLockedRetryReason)
86 KVTemporaryFailureRetryReason = RetryReason(gocbcore.KVTemporaryFailureRetryReason)
160 …unc (rs *retryStrategyWrapper) RetryAfter(req gocbcore.RetryRequest, reason gocbcore.RetryReason) …
[all …]
|
| H A D | bucket_ping_test.go | 8 gocbcore "github.com/couchbase/gocbcore/v9" packageName
13 expectedResults := map[gocbcore.ServiceType][]gocbcore.EndpointPingResult{
14 gocbcore.MemdService: {
19 State: gocbcore.PingStateOK,
36 gocbcore.N1qlService: {
41 State: gocbcore.PingStateOK,
51 gocbcore.CbasService: {
56 State: gocbcore.PingStateOK,
59 gocbcore.FtsService: {
64 State: gocbcore.PingStateOK,
[all …]
|
| H A D | mock_diagnosticsProvider_test.go | 6 gocbcore "github.com/couchbase/gocbcore/v9" packageName
16 func (_m *mockDiagnosticsProvider) Diagnostics(opts gocbcore.DiagnosticsOptions) (*gocbcore.Diagnos…
19 var r0 *gocbcore.DiagnosticInfo
20 if rf, ok := ret.Get(0).(func(gocbcore.DiagnosticsOptions) *gocbcore.DiagnosticInfo); ok {
24 r0 = ret.Get(0).(*gocbcore.DiagnosticInfo)
29 if rf, ok := ret.Get(1).(func(gocbcore.DiagnosticsOptions) error); ok {
39 func (_m *mockDiagnosticsProvider) Ping(opts gocbcore.PingOptions) (*gocbcore.PingResult, error) {
42 var r0 *gocbcore.PingResult
43 if rf, ok := ret.Get(0).(func(gocbcore.PingOptions) *gocbcore.PingResult); ok {
47 r0 = ret.Get(0).(*gocbcore.PingResult)
[all …]
|
| H A D | logging.go | 8 gocbcore "github.com/couchbase/gocbcore/v9" packageName
12 type LogLevel gocbcore.LogLevel
17 LogError LogLevel = LogLevel(gocbcore.LogError)
18 LogWarn LogLevel = LogLevel(gocbcore.LogWarn)
19 LogInfo LogLevel = LogLevel(gocbcore.LogInfo)
20 LogDebug LogLevel = LogLevel(gocbcore.LogDebug)
43 gocbcore.SetLogRedactionLevel(gocbcore.LogRedactLevel(level))
63 wrapped gocbcore.Logger
74 wrapped: gocbcore.DefaultStdioLogger(),
84 wrapped: gocbcore.VerboseStdioLogger(),
[all …]
|
| H A D | collection_crud.go | 12 Add(opts gocbcore.AddOptions, cb gocbcore.StoreCallback) (gocbcore.PendingOp, error)
13 Set(opts gocbcore.SetOptions, cb gocbcore.StoreCallback) (gocbcore.PendingOp, error)
14 Replace(opts gocbcore.ReplaceOptions, cb gocbcore.StoreCallback) (gocbcore.PendingOp, error)
15 Get(opts gocbcore.GetOptions, cb gocbcore.GetCallback) (gocbcore.PendingOp, error)
17 Observe(opts gocbcore.ObserveOptions, cb gocbcore.ObserveCallback) (gocbcore.PendingOp, error)
19 GetMeta(opts gocbcore.GetMetaOptions, cb gocbcore.GetMetaCallback) (gocbcore.PendingOp, error)
20 Delete(opts gocbcore.DeleteOptions, cb gocbcore.DeleteCallback) (gocbcore.PendingOp, error)
25 Unlock(opts gocbcore.UnlockOptions, cb gocbcore.UnlockCallback) (gocbcore.PendingOp, error)
26 Touch(opts gocbcore.TouchOptions, cb gocbcore.TouchCallback) (gocbcore.PendingOp, error)
29 Append(opts gocbcore.AdjoinOptions, cb gocbcore.AdjoinCallback) (gocbcore.PendingOp, error)
[all …]
|
| H A D | token_test.go | 15 token: gocbcore.MutationToken{
17 VbUUID: gocbcore.VbUUID(9),
18 SeqNo: gocbcore.SeqNo(12),
23 token: gocbcore.MutationToken{
25 VbUUID: gocbcore.VbUUID(1),
26 SeqNo: gocbcore.SeqNo(22),
31 token: gocbcore.MutationToken{
33 VbUUID: gocbcore.VbUUID(4),
34 SeqNo: gocbcore.SeqNo(99),
75 VbUUID: gocbcore.VbUUID(9),
[all …]
|
| H A D | retry_test.go | 27 reasons []gocbcore.RetryReason
29 gocbcore.RetryRequest
44 func (mgr *mockGocbcoreRequest) RetryReasons() []gocbcore.RetryReason {
94 …reasons: []gocbcore.RetryReason{gocbcore.KVCollectionOutdatedRetryReason, gocbcore.UnknownRetryRea…
96 action := strategy.RetryAfter(request, gocbcore.UnknownRetryReason)
104 action := strategy.RetryAfter(&mockRetryRequest{}, RetryReason(gocbcore.UnknownRetryReason))
125 action := strategy.RetryAfter(&mockRetryRequest{}, RetryReason(gocbcore.KVLockedRetryReason))
130 …action = strategy.RetryAfter(&mockRetryRequest{attempts: 5}, RetryReason(gocbcore.KVLockedRetryRea…
143 …action = strategy.RetryAfter(&mockRetryRequest{attempts: 5}, RetryReason(gocbcore.KVLockedRetryRea…
151 action := strategy.RetryAfter(&mockRetryRequest{}, RetryReason(gocbcore.UnknownRetryReason))
[all …]
|
| H A D | cluster_ping_test.go | 8 gocbcore "github.com/couchbase/gocbcore/v9" packageName
56 expectedResults := map[gocbcore.ServiceType][]gocbcore.EndpointPingResult{
57 gocbcore.N1qlService: {
62 State: gocbcore.PingStateOK,
72 gocbcore.CbasService: {
77 State: gocbcore.PingStateOK,
80 gocbcore.FtsService: {
85 State: gocbcore.PingStateOK,
89 pingResult := &gocbcore.PingResult{
156 expectedResults := map[gocbcore.ServiceType][]gocbcore.EndpointPingResult{
[all …]
|
| H A D | mock_httpProvider_test.go | 6 gocbcore "github.com/couchbase/gocbcore/v9" packageName
16 func (_m *mockHttpProvider) DoHTTPRequest(req *gocbcore.HTTPRequest) (*gocbcore.HTTPResponse, error…
19 var r0 *gocbcore.HTTPResponse
20 if rf, ok := ret.Get(0).(func(*gocbcore.HTTPRequest) *gocbcore.HTTPResponse); ok {
24 r0 = ret.Get(0).(*gocbcore.HTTPResponse)
29 if rf, ok := ret.Get(1).(func(*gocbcore.HTTPRequest) error); ok {
|
| H A D | constants.go | 4 gocbcore "github.com/couchbase/gocbcore/v9" packageName
59 type ServiceType gocbcore.ServiceType
63 ServiceTypeManagement ServiceType = ServiceType(gocbcore.MgmtService)
66 ServiceTypeKeyValue ServiceType = ServiceType(gocbcore.MemdService)
69 ServiceTypeViews ServiceType = ServiceType(gocbcore.CapiService)
72 ServiceTypeQuery ServiceType = ServiceType(gocbcore.N1qlService)
75 ServiceTypeSearch ServiceType = ServiceType(gocbcore.FtsService)
78 ServiceTypeAnalytics ServiceType = ServiceType(gocbcore.CbasService)
|
| H A D | mock_queryProvider_test.go | 6 gocbcore "github.com/couchbase/gocbcore/v9" packageName
16 func (_m *mockQueryProvider) N1QLQuery(opts gocbcore.N1QLQueryOptions) (queryRowReader, error) {
20 if rf, ok := ret.Get(0).(func(gocbcore.N1QLQueryOptions) queryRowReader); ok {
29 if rf, ok := ret.Get(1).(func(gocbcore.N1QLQueryOptions) error); ok {
39 func (_m *mockQueryProvider) PreparedN1QLQuery(opts gocbcore.N1QLQueryOptions) (queryRowReader, err…
43 if rf, ok := ret.Get(0).(func(gocbcore.N1QLQueryOptions) queryRowReader); ok {
52 if rf, ok := ret.Get(1).(func(gocbcore.N1QLQueryOptions) error); ok {
|
| H A D | collection_dura.go | 6 gocbcore "github.com/couchbase/gocbcore/v9" packageName
12 mt gocbcore.MutationToken,
28 err = opm.Wait(agent.ObserveVb(gocbcore.ObserveVbOptions{
34 }, func(res *gocbcore.ObserveVbResult, err error) {
55 mt gocbcore.MutationToken,
64 calc := gocbcore.ExponentialBackoff(10*time.Microsecond, 100*time.Millisecond, 0)
97 waitTmr := gocbcore.AcquireTimer(calc(retries))
101 gocbcore.ReleaseTimer(waitTmr, true)
103 gocbcore.ReleaseTimer(waitTmr, false)
111 mt gocbcore.MutationToken,
|