Documentation
¶
Index ¶
- func NATSTransportFactory(conn *nats.Conn, subject string, timeout, readTimeout time.Duration) (thrift.TTransport, error)
- func NewNATSServer(conn *nats.Conn, subject string, clientTimeout time.Duration, ...) thrift.TServer
- func NewNATSServerFactory7(conn *nats.Conn, subject string, clientTimeout time.Duration, ...) thrift.TServer
- func NewNATSServerFactory9(conn *nats.Conn, subject string, clientTimeout time.Duration, ...) thrift.TServer
- func NewNATSTransport(conn *nats.Conn, listenTo, replyTo, heartbeat string, ...) thrift.TTransport
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NATSTransportFactory ¶
func NATSTransportFactory(conn *nats.Conn, subject string, timeout, readTimeout time.Duration) (thrift.TTransport, error)
NATSTransportFactory returns a new thrift TTransport which uses the NATS messaging system as the underlying transport. This TTransport can only be used with NATSServer.
func NewNATSServer ¶
func NewNATSServer( conn *nats.Conn, subject string, clientTimeout time.Duration, heartbeatDeadline time.Duration, processor thrift.TProcessor, transportFactory thrift.TTransportFactory, protocolFactory thrift.TProtocolFactory) thrift.TServer
NewNATSServer returns a Thrift TServer which uses the NATS messaging system as the underlying transport. The subject is the NATS subject used for connection handshakes. The client timeout controls the read timeout on the client connection (negative value for no timeout). The heartbeat deadline controls how long clients have to respond with a heartbeat (negative value for no heartbeats).
func NewNATSServerFactory7 ¶
func NewNATSServerFactory7( conn *nats.Conn, subject string, clientTimeout time.Duration, heartbeatDeadline time.Duration, processorFactory thrift.TProcessorFactory, transportFactory thrift.TTransportFactory, protocolFactory thrift.TProtocolFactory) thrift.TServer
func NewNATSServerFactory9 ¶
func NewNATSServerFactory9( conn *nats.Conn, subject string, clientTimeout time.Duration, heartbeatDeadline time.Duration, processorFactory thrift.TProcessorFactory, inputTransportFactory thrift.TTransportFactory, outputTransportFactory thrift.TTransportFactory, inputProtocolFactory thrift.TProtocolFactory, outputProtocolFactory thrift.TProtocolFactory) thrift.TServer
func NewNATSTransport ¶
func NewNATSTransport(conn *nats.Conn, listenTo, replyTo, heartbeat string, readTimeout, heartbeatInterval time.Duration) thrift.TTransport
NewNATSTransport returns a Thrift TTransport which uses the NATS messaging system as the underlying transport. This TTransport can only be used with NATSServer.
Types ¶
This section is empty.
Source Files