NewElastic provides a new Elastic client.

NewKafkaReader creates a new kafka reader.

NewKafkaWriter creates a new kafka writer.

NewMongo provides a new Mongo client.

NewPostgres provides a new Postgres client.

NewRedis provides a new Redis client.

infra.Coco 可用于嵌入，用于自定义的 infra 实例.

KafkaReader is a wrapper of kafka reader.

KafkaWriter is a wrapper of kafka writer.

Infra 带有初始化逻辑的基础设施等.