transport

Documentation

Index

• Variables
• type Transport
  • func NewTransport(addr string) Transport

Variables

var Scheme = flag.String("transport", "tcp", "transport scheme (tcp, udp, chan), default tcp")

Types

type Transport

type Transport interface {
	// Scheme returns tranport scheme
	Scheme() string

	// Send sends message into t.send chan
	Send(interface{})

	// Recv waits for message from t.recv chan
	Recv() interface{}

	// Dial connects to remote server non-blocking once connected
	Dial() error

	// Listen waits for connections, non-blocking once listener starts
	Listen()

	// Close closes send channel and stops listener
	Close()
}

Transport = transport + pipe + client + server

func NewTransport

func NewTransport(addr string) Transport

NewTransport creates new transport object with url