polaris

Documentation

Index

• Constants
• type Connector
  • func (c *Connector) CreateConnection(address string, timeout time.Duration, clientInfo *network.ClientInfo) (network.ClosableConn, error)
  • func (c *Connector) Destroy() error
  • func (c *Connector) GetConfigFile(configFile *configconnector.ConfigFile) (*configconnector.ConfigFileResponse, error)
  • func (c *Connector) Init(ctx *plugin.InitContext) error
  • func (c *Connector) IsEnable(cfg config.Configuration) bool
  • func (c *Connector) Name() string
  • func (c *Connector) Type() common.Type
  • func (c *Connector) WatchConfigFiles(configFileList []*configconnector.ConfigFile) (*configconnector.ConfigFileResponse, error)

Constants

const (
	// DefaultMaxCallRecvMsgSize 默认GRPC链路包接收大小.
	DefaultMaxCallRecvMsgSize = 50 * 1024 * 1024
	// MaxMaxCallRecvMsgSize GRPC链路包接收大小的设置上限.
	MaxMaxCallRecvMsgSize = 500 * 1024 * 1024
)

Types

type Connector

type Connector struct {
	*plugin.PluginBase
	*common.RunContext
	// contains filtered or unexported fields
}

Connector 使用GRPC协议对接.

func (*Connector) CreateConnection

func (c *Connector) CreateConnection(
	address string, timeout time.Duration, clientInfo *network.ClientInfo,
) (network.ClosableConn, error)

CreateConnection 创建连接.

func (*Connector) Destroy

func (c *Connector) Destroy() error

Destroy 销毁插件，可用于释放资源.

func (*Connector) GetConfigFile

func (c *Connector) GetConfigFile(configFile *configconnector.ConfigFile) (*configconnector.ConfigFileResponse, error)

GetConfigFile Get config file.

func (*Connector) Init

func (c *Connector) Init(ctx *plugin.InitContext) error

Init 初始化插件.

func (*Connector) IsEnable

func (c *Connector) IsEnable(cfg config.Configuration) bool

IsEnable .插件开关.

func (*Connector) Name

func (c *Connector) Name() string

Name 插件名，一个类型下插件名唯一.

func (*Connector) Type

func (c *Connector) Type() common.Type

Type 插件类型.

func (*Connector) WatchConfigFiles

func (c *Connector) WatchConfigFiles(configFileList []*configconnector.ConfigFile) (*configconnector.ConfigFileResponse, error)

WatchConfigFiles Watch config files.