Documentation ¶
Index ¶
- func AddConsumerReference(consumer *ConsumerReference)
- func StartConsumers(_ context.Context, registry *Registry, consumerOption *ConsumerOption, ...) error
- func StartProvider(_ context.Context, registry *Registry, provider *ProviderInfo, ...) error
- func StartProviderAndConsumers(_ context.Context, registry *Registry, provider *ProviderInfo, ...) error
- type ConsumerOption
- type ConsumerReference
- type LoggerOption
- type ProviderInfo
- type Registry
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AddConsumerReference ¶
func AddConsumerReference(consumer *ConsumerReference)
AddConsumerReference 增加一个 consumer 的依赖配置
func StartConsumers ¶
func StartConsumers(_ context.Context, registry *Registry, consumerOption *ConsumerOption, loggerOption *LoggerOption) error
StartConsumers 启动通过 AddConsumerReference 添加的所有的 Consumer
func StartProvider ¶
func StartProvider(_ context.Context, registry *Registry, provider *ProviderInfo, logger *LoggerOption) error
func StartProviderAndConsumers ¶ added in v0.1.3
func StartProviderAndConsumers(_ context.Context, registry *Registry, provider *ProviderInfo, consumers []*ConsumerReference, consumerOption *ConsumerOption, logger *LoggerOption) error
StartProviderAndConsumers 同时启动一个provider,以及一到多个 consumer
Types ¶
type ConsumerOption ¶ added in v0.1.0
type ConsumerReference ¶ added in v0.1.0
type ConsumerReference struct { ClientImplStructName string // consumer ClientImpl 的 struct 名称(通常在 protobuf 生成的文件中被命名为 XxxClientImpl) Service common.RPCService // consumer ClientImpl 的实例 Protocol string // 协议,当前只支持 "tri" }
type LoggerOption ¶ added in v0.1.0
type ProviderInfo ¶ added in v0.1.0
Click to show internal directories.
Click to hide internal directories.