Documentation ¶
Index ¶
- func Factory(ctx context.Context, conf *logical.BackendConfig) (logical.Backend, error)
- func LeaseSwitchedPassthroughBackend(ctx context.Context, conf *logical.BackendConfig, leases bool) (logical.Backend, error)
- func LeasedPassthroughBackendFactory(ctx context.Context, conf *logical.BackendConfig) (logical.Backend, error)
- func PassthroughBackendFactory(ctx context.Context, conf *logical.BackendConfig) (logical.Backend, error)
- func VersionedKVFactory(ctx context.Context, conf *logical.BackendConfig) (logical.Backend, error)
- type Configuration
- func (*Configuration) Descriptor() ([]byte, []int)
- func (c *Configuration) DisableDeleteVersionAfter()
- func (m *Configuration) GetCasRequired() bool
- func (m *Configuration) GetDeleteVersionAfter() *duration.Duration
- func (m *Configuration) GetMaxVersions() uint32
- func (c *Configuration) IsDeleteVersionAfterDisabled() bool
- func (*Configuration) ProtoMessage()
- func (m *Configuration) Reset()
- func (c *Configuration) ResetDeleteVersionAfter()
- func (m *Configuration) String() string
- func (m *Configuration) XXX_DiscardUnknown()
- func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Configuration) XXX_Merge(src proto.Message)
- func (m *Configuration) XXX_Size() int
- func (m *Configuration) XXX_Unmarshal(b []byte) error
- type KeyMetadata
- func (k *KeyMetadata) AddVersion(createdTime, deletionTime *timestamp.Timestamp, configMaxVersions uint32) (*VersionMetadata, uint64)
- func (*KeyMetadata) Descriptor() ([]byte, []int)
- func (m *KeyMetadata) GetCasRequired() bool
- func (m *KeyMetadata) GetCreatedTime() *timestamp.Timestamp
- func (m *KeyMetadata) GetCurrentVersion() uint64
- func (m *KeyMetadata) GetDeleteVersionAfter() *duration.Duration
- func (m *KeyMetadata) GetKey() string
- func (m *KeyMetadata) GetMaxVersions() uint32
- func (m *KeyMetadata) GetOldestVersion() uint64
- func (m *KeyMetadata) GetUpdatedTime() *timestamp.Timestamp
- func (m *KeyMetadata) GetVersions() map[uint64]*VersionMetadata
- func (*KeyMetadata) ProtoMessage()
- func (m *KeyMetadata) Reset()
- func (m *KeyMetadata) String() string
- func (m *KeyMetadata) XXX_DiscardUnknown()
- func (m *KeyMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *KeyMetadata) XXX_Merge(src proto.Message)
- func (m *KeyMetadata) XXX_Size() int
- func (m *KeyMetadata) XXX_Unmarshal(b []byte) error
- type Passthrough
- type PassthroughBackend
- type UpgradeInfo
- func (*UpgradeInfo) Descriptor() ([]byte, []int)
- func (m *UpgradeInfo) GetDone() bool
- func (m *UpgradeInfo) GetStartedTime() *timestamp.Timestamp
- func (*UpgradeInfo) ProtoMessage()
- func (m *UpgradeInfo) Reset()
- func (m *UpgradeInfo) String() string
- func (m *UpgradeInfo) XXX_DiscardUnknown()
- func (m *UpgradeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *UpgradeInfo) XXX_Merge(src proto.Message)
- func (m *UpgradeInfo) XXX_Size() int
- func (m *UpgradeInfo) XXX_Unmarshal(b []byte) error
- type Version
- func (*Version) Descriptor() ([]byte, []int)
- func (m *Version) GetCreatedTime() *timestamp.Timestamp
- func (m *Version) GetData() []byte
- func (m *Version) GetDeletionTime() *timestamp.Timestamp
- func (*Version) ProtoMessage()
- func (m *Version) Reset()
- func (m *Version) String() string
- func (m *Version) XXX_DiscardUnknown()
- func (m *Version) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Version) XXX_Merge(src proto.Message)
- func (m *Version) XXX_Size() int
- func (m *Version) XXX_Unmarshal(b []byte) error
- type VersionMetadata
- func (*VersionMetadata) Descriptor() ([]byte, []int)
- func (m *VersionMetadata) GetCreatedTime() *timestamp.Timestamp
- func (m *VersionMetadata) GetDeletionTime() *timestamp.Timestamp
- func (m *VersionMetadata) GetDestroyed() bool
- func (*VersionMetadata) ProtoMessage()
- func (m *VersionMetadata) Reset()
- func (m *VersionMetadata) String() string
- func (m *VersionMetadata) XXX_DiscardUnknown()
- func (m *VersionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *VersionMetadata) XXX_Merge(src proto.Message)
- func (m *VersionMetadata) XXX_Size() int
- func (m *VersionMetadata) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Factory ¶
Factory will return a logical backend of type versionedKVBackend or PassthroughBackend based on the config passed in.
func LeaseSwitchedPassthroughBackend ¶
func LeaseSwitchedPassthroughBackend(ctx context.Context, conf *logical.BackendConfig, leases bool) (logical.Backend, error)
LeaseSwitchedPassthroughBackend returns a PassthroughBackend with leases switched on or off
func LeasedPassthroughBackendFactory ¶
func LeasedPassthroughBackendFactory(ctx context.Context, conf *logical.BackendConfig) (logical.Backend, error)
LeasedPassthroughBackendFactory returns a PassthroughBackend with leases switched on
func PassthroughBackendFactory ¶
func PassthroughBackendFactory(ctx context.Context, conf *logical.BackendConfig) (logical.Backend, error)
PassthroughBackendFactory returns a PassthroughBackend with leases switched off
func VersionedKVFactory ¶
Factory returns a new backend as logical.Backend.
Types ¶
type Configuration ¶
type Configuration struct { MaxVersions uint32 `protobuf:"varint,1,opt,name=max_versions,json=maxVersions,proto3" json:"max_versions,omitempty"` CasRequired bool `protobuf:"varint,2,opt,name=cas_required,json=casRequired,proto3" json:"cas_required,omitempty"` DeleteVersionAfter *duration.Duration `protobuf:"bytes,3,opt,name=delete_version_after,json=deleteVersionAfter,proto3" json:"delete_version_after,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
If values are added to this, be sure to update the config() function
func (*Configuration) Descriptor ¶
func (*Configuration) Descriptor() ([]byte, []int)
func (*Configuration) DisableDeleteVersionAfter ¶ added in v0.5.2
func (c *Configuration) DisableDeleteVersionAfter()
DisableDeleteVersionAfter disables DeleteVersionAfter.
func (*Configuration) GetCasRequired ¶
func (m *Configuration) GetCasRequired() bool
func (*Configuration) GetDeleteVersionAfter ¶ added in v0.5.2
func (m *Configuration) GetDeleteVersionAfter() *duration.Duration
func (*Configuration) GetMaxVersions ¶
func (m *Configuration) GetMaxVersions() uint32
func (*Configuration) IsDeleteVersionAfterDisabled ¶ added in v0.5.2
func (c *Configuration) IsDeleteVersionAfterDisabled() bool
IsDeleteVersionAfterDisabled returns true if DeleteVersionAfter is disabled.
func (*Configuration) ProtoMessage ¶
func (*Configuration) ProtoMessage()
func (*Configuration) Reset ¶
func (m *Configuration) Reset()
func (*Configuration) ResetDeleteVersionAfter ¶ added in v0.5.2
func (c *Configuration) ResetDeleteVersionAfter()
ResetDeleteVersionAfter resets the DeleteVersionAfter to the default value.
func (*Configuration) String ¶
func (m *Configuration) String() string
func (*Configuration) XXX_DiscardUnknown ¶ added in v0.5.2
func (m *Configuration) XXX_DiscardUnknown()
func (*Configuration) XXX_Marshal ¶ added in v0.5.2
func (m *Configuration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Configuration) XXX_Merge ¶ added in v0.5.2
func (m *Configuration) XXX_Merge(src proto.Message)
func (*Configuration) XXX_Size ¶ added in v0.5.2
func (m *Configuration) XXX_Size() int
func (*Configuration) XXX_Unmarshal ¶ added in v0.5.2
func (m *Configuration) XXX_Unmarshal(b []byte) error
type KeyMetadata ¶
type KeyMetadata struct { // Key is the key for this entry Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"` // Versions is the map of versionID -> VersionMetadata. // Useful when listing all versions. Versions map[uint64]*VersionMetadata `` /* 158-byte string literal not displayed */ // CurrentVersion is the latest version of the value CurrentVersion uint64 `protobuf:"varint,3,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"` // OldestVersion is the oldest version of the value. OldestVersion uint64 `protobuf:"varint,4,opt,name=oldest_version,json=oldestVersion,proto3" json:"oldest_version,omitempty"` // Created time is when the metadata was created. CreatedTime *timestamp.Timestamp `protobuf:"bytes,5,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"` // Updated time was the last time the metadata version // was updated. UpdatedTime *timestamp.Timestamp `protobuf:"bytes,6,opt,name=updated_time,json=updatedTime,proto3" json:"updated_time,omitempty"` // MaxVersions specifies how many versions to keep around. // If empty value, defaults to the configured Max // for the mount. MaxVersions uint32 `protobuf:"varint,7,opt,name=max_versions,json=maxVersions,proto3" json:"max_versions,omitempty"` // CasRequired specifies if the cas parameter is // required for this key CasRequired bool `protobuf:"varint,8,opt,name=cas_required,json=casRequired,proto3" json:"cas_required,omitempty"` // DeleteVersionAfter specifies how long to keep versions around. If // empty value, defaults to the configured delete_version_after for the // mount. DeleteVersionAfter *duration.Duration `protobuf:"bytes,9,opt,name=delete_version_after,json=deleteVersionAfter,proto3" json:"delete_version_after,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*KeyMetadata) AddVersion ¶
func (k *KeyMetadata) AddVersion(createdTime, deletionTime *timestamp.Timestamp, configMaxVersions uint32) (*VersionMetadata, uint64)
AddVersion adds a version to the key metadata and moves the sliding window of max versions. It returns the newly added version and the version to delete from storage.
func (*KeyMetadata) Descriptor ¶
func (*KeyMetadata) Descriptor() ([]byte, []int)
func (*KeyMetadata) GetCasRequired ¶
func (m *KeyMetadata) GetCasRequired() bool
func (*KeyMetadata) GetCreatedTime ¶
func (m *KeyMetadata) GetCreatedTime() *timestamp.Timestamp
func (*KeyMetadata) GetCurrentVersion ¶
func (m *KeyMetadata) GetCurrentVersion() uint64
func (*KeyMetadata) GetDeleteVersionAfter ¶ added in v0.5.2
func (m *KeyMetadata) GetDeleteVersionAfter() *duration.Duration
func (*KeyMetadata) GetKey ¶
func (m *KeyMetadata) GetKey() string
func (*KeyMetadata) GetMaxVersions ¶
func (m *KeyMetadata) GetMaxVersions() uint32
func (*KeyMetadata) GetOldestVersion ¶
func (m *KeyMetadata) GetOldestVersion() uint64
func (*KeyMetadata) GetUpdatedTime ¶
func (m *KeyMetadata) GetUpdatedTime() *timestamp.Timestamp
func (*KeyMetadata) GetVersions ¶
func (m *KeyMetadata) GetVersions() map[uint64]*VersionMetadata
func (*KeyMetadata) ProtoMessage ¶
func (*KeyMetadata) ProtoMessage()
func (*KeyMetadata) Reset ¶
func (m *KeyMetadata) Reset()
func (*KeyMetadata) String ¶
func (m *KeyMetadata) String() string
func (*KeyMetadata) XXX_DiscardUnknown ¶ added in v0.5.2
func (m *KeyMetadata) XXX_DiscardUnknown()
func (*KeyMetadata) XXX_Marshal ¶ added in v0.5.2
func (m *KeyMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*KeyMetadata) XXX_Merge ¶ added in v0.5.2
func (m *KeyMetadata) XXX_Merge(src proto.Message)
func (*KeyMetadata) XXX_Size ¶ added in v0.5.2
func (m *KeyMetadata) XXX_Size() int
func (*KeyMetadata) XXX_Unmarshal ¶ added in v0.5.2
func (m *KeyMetadata) XXX_Unmarshal(b []byte) error
type Passthrough ¶
type Passthrough interface {
// contains filtered or unexported methods
}
type PassthroughBackend ¶
PassthroughBackend is used storing secrets directly into the physical backend. The secrets are encrypted in the durable storage and custom TTL information can be specified, but otherwise this backend doesn't do anything fancy.
func (*PassthroughBackend) GeneratesLeases ¶
func (b *PassthroughBackend) GeneratesLeases() bool
type UpgradeInfo ¶
type UpgradeInfo struct { // Started time is when the upgrade was started. StartedTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=started_time,json=startedTime,proto3" json:"started_time,omitempty"` // done is set to true once the backend has been successfully // upgraded. Done bool `protobuf:"varint,2,opt,name=done,proto3" json:"done,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*UpgradeInfo) Descriptor ¶
func (*UpgradeInfo) Descriptor() ([]byte, []int)
func (*UpgradeInfo) GetDone ¶
func (m *UpgradeInfo) GetDone() bool
func (*UpgradeInfo) GetStartedTime ¶
func (m *UpgradeInfo) GetStartedTime() *timestamp.Timestamp
func (*UpgradeInfo) ProtoMessage ¶
func (*UpgradeInfo) ProtoMessage()
func (*UpgradeInfo) Reset ¶
func (m *UpgradeInfo) Reset()
func (*UpgradeInfo) String ¶
func (m *UpgradeInfo) String() string
func (*UpgradeInfo) XXX_DiscardUnknown ¶ added in v0.5.2
func (m *UpgradeInfo) XXX_DiscardUnknown()
func (*UpgradeInfo) XXX_Marshal ¶ added in v0.5.2
func (m *UpgradeInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*UpgradeInfo) XXX_Merge ¶ added in v0.5.2
func (m *UpgradeInfo) XXX_Merge(src proto.Message)
func (*UpgradeInfo) XXX_Size ¶ added in v0.5.2
func (m *UpgradeInfo) XXX_Size() int
func (*UpgradeInfo) XXX_Unmarshal ¶ added in v0.5.2
func (m *UpgradeInfo) XXX_Unmarshal(b []byte) error
type Version ¶
type Version struct { // Data is a JSON object with string keys that // represents the user supplied data. Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"` // CreatedTime is when the version was created. CreatedTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"` // DeletionTime is the time this version becomes invalid. // Set to Now() to delete the version before the configured // deletion time. DeletionTime *timestamp.Timestamp `protobuf:"bytes,3,opt,name=deletion_time,json=deletionTime,proto3" json:"deletion_time,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Version) Descriptor ¶
func (*Version) GetCreatedTime ¶
func (*Version) GetDeletionTime ¶
func (*Version) ProtoMessage ¶
func (*Version) ProtoMessage()
func (*Version) XXX_DiscardUnknown ¶ added in v0.5.2
func (m *Version) XXX_DiscardUnknown()
func (*Version) XXX_Marshal ¶ added in v0.5.2
func (*Version) XXX_Unmarshal ¶ added in v0.5.2
type VersionMetadata ¶
type VersionMetadata struct { // CreatedTime is when the version was created. CreatedTime *timestamp.Timestamp `protobuf:"bytes,1,opt,name=created_time,json=createdTime,proto3" json:"created_time,omitempty"` // DeletionTime is the time this version becomes invalid. // Set to Now() to delete the version before the configured // delete time. DeletionTime *timestamp.Timestamp `protobuf:"bytes,2,opt,name=deletion_time,json=deletionTime,proto3" json:"deletion_time,omitempty"` // Destroyed is used to specify this version is // a has been removed and the underlying data deleted. Destroyed bool `protobuf:"varint,3,opt,name=destroyed,proto3" json:"destroyed,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*VersionMetadata) Descriptor ¶
func (*VersionMetadata) Descriptor() ([]byte, []int)
func (*VersionMetadata) GetCreatedTime ¶
func (m *VersionMetadata) GetCreatedTime() *timestamp.Timestamp
func (*VersionMetadata) GetDeletionTime ¶
func (m *VersionMetadata) GetDeletionTime() *timestamp.Timestamp
func (*VersionMetadata) GetDestroyed ¶
func (m *VersionMetadata) GetDestroyed() bool
func (*VersionMetadata) ProtoMessage ¶
func (*VersionMetadata) ProtoMessage()
func (*VersionMetadata) Reset ¶
func (m *VersionMetadata) Reset()
func (*VersionMetadata) String ¶
func (m *VersionMetadata) String() string
func (*VersionMetadata) XXX_DiscardUnknown ¶ added in v0.5.2
func (m *VersionMetadata) XXX_DiscardUnknown()
func (*VersionMetadata) XXX_Marshal ¶ added in v0.5.2
func (m *VersionMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*VersionMetadata) XXX_Merge ¶ added in v0.5.2
func (m *VersionMetadata) XXX_Merge(src proto.Message)
func (*VersionMetadata) XXX_Size ¶ added in v0.5.2
func (m *VersionMetadata) XXX_Size() int
func (*VersionMetadata) XXX_Unmarshal ¶ added in v0.5.2
func (m *VersionMetadata) XXX_Unmarshal(b []byte) error