dubbogo

package
v0.2.4 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 8, 2023 License: Apache-2.0 Imports: 15 Imported by: 3

Documentation

Index

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

Types

type ConsumerOption

type ConsumerOption struct {
	CheckProviderExists bool // 是否要求在consumer启动时,对应的provider必须存在
	TimeoutSeconds      int  // 调用 provider 方法的超时时间(秒数)
}

type ConsumerReference

type ConsumerReference struct {
	ClientImplStructName string            // consumer ClientImpl 的 struct 名称(通常在 protobuf 生成的文件中被命名为 XxxClientImpl)
	Service              common.RPCService // consumer ClientImpl 的实例
	Protocol             string            // 协议,当前只支持 "tri"
}

type LoggerOption

type LoggerOption struct {
	Development bool   // 是否为开发阶段,可能输出更详细的日志
	Stdout      bool   // 是否将日志同时输出到 stdout/stderr
	LogDir      string // 日志文件的路径
	LogFileName string // 日志文件的文件名(不含路径)
	Level       string // 日志级别,可选项:[error|warn|info|debug]
}

type ProviderInfo

type ProviderInfo struct {
	ApplicationName   string        // 应用名称(不支持中文)
	Protocol          string        // 协议,当前只支持 "tri"
	Port              int           // 侦听的端口号
	IP                string        // 不建议指定,如果要绑定运行的IP,可指定
	ShutdownCallbacks []func()      // 关闭时要执行的回调
	Services          []ServiceInfo // provider 实现 IXxx 接口的 struct 名称和实例的 map
}

type Registry

type Registry struct {
	Id        string // 注册中心的ID,随便取,
	Type      string // 注册中心类型,例如 nacos
	Address   string // 注册中心地址,例如 ip:port
	Namespace string // 仅当注册中心协议为 nacos 时有效
}

type ServiceInfo

type ServiceInfo struct {
	ServerImplStructName string            // provider 实现 IXxx 接口的 struct 名称
	Service              common.RPCService // provider 实现 IXxx 接口的 struct 实例
}

Directories

Path Synopsis
filter

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL