endpoint

Documentation

Overview

* @Author: your name * @Date: 2021-10-19 17:41:17 * @LastEditTime: 2021-11-04 17:05:48 * @LastEditors: Please set LastEditors * @Description: In User Settings Edit * @FilePath: /components/gxynet/conn/endpoint.go

Index

• type BaseEventHandler
  • func (e *BaseEventHandler) OnClose(context.Context, Endpoint)
  • func (e *BaseEventHandler) OnError(context.Context, Endpoint, error)
  • func (e *BaseEventHandler) OnMessage(context.Context, Endpoint, *message.Message) error
  • func (e *BaseEventHandler) OnOpen(ctx context.Context, _ Endpoint) error
• type CoreBundle
  • func (p *CoreBundle) BindHandler(handler EventHandler)
  • func (p *CoreBundle) BindProc(c *gxyconfig.Configuration) error
• type Endpoint
• type EventHandler
• type TcpEndpoint
  • func NewTcpEndPoint(conn net.Conn, bundle CoreBundle) *TcpEndpoint
  • func (t *TcpEndpoint) Close(ctx context.Context, err error)
  • func (t *TcpEndpoint) Conn() net.Conn
  • func (t *TcpEndpoint) GetData() interface{}
  • func (t *TcpEndpoint) IsClosed() bool
  • func (t *TcpEndpoint) Send(msg interface{}) error
  • func (t *TcpEndpoint) SetData(d interface{})
  • func (t *TcpEndpoint) Start(ctx context.Context) error

Types

type BaseEventHandler

type BaseEventHandler struct {
}

func (*BaseEventHandler) OnClose

func (e *BaseEventHandler) OnClose(context.Context, Endpoint)

func (*BaseEventHandler) OnError

func (e *BaseEventHandler) OnError(context.Context, Endpoint, error)

func (*BaseEventHandler) OnMessage

func (e *BaseEventHandler) OnMessage(context.Context, Endpoint, *message.Message) error

func (*BaseEventHandler) OnOpen

func (e *BaseEventHandler) OnOpen(ctx context.Context, _ Endpoint) error

type CoreBundle

type CoreBundle struct {
	*processor.Processor
	Handler EventHandler
}

func (*CoreBundle) BindHandler

func (p *CoreBundle) BindHandler(handler EventHandler)

func (*CoreBundle) BindProc

func (p *CoreBundle) BindProc(c *gxyconfig.Configuration) error

type Endpoint

type Endpoint interface {
	Send(msg interface{}) error
	Start(ctx context.Context) error
	Close(context.Context, error)
	Conn() net.Conn
	GetData() interface{}
	SetData(interface{})
}

type EventHandler

type EventHandler interface {
	OnOpen(context.Context, Endpoint) error
	OnClose(context.Context, Endpoint)
	OnError(context.Context, Endpoint, error)
	OnMessage(context.Context, Endpoint, *message.Message) error
}

type TcpEndpoint

type TcpEndpoint struct {
	CoreBundle
	// contains filtered or unexported fields
}

func NewTcpEndPoint

func NewTcpEndPoint(conn net.Conn, bundle CoreBundle) *TcpEndpoint

func (*TcpEndpoint) Close

func (t *TcpEndpoint) Close(ctx context.Context, err error)

func (*TcpEndpoint) Conn

func (t *TcpEndpoint) Conn() net.Conn

func (*TcpEndpoint) GetData

func (t *TcpEndpoint) GetData() interface{}

func (*TcpEndpoint) IsClosed

func (t *TcpEndpoint) IsClosed() bool

func (*TcpEndpoint) Send

func (t *TcpEndpoint) Send(msg interface{}) error

func (*TcpEndpoint) SetData

func (t *TcpEndpoint) SetData(d interface{})

func (*TcpEndpoint) Start

func (t *TcpEndpoint) Start(ctx context.Context) error