Documentation
¶
Index ¶
- type CacheClientBound
- type CacheClientBoundImpl
- func (c *CacheClientBoundImpl) InstanceClose(ctx context.Context) error
- func (c *CacheClientBoundImpl) InstanceCreate(ctx context.Context) error
- func (c *CacheClientBoundImpl) InstanceDelete(ctx context.Context) error
- func (c *CacheClientBoundImpl) InstanceExists(ctx context.Context) bool
- func (c *CacheClientBoundImpl) IntentDelete(ctx context.Context, intentName string) error
- func (c *CacheClientBoundImpl) IntentExists(ctx context.Context, intentName string) (bool, error)
- func (c *CacheClientBoundImpl) IntentGet(ctx context.Context, intentName string) (*tree_persist.Intent, error)
- func (c *CacheClientBoundImpl) IntentGetAll(ctx context.Context, excludeIntentNames []string, ...)
- func (c *CacheClientBoundImpl) IntentModify(ctx context.Context, intent *tree_persist.Intent) error
- func (c *CacheClientBoundImpl) IntentsList(ctx context.Context) ([]string, error)
- type Client
- type LocalCache
- func (l *LocalCache) InstanceIntentGet(ctx context.Context, cacheName string, intentName string) (*tree_persist.Intent, error)
- func (l *LocalCache) InstanceIntentGetAll(ctx context.Context, cacheName string, excludeIntentNames []string, ...)
- func (l *LocalCache) InstanceIntentModify(ctx context.Context, cacheName string, intent *tree_persist.Intent) error
- type Update
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CacheClientBound ¶ added in v0.0.56
type CacheClientBound interface {
InstanceCreate(ctx context.Context) error
InstanceDelete(ctx context.Context) error
InstanceExists(ctx context.Context) bool
IntentsList(ctx context.Context) ([]string, error)
IntentGet(ctx context.Context, intentName string) (*tree_persist.Intent, error)
IntentModify(ctx context.Context, intent *tree_persist.Intent) error
IntentDelete(ctx context.Context, intentName string) error
IntentExists(ctx context.Context, intentName string) (bool, error)
IntentGetAll(ctx context.Context, excludeIntentNames []string, intentChan chan<- *tree_persist.Intent, errChan chan<- error)
InstanceClose(ctx context.Context) error
}
type CacheClientBoundImpl ¶ added in v0.0.56
type CacheClientBoundImpl struct {
// contains filtered or unexported fields
}
func NewCacheClientBound ¶ added in v0.0.56
func NewCacheClientBound(name string, c Client) *CacheClientBoundImpl
func (*CacheClientBoundImpl) InstanceClose ¶ added in v0.0.56
func (c *CacheClientBoundImpl) InstanceClose(ctx context.Context) error
func (*CacheClientBoundImpl) InstanceCreate ¶ added in v0.0.56
func (c *CacheClientBoundImpl) InstanceCreate(ctx context.Context) error
func (*CacheClientBoundImpl) InstanceDelete ¶ added in v0.0.56
func (c *CacheClientBoundImpl) InstanceDelete(ctx context.Context) error
func (*CacheClientBoundImpl) InstanceExists ¶ added in v0.0.56
func (c *CacheClientBoundImpl) InstanceExists(ctx context.Context) bool
func (*CacheClientBoundImpl) IntentDelete ¶ added in v0.0.56
func (c *CacheClientBoundImpl) IntentDelete(ctx context.Context, intentName string) error
func (*CacheClientBoundImpl) IntentExists ¶ added in v0.0.56
func (*CacheClientBoundImpl) IntentGet ¶ added in v0.0.56
func (c *CacheClientBoundImpl) IntentGet(ctx context.Context, intentName string) (*tree_persist.Intent, error)
func (*CacheClientBoundImpl) IntentGetAll ¶ added in v0.0.56
func (c *CacheClientBoundImpl) IntentGetAll(ctx context.Context, excludeIntentNames []string, intentChan chan<- *tree_persist.Intent, errChan chan<- error)
func (*CacheClientBoundImpl) IntentModify ¶ added in v0.0.56
func (c *CacheClientBoundImpl) IntentModify(ctx context.Context, intent *tree_persist.Intent) error
func (*CacheClientBoundImpl) IntentsList ¶ added in v0.0.56
func (c *CacheClientBoundImpl) IntentsList(ctx context.Context) ([]string, error)
type Client ¶
type Client interface {
InstanceCreate(ctx context.Context, cacheInstanceName string) error
InstanceDelete(ctx context.Context, cacheInstanceName string) error
InstanceClose(ctx context.Context, cacheInstanceName string) error
InstanceExists(ctx context.Context, cacheInstanceName string) bool
InstancesList(ctx context.Context) []string
InstanceIntentsList(ctx context.Context, cacheInstanceName string) ([]string, error)
InstanceIntentGet(ctx context.Context, cacheName string, intentName string) (*tree_persist.Intent, error)
InstanceIntentModify(ctx context.Context, cacheName string, intent *tree_persist.Intent) error
InstanceIntentDelete(ctx context.Context, cacheName string, intentName string) error
InstanceIntentExists(ctx context.Context, cacheName string, intentName string) (bool, error)
InstanceIntentGetAll(ctx context.Context, cacheName string, excludeIntentNames []string, intentChan chan<- *tree_persist.Intent, errChan chan<- error)
}
func NewLocalCache ¶
func NewLocalCache(cfg *config.CacheConfig) (Client, error)
type LocalCache ¶ added in v0.0.56
func (*LocalCache) InstanceIntentGet ¶ added in v0.0.56
func (l *LocalCache) InstanceIntentGet(ctx context.Context, cacheName string, intentName string) (*tree_persist.Intent, error)
func (*LocalCache) InstanceIntentGetAll ¶ added in v0.0.56
func (l *LocalCache) InstanceIntentGetAll(ctx context.Context, cacheName string, excludeIntentNames []string, intentChanOrig chan<- *tree_persist.Intent, errChanOrig chan<- error)
func (*LocalCache) InstanceIntentModify ¶ added in v0.0.56
func (l *LocalCache) InstanceIntentModify(ctx context.Context, cacheName string, intent *tree_persist.Intent) error
Click to show internal directories.
Click to hide internal directories.