transport

Documentation

Index

• Constants
• Variables
• func NewTransport(opts ...Option) *transport
• type Option
  • func Addrs(addrs ...string) Option
  • func Subject(sub string) Option
  • func Timeout(t time.Duration) Option
• type Options
• type ResponseHandler
• type Transport

Constants

const (
	DefaultRequestTimeout = time.Second * 15
)

Variables

var (
	DefaultTransport = NewTransport()
)

Functions

func NewTransport

func NewTransport(opts ...Option) *transport

Types

type Option

type Option func(*Options)

func Addrs

func Addrs(addrs ...string) Option

Addrs to use for transport

func Subject

func Subject(sub string) Option

subject to use for transport

func Timeout

func Timeout(t time.Duration) Option

Timeout sets the timeout for Send/Recv execution

type Options

type Options struct {
	Subject string        // Message destination address
	Addrs   []string      // A configured set of nats servers which this client will use when attempting to connect.
	Timeout time.Duration // Dialer timeout
}

type ResponseHandler

type ResponseHandler func([]byte) error

type Transport

type Transport interface {
	Options() Options
	Init() error
	Request(string, []byte, ResponseHandler) error
	Publish(string, []byte) error
	Subscribe() error
	SetHandler(nats.MsgHandler)
	SendFile(*codec.Message, string, []byte) error
	Close() error
}