thrift_nats

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.