CacheClient

Documentation

Index

• type CacheClientBound
• type CacheClientBoundImpl
  • func NewCacheClientBound(name string, c cache.Client) *CacheClientBoundImpl
  • func (ccb *CacheClientBoundImpl) GetValue(ctx context.Context, candidateName string, path *sdcpb.Path) (*sdcpb.TypedValue, error)
  • func (ccb *CacheClientBoundImpl) GetValues(ctx context.Context, candidateName string, path *sdcpb.Path) ([]*sdcpb.TypedValue, error)
  • func (ccb *CacheClientBoundImpl) ReadIntended(ctx context.Context, opts *cache.Opts, paths [][]string, period time.Duration) []*cache.Update

Types

type CacheClientBound

type CacheClientBound interface {
	// GetValue retrieves config value for the provided path
	GetValue(ctx context.Context, candidateName string, path *sdcpb.Path) (*sdcpb.TypedValue, error)
	// GetValues retrieves config value from the provided path. If path is not a leaf path, all the sub paths will be returned.
	GetValues(ctx context.Context, candidateName string, path *sdcpb.Path) ([]*sdcpb.TypedValue, error)
	// ReadIntended retrieves the highes priority value from the intended store
	ReadIntended(ctx context.Context, opts *cache.Opts, paths [][]string, period time.Duration) []*cache.Update
}

type CacheClientBoundImpl

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

func NewCacheClientBound

func NewCacheClientBound(name string, c cache.Client) *CacheClientBoundImpl

func (*CacheClientBoundImpl) GetValue

func (ccb *CacheClientBoundImpl) GetValue(ctx context.Context, candidateName string, path *sdcpb.Path) (*sdcpb.TypedValue, error)

GetValue retrieves config value for the provided path

func (*CacheClientBoundImpl) GetValues

func (ccb *CacheClientBoundImpl) GetValues(ctx context.Context, candidateName string, path *sdcpb.Path) ([]*sdcpb.TypedValue, error)

GetValues retrieves config value from the provided path. If path is not a leaf path, all the sub paths will be returned.

func (*CacheClientBoundImpl) ReadIntended

func (ccb *CacheClientBoundImpl) ReadIntended(ctx context.Context, opts *cache.Opts, paths [][]string, period time.Duration) []*cache.Update

Read