cmux

Documentation

Index

• type ConnectionMux
  • func NewConnectionMux(logger *zap.Logger, port int32) (result *ConnectionMux, err error)
  • func NewTlsConnectionMux(logger *zap.Logger, port int32, tlsCert string, tlsKey string, ...) (result *ConnectionMux, err error)
  • func (cm *ConnectionMux) GrpcListener() (listener net.Listener, err error)
  • func (cm *ConnectionMux) HTTPListener() (listener net.Listener, err error)
  • func (cm *ConnectionMux) StartServing(_ context.Context) error
  • func (cm *ConnectionMux) StopServing(_ context.Context) error
  • func (cm *ConnectionMux) TCPListener() (listener net.Listener, err error)
  • func (cm *ConnectionMux) WSListener() (listener net.Listener, err error)

Types

type ConnectionMux

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

func NewConnectionMux

func NewConnectionMux(
	logger *zap.Logger,
	port int32,
) (result *ConnectionMux, err error)

func NewTlsConnectionMux

func NewTlsConnectionMux(
	logger *zap.Logger,
	port int32,
	tlsCert string,
	tlsKey string,
	clientsCA string,
) (result *ConnectionMux, err error)

func (*ConnectionMux) GrpcListener

func (cm *ConnectionMux) GrpcListener() (listener net.Listener, err error)

func (*ConnectionMux) HTTPListener

func (cm *ConnectionMux) HTTPListener() (listener net.Listener, err error)

func (*ConnectionMux) StartServing

func (cm *ConnectionMux) StartServing(_ context.Context) error

func (*ConnectionMux) StopServing

func (cm *ConnectionMux) StopServing(_ context.Context) error

func (*ConnectionMux) TCPListener

func (cm *ConnectionMux) TCPListener() (listener net.Listener, err error)

func (*ConnectionMux) WSListener

func (cm *ConnectionMux) WSListener() (listener net.Listener, err error)