grpcmux

Documentation

Index

• type Mux
  • func New(ctx context.Context, listeners []MuxListener, tm *taskmanager.TaskManager) *Mux
  • func (m *Mux) Accept() (net.Conn, error)
  • func (m *Mux) Addr() net.Addr
  • func (m *Mux) Close() error
  • func (m *Mux) Start(ctx context.Context) error
  • func (m *Mux) Status() interface{}
• type MuxListener

Types

type Mux

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

func New

func New(
	ctx context.Context,
	listeners []MuxListener,
	tm *taskmanager.TaskManager,
) *Mux

func (*Mux) Accept

func (m *Mux) Accept() (net.Conn, error)

func (*Mux) Addr

func (m *Mux) Addr() net.Addr

func (*Mux) Close

func (m *Mux) Close() error

func (*Mux) Start

func (m *Mux) Start(ctx context.Context) error

func (*Mux) Status

func (m *Mux) Status() interface{}

type MuxListener

type MuxListener struct {
	Start func() (net.Listener, error)
	Tag   string
}