vault: Index | Files

package oci

import ""

Copyright © 2019, Oracle and/or its affiliates.

Copyright © 2019, Oracle and/or its affiliates.


Package Files

oci.go oci_ha.go


const (
    // LockRenewInterval is the time to wait between lock renewals.
    LockRenewInterval = 3 * time.Second

    // LockRetryInterval is the amount of time to wait if the lock fails before trying again.
    LockRetryInterval = 5 * time.Second

    // LockWatchRetryInterval is the amount of time to wait if a watch fails before trying again.
    LockWatchRetryInterval = 2 * time.Second

    // LockTTL is the default lock TTL.
    LockTTL = 15 * time.Second

    // LockWatchRetryMax is the number of times to retry a failed watch before signaling that leadership is lost.
    LockWatchRetryMax = 4

    // LockCacheMinAcceptableAge is minimum cache age in seconds to determine that its safe for a secondary instance
    // to acquire lock.
    LockCacheMinAcceptableAge = 45 * time.Second

    // LockWriteRetriesOnFailures is the number of retries that are made on write 5xx failures.
    LockWriteRetriesOnFailures = 4

    ObjectStorageCallsReadTimeout = 3 * time.Second

    ObjectStorageCallsWriteTimeout = 3 * time.Second
const (
    // Limits maximum outstanding requests
    MaxNumberOfPermits = 256

func NewBackend Uses

func NewBackend(conf map[string]string, logger log.Logger) (physical.Backend, error)

type Backend Uses

type Backend struct {
    // contains filtered or unexported fields

func (*Backend) Delete Uses

func (o *Backend) Delete(ctx context.Context, key string) error

func (*Backend) Get Uses

func (o *Backend) Get(ctx context.Context, key string) (*physical.Entry, error)

func (*Backend) HAEnabled Uses

func (b *Backend) HAEnabled() bool

func (*Backend) List Uses

func (o *Backend) List(ctx context.Context, prefix string) ([]string, error)

func (*Backend) LockWith Uses

func (b *Backend) LockWith(key, value string) (physical.Lock, error)

LockWith acquires a mutual exclusion based on the given Key.

func (*Backend) Put Uses

func (o *Backend) Put(ctx context.Context, entry *physical.Entry) error

type Lock Uses

type Lock struct {
    // contains filtered or unexported fields

func (*Lock) Lock Uses

func (l *Lock) Lock(stopCh <-chan struct{}) (<-chan struct{}, error)

func (*Lock) Unlock Uses

func (l *Lock) Unlock() error

func (*Lock) Value Uses

func (l *Lock) Value() (bool, string, error)

type LockCache Uses

type LockCache struct {
    // contains filtered or unexported fields

type LockRecord Uses

type LockRecord struct {
    Key      string
    Value    string
    Identity string

Package oci imports 23 packages (graph) and is imported by 2 packages. Updated 2020-01-08. Refresh now. Tools for package owners.