compressor

Documentation

Overview

Package compressor represents compressor client

Package compressor represents compressor client

Index

• type Client
  • func New(opts ...Option) (c Client, err error)
• type Option
  • func WithAddr(addr string) Option
  • func WithClient(gc grpc.Client) Option

Types

type Client

type Client interface {
	Start(ctx context.Context) (<-chan error, error)
	GetVector(ctx context.Context, uuid string) (*payload.Backup_MetaVector, error)
	GetLocation(ctx context.Context, uuid string) ([]string, error)
	Register(ctx context.Context, vec *payload.Backup_MetaVector) error
	RegisterMultiple(ctx context.Context, vecs *payload.Backup_MetaVectors) error
	Remove(ctx context.Context, uuid string) error
	RemoveMultiple(ctx context.Context, uuids ...string) error
	RegisterIPs(ctx context.Context, ips []string) error
	RemoveIPs(ctx context.Context, ips []string) error
}

func New

func New(opts ...Option) (c Client, err error)

type Option

type Option func(c *client) error

func WithAddr

func WithAddr(addr string) Option

func WithClient

func WithClient(gc grpc.Client) Option