connector

Documentation

Overview

Package connector 实现了基本的连接器接口

Index

• func Register(kind string, creator ConnectorCreator)
• type Connector
  • func NewConnector(kind string, source string) (Connector, error)
  • func NewHttpConnector(source string) (Connector, error)
  • func NewHttpsConnector(source string) (Connector, error)
• type ConnectorCreator
• type Dispatcher
• type Error
  • func (this Error) Error() error
  • func (this Error) Format(data ...interface{}) Error
  • func (this Error) String() string
• type HttpConnector
  • func (this *HttpConnector) Dispatcher() Dispatcher
  • func (this *HttpConnector) Init() error
  • func (this *HttpConnector) Run() error
  • func (this *HttpConnector) SetDispatcher(dispatcher Dispatcher)
  • func (this *HttpConnector) Stop() error
• type HttpContext
• type HttpHandler
  • func (this *HttpHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)
• type HttpsConnector
  • func (this *HttpsConnector) Run() error
  • func (this *HttpsConnector) Stop() error

Functions

func Register

func Register(kind string, creator ConnectorCreator)

Register 注册Connector创建器

Types

type Connector

type Connector interface {
	// Init 初始化连接器设置
	Init() error
	// Run 运行(接受连接并进行处理,阻塞)
	Run() error
	// Stop 停止运行
	Stop() error
	// Dispatcher 返回当前调度器
	Dispatcher() Dispatcher
	// SetDispatcher 设置调度器
	SetDispatcher(dispatcher Dispatcher)
}

连接器

func NewConnector

func NewConnector(kind string, source string) (Connector, error)

NewConnector 创建一个新的Connector

kind:日志类型

func NewHttpConnector

func NewHttpConnector(source string) (Connector, error)

NewHttpConnector 创建Http连接器

func NewHttpsConnector

func NewHttpsConnector(source string) (Connector, error)

NewHttpsConnector 创建Http连接器

source:格式如: 127.0.0.1:8080;Cert=path/to/cert;Key=path/to/key

type ConnectorCreator

type ConnectorCreator func(source string) (Connector, error)

连接器创建器

suorce: 连接器监听位置(例如:127.0.0.1:9999表示监听127.0.0.1上的9999端口)

type Dispatcher

type Dispatcher interface {
	// Dispatch 分发
	//  segments:用于进行分发的路径段信息
	//  data:连接携带的数据
	Dispatch(segments []string, data interface{})
}

Dispatcher 调度器

type Error

type Error string

错误信息

const (
	ErrorInvalidConnectorCreator Error = "ErrorInvalidConnectorCreator(N10000):无效的连接创建器"
	ErrorInvalidKind             Error = "ErrorInvalidKind(N10010):无效的连接类型(%s)"
	ErrorFailToStop              Error = "ErrorFailToStop(N10020):无法停止连接器(%s)"
	ErrorInvalidDispatcher       Error = "ErrorInvalidDispatcher(N10030):无效的Dispatcher,无法启动Connector(%s)"
	ErrorParamNotFound           Error = "ErrorParamNotFound(N10100):source中没有%s,无法创建https连接器"
)

错误码

func (Error) Error

func (this Error) Error() error

Error 生成error类型

func (Error) Format

func (this Error) Format(data ...interface{}) Error

Format 格式化错误信息并生成新的错误信息

func (Error) String

func (this Error) String() string

String 返回错误字符串描述

type HttpConnector

type HttpConnector struct {
	// contains filtered or unexported fields
}

Http连接器

func (*HttpConnector) Dispatcher

func (this *HttpConnector) Dispatcher() Dispatcher

Dispatcher 返回当前调度器

func (*HttpConnector) Init

func (this *HttpConnector) Init() error

Init 初始化连接器设置

func (*HttpConnector) Run

func (this *HttpConnector) Run() error

Run 运行(接受连接并进行处理,阻塞)

func (*HttpConnector) SetDispatcher

func (this *HttpConnector) SetDispatcher(dispatcher Dispatcher)

SetDispatcher 设置调度器

func (*HttpConnector) Stop

func (this *HttpConnector) Stop() error

Stop 停止运行

type HttpContext

type HttpContext struct {
	Request        *http.Request       //http请求
	ResponseWriter http.ResponseWriter //http响应
}

Http上下文

type HttpHandler

type HttpHandler struct {
	// contains filtered or unexported fields
}

Http处理器

func (*HttpHandler) ServeHTTP

func (this *HttpHandler) ServeHTTP(rw http.ResponseWriter, r *http.Request)

ServeHTTP 处理http请求

type HttpsConnector

type HttpsConnector struct {
	HttpConnector
	// contains filtered or unexported fields
}

Https连接器

func (*HttpsConnector) Run

func (this *HttpsConnector) Run() error

Run 运行(接受连接并进行处理,阻塞)

func (*HttpsConnector) Stop

func (this *HttpsConnector) Stop() error

Stop 停止运行