Versions in this module Expand all Collapse all v0 v0.0.33 Feb 8, 2024 v0.0.32 Feb 8, 2024 Changes in this version + type Client struct + func New(ctx context.Context, ccfg *ClientConfig) (*Client, error) + func (c *Client) Clone(ctx context.Context, name, clone string, opts ...grpc.CallOption) error + func (c *Client) Close() error + func (c *Client) Commit(ctx context.Context, name, candidate string, opts ...grpc.CallOption) error + func (c *Client) Create(ctx context.Context, name string, opts ...grpc.CallOption) error + func (c *Client) CreateCandidate(ctx context.Context, name, candidate, owner string, p int32, ...) error + func (c *Client) Delete(ctx context.Context, name string, opts ...grpc.CallOption) error + func (c *Client) Discard(ctx context.Context, name, candidate string, opts ...grpc.CallOption) error + func (c *Client) Exists(ctx context.Context, name string, opts ...grpc.CallOption) (bool, error) + func (c *Client) Get(ctx context.Context, name string, opts ...grpc.CallOption) (*cachepb.GetResponse, error) + func (c *Client) GetChanges(ctx context.Context, name, candidate string, opts ...grpc.CallOption) ([]*cachepb.GetChangesResponse, error) + func (c *Client) List(ctx context.Context, opts ...grpc.CallOption) ([]string, error) + func (c *Client) Modify(ctx context.Context, name string, wo *ClientOpts, dels [][]string, ...) error + func (c *Client) Prune(ctx context.Context, name string, id string, force bool, ...) (*cachepb.PruneResponse, error) + func (c *Client) Read(ctx context.Context, name string, ro *ClientOpts, paths [][]string, ...) chan *cachepb.ReadResponse + func (c *Client) Watch(ctx context.Context, name string, store cache.Store, prefixes [][]string, ...) (chan *cachepb.WatchResponse, error) + type ClientConfig struct + Address string + MaxReadStream int64 + MaxWatchStream int64 + Timeout time.Duration + type ClientOpts struct + KeysOnly bool + Owner string + Priority int32 + PriorityCount uint64 + Store cache.Store