transport

Documentation

Overview

*

*
* @author liangjf
* @create on 2020/5/20
* @version 1.0

*

*
* @author liangjf
* @create on 2020/5/20
* @version 1.0

*

*
* @author liangjf
* @create on 2020/5/20
* @version 1.0

*

*
* @author liangjf
* @create on 2020/5/21
* @version 1.0

*

*
* @author liangjf
* @create on 2020/5/20
* @version 1.0

*

*
* @author liangjf
* @create on 2020/5/20
* @version 1.0

Index

• Variables
• type FactoryRPCTransport
• type FactoryTcpTransport
• type FactoryWSTransport
• type IFactory
• type ITransport
  • func NewFactoryRPCTransport(opts ...Option) ITransport
  • func NewFactoryTcpTransport(opts ...Option) ITransport
  • func NewFactoryWSTransport(opts ...Option) ITransport
  • func NewRpcTransport(opts ...Option) ITransport
  • func NewTcpTransport(opts ...Option) ITransport
  • func NewWSTransport(opts ...Option) ITransport
• type Option
  • func Addr(address string) Option
  • func DiscoveryAddr(DiscoveryAddr []string) Option
  • func KeepAlivePeriod(keepAlivePeriod time.Duration) Option
  • func Network(network string) Option
  • func RpcPort(rpcPort int) Option
  • func SrvName(SrvName string) Option
  • func Timeout(timeout time.Duration) Option
• type Options

Variables

var (
	HeartbeatReply             = []byte("ok")
	ErrConnReqPayloadInfoReply = []byte("conn req payload info err")
)

Types

type FactoryRPCTransport

type FactoryRPCTransport struct{}

type FactoryTcpTransport

type FactoryTcpTransport struct{}

type FactoryWSTransport

type FactoryWSTransport struct{}

type IFactory

type IFactory interface {
	CreateTransport() ITransport
}

type ITransport

type ITransport interface {
	Init(...Option)
	ListenServer(context.Context) error
}

func NewFactoryRPCTransport

func NewFactoryRPCTransport(opts ...Option) ITransport

func NewFactoryTcpTransport

func NewFactoryTcpTransport(opts ...Option) ITransport

func NewFactoryWSTransport

func NewFactoryWSTransport(opts ...Option) ITransport

func NewRpcTransport

func NewRpcTransport(opts ...Option) ITransport

func NewTcpTransport

func NewTcpTransport(opts ...Option) ITransport

func NewWSTransport

func NewWSTransport(opts ...Option) ITransport

type Option

type Option func(*Options)

func Addr

func Addr(address string) Option

func DiscoveryAddr

func DiscoveryAddr(DiscoveryAddr []string) Option

func KeepAlivePeriod

func KeepAlivePeriod(keepAlivePeriod time.Duration) Option

func Network

func Network(network string) Option

func RpcPort

func RpcPort(rpcPort int) Option

func SrvName

func SrvName(SrvName string) Option

func Timeout

func Timeout(timeout time.Duration) Option

type Options

type Options struct {
	Address         string
	Network         string
	KeepAlivePeriod time.Duration
	Timeout         time.Duration
	RpcPort         int
	DiscoveryAddr   []string
	SrvName         string
}