Changeset View
Changeset View
Standalone View
Standalone View
swh/journal/cli.py
Show First 20 Lines • Show All 135 Lines • ▼ Show 20 Lines | except KeyboardInterrupt: | ||||
ctx.exit(0) | ctx.exit(0) | ||||
@cli.command() | @cli.command() | ||||
@click.option('--concurrency', type=int, | @click.option('--concurrency', type=int, | ||||
default=8, | default=8, | ||||
help='Concurrentcy level.') | help='Concurrentcy level.') | ||||
@click.option('--broker', 'brokers', type=str, multiple=True, | @click.option('--broker', 'brokers', type=str, multiple=True, | ||||
hidden=True, # prefer config file | help='Kafka broker to connect to.' | ||||
help='Kafka broker to connect to.') | '(deprecated, use the config file instead)') | ||||
@click.option('--prefix', type=str, default=None, | @click.option('--prefix', type=str, default=None, | ||||
hidden=True, # prefer config file | help='Prefix of Kafka topic names to read from.' | ||||
help='Prefix of Kafka topic names to read from.') | '(deprecated, use the config file instead)') | ||||
@click.option('--group-id', '--consumer-id', type=str, | @click.option('--group-id', '--consumer-id', type=str, | ||||
hidden=True, # prefer config file | help='Name of the consumer/group id for reading from Kafka.' | ||||
help='Name of the consumer/group id for reading from Kafka.') | '(deprecated, use the config file instead)') | ||||
@click.pass_context | @click.pass_context | ||||
def content_replay(ctx, concurrency, brokers, prefix, group_id): | def content_replay(ctx, concurrency, brokers, prefix, group_id): | ||||
"""Fill a destination Object Storage (typically a mirror) by reading a Journal | """Fill a destination Object Storage (typically a mirror) by reading a Journal | ||||
and retrieving objects from an existing source ObjStorage. | and retrieving objects from an existing source ObjStorage. | ||||
There can be several 'replayers' filling a given ObjStorage as long as they | There can be several 'replayers' filling a given ObjStorage as long as they | ||||
use the same `group-id`. | use the same `group-id`. | ||||
▲ Show 20 Lines • Show All 43 Lines • Show Last 20 Lines |