Documentation ¶
Index ¶
- func Benchmark(ctx context.Context, conf *config.Config, kv *db.DB, ...) <-chan error
- func GetReplication() *pb.Replication
- func PutObjects(ctx context.Context, conf *config.Config, kv *db.DB, proxy s3client.Client) (<-chan struct{}, <-chan error, error)
- func Start(conf *config.Config) error
- func WatchReplicationMeta(ctx context.Context, conf *config.Config, apiClient pb.ChorusClient) (<-chan error, error)
- type Prev
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func GetReplication ¶
func GetReplication() *pb.Replication
func PutObjects ¶
func WatchReplicationMeta ¶
Types ¶
Click to show internal directories.
Click to hide internal directories.