cache

Documentation

Index

• func Handler(ctx context.Context, logger hclog.Logger, proxier Proxier, inmemSink sink.Sink, ...) http.Handler
• func StartListener(lnConfig *configutil.Listener) (net.Listener, *tls.Config, error)
• type APIProxy
  • func (ap *APIProxy) Send(ctx context.Context, req *SendRequest) (*SendResponse, error)
• type APIProxyConfig
• type CacheMeta
• type EnforceConsistency
• type LeaseCache
  • func NewLeaseCache(conf *LeaseCacheConfig) (*LeaseCache, error)
  • func (c *LeaseCache) Evict(index *cachememdb.Index) error
  • func (c *LeaseCache) Flush() error
  • func (c *LeaseCache) HandleCacheClear(ctx context.Context) http.Handler
  • func (c *LeaseCache) RegisterAutoAuthToken(token string) error
  • func (c *LeaseCache) Restore(ctx context.Context, storage *cacheboltdb.BoltStorage) error
  • func (c *LeaseCache) Send(ctx context.Context, req *SendRequest) (*SendResponse, error)
  • func (c *LeaseCache) Set(ctx context.Context, index *cachememdb.Index) error
  • func (c *LeaseCache) SetPersistentStorage(storageIn *cacheboltdb.BoltStorage)
  • func (c *LeaseCache) SetShuttingDown(in bool)
• type LeaseCacheConfig
• type Proxier
  • func NewAPIProxy(config *APIProxyConfig) (Proxier, error)
• type SendRequest
• type SendResponse
  • func NewSendResponse(apiResponse *api.Response, responseBody []byte) (*SendResponse, error)
• type WhenInconsistentAction

Functions

func Handler

func Handler(ctx context.Context, logger hclog.Logger, proxier Proxier, inmemSink sink.Sink, proxyVaultToken bool) http.Handler

func StartListener

func StartListener(lnConfig *configutil.Listener) (net.Listener, *tls.Config, error)

Types

type APIProxy

type APIProxy struct {
	// contains filtered or unexported fields
}

APIProxy is an implementation of the proxier interface that is used to forward the request to Vault and get the response.

func (*APIProxy) Send

func (ap *APIProxy) Send(ctx context.Context, req *SendRequest) (*SendResponse, error)

type APIProxyConfig

type APIProxyConfig struct {
	Client                 *api.Client
	Logger                 hclog.Logger
	EnforceConsistency     EnforceConsistency
	WhenInconsistentAction WhenInconsistentAction
}

type CacheMeta

type CacheMeta struct {
	Hit bool
	Age time.Duration
}

CacheMeta contains metadata information about the response, such as whether it was a cache hit or miss, and the age of the cached entry.

type EnforceConsistency

type EnforceConsistency int

const (
	EnforceConsistencyNever EnforceConsistency = iota
	EnforceConsistencyAlways
)

type LeaseCache

type LeaseCache struct {
	// contains filtered or unexported fields
}

LeaseCache is an implementation of Proxier that handles the caching of responses. It passes the incoming request to an underlying Proxier implementation.

func NewLeaseCache

func NewLeaseCache(conf *LeaseCacheConfig) (*LeaseCache, error)

NewLeaseCache creates a new instance of a LeaseCache.

func (*LeaseCache) Evict

func (c *LeaseCache) Evict(index *cachememdb.Index) error

Evict removes an Index from the cachememdb, and also removes it from the persistent cache (if enabled)

func (*LeaseCache) Flush

func (c *LeaseCache) Flush() error

Flush the cachememdb and persistent cache (if enabled)

func (*LeaseCache) HandleCacheClear

func (c *LeaseCache) HandleCacheClear(ctx context.Context) http.Handler

HandleCacheClear returns a handlerFunc that can perform cache clearing operations.

func (*LeaseCache) RegisterAutoAuthToken

func (c *LeaseCache) RegisterAutoAuthToken(token string) error

RegisterAutoAuthToken adds the provided auto-token into the cache. This is primarily used to register the auto-auth token and should only be called within a sink's WriteToken func.

func (*LeaseCache) Restore

func (c *LeaseCache) Restore(ctx context.Context, storage *cacheboltdb.BoltStorage) error

Restore loads the cachememdb from the persistent storage passed in. Loads tokens first, since restoring a lease's renewal context and watcher requires looking up the token in the cachememdb.

func (*LeaseCache) Send

func (c *LeaseCache) Send(ctx context.Context, req *SendRequest) (*SendResponse, error)

Send performs a cache lookup on the incoming request. If it's a cache hit, it will return the cached response, otherwise it will delegate to the underlying Proxier and cache the received response.

func (*LeaseCache) Set

func (c *LeaseCache) Set(ctx context.Context, index *cachememdb.Index) error

Set stores the index in the cachememdb, and also stores it in the persistent cache (if enabled)

func (*LeaseCache) SetPersistentStorage

func (c *LeaseCache) SetPersistentStorage(storageIn *cacheboltdb.BoltStorage)

SetPersistentStorage is a setter for the persistent storage field in LeaseCache

func (*LeaseCache) SetShuttingDown

func (c *LeaseCache) SetShuttingDown(in bool)

SetShuttingDown is a setter for the shuttingDown field

type LeaseCacheConfig

type LeaseCacheConfig struct {
	Client      *api.Client
	BaseContext context.Context
	Proxier     Proxier
	Logger      hclog.Logger
	Storage     *cacheboltdb.BoltStorage
}

LeaseCacheConfig is the configuration for initializing a new Lease.

type Proxier

type Proxier interface {
	Send(ctx context.Context, req *SendRequest) (*SendResponse, error)
}

Proxier is the interface implemented by different components that are responsible for performing specific tasks, such as caching and proxying. All these tasks combined together would serve the request received by the agent.

func NewAPIProxy

func NewAPIProxy(config *APIProxyConfig) (Proxier, error)

type SendRequest

type SendRequest struct {
	Token   string
	Request *http.Request

	// RequestBody is the stored body bytes from Request.Body. It is set here to
	// avoid reading and re-setting the stream multiple times.
	RequestBody []byte
}

SendRequest is the input for Proxier.Send.

type SendResponse

type SendResponse struct {
	Response *api.Response

	// ResponseBody is the stored body bytes from Response.Body. It is set here to
	// avoid reading and re-setting the stream multiple times.
	ResponseBody []byte
	CacheMeta    *CacheMeta
}

SendResponse is the output from Proxier.Send.

func NewSendResponse

func NewSendResponse(apiResponse *api.Response, responseBody []byte) (*SendResponse, error)

NewSendResponse creates a new SendResponse and takes care of initializing its fields properly.

type WhenInconsistentAction

type WhenInconsistentAction int

const (
	WhenInconsistentFail WhenInconsistentAction = iota
	WhenInconsistentRetry
	WhenInconsistentForward
)