channel

Documentation

Index

• Variables
• func GetChannel(config ChannelConfig) (rpc.Channel, error)
• func RegistChannel(proto string, f func(config ChannelConfig) (rpc.Channel, error))
• type ChannelConfig

Variables

var (
	ErrTimeout = errors.New("request timeout")
)

Functions

func GetChannel

func GetChannel(config ChannelConfig) (rpc.Channel, error)

GetChannel creates a rpc.Channel according to config.Protocol

func RegistChannel

func RegistChannel(proto string, f func(config ChannelConfig) (rpc.Channel, error))

RegistChannel is set protocol

Types

type ChannelConfig

type ChannelConfig struct {
	Protocol string                 `json:"protocol"`
	Listener string                 `json:"listener"`
	Size     int                    `json:"size"`
	Ext      map[string]interface{} `json:"ext"`
}

ChannelConfig is Channel config