abstactOutbound

package

v5.52.0 Latest Latest Go to latest Published: Jul 7, 2026 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Outbound is a outbound.Handler that handles gRPC connections.

func NewOutbound(tag string, listener *OutboundListener) *Outbound

func (co *Outbound) Close() error

Close implements common.Closable.

func (co *Outbound) Dispatch(ctx context.Context, link *transport.Link)

Dispatch implements outbound.Handler.

func (co *Outbound) Start() error

Start implements common.Runnable.

func (co *Outbound) Tag() string

Tag implements outbound.Handler.

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

OutboundListener is a net.Listener for listening gRPC connections.

func NewOutboundListener() *OutboundListener

func (l *OutboundListener) Accept() (net.Conn, error)

Accept implements net.Listener.

func (l *OutboundListener) Addr() net.Addr

Addr implements net.Listener.

func (l *OutboundListener) Close() error

Close implement net.Listener.