README
¶
thrift-zmq-transport
zmq transport for thrift framework
supported zmq socket
- DEALER / ROUTER
cross compile on mac OS X
Because the zmq4 makes use of CGO, it's not possible to cross compile a linux binary on mac OS X platform. Use golang-zeromq docker image to cross compile. Usage: docker run --rm -w /go/src/path/to/go/project -v ${GOPATH}:/go rxwen/golang-zeromq go build ./
Documentation
¶
Index ¶
- type TDealerTransport
- func (t TDealerTransport) Close() error
- func (p TDealerTransport) Flush() error
- func (t TDealerTransport) IsOpen() bool
- func (t TDealerTransport) Open() error
- func (t TDealerTransport) Read(buf []byte) (l int, err error)
- func (p TDealerTransport) RemainingBytes() (num_bytes uint64)
- func (t TDealerTransport) Write(buf []byte) (int, error)
- type TRouterServerTransport
- type TRouterTransport
- func (t TRouterTransport) Close() error
- func (p TRouterTransport) Flush() error
- func (t TRouterTransport) IsOpen() bool
- func (t TRouterTransport) Open() error
- func (t TRouterTransport) Read(buf []byte) (l int, err error)
- func (p TRouterTransport) RemainingBytes() (num_bytes uint64)
- func (t TRouterTransport) Write(buf []byte) (int, error)
- type WriteMessage
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TDealerTransport ¶
type TDealerTransport struct {
// contains filtered or unexported fields
}
TDeleaerTransport is a TTransport implementation.
func NewTDealerTransport ¶
func NewTDealerTransport(endpoint string) TDealerTransport
NewTDealerTransport function creates a new TDealerTransport instance.
func (TDealerTransport) Close ¶
func (t TDealerTransport) Close() error
Close method shuts down the zmq socket.
func (TDealerTransport) IsOpen ¶
func (t TDealerTransport) IsOpen() bool
IsOpen method alwasy return true.
func (TDealerTransport) Open ¶
func (t TDealerTransport) Open() error
Open method connects to remote endpoint.
func (TDealerTransport) Read ¶
func (t TDealerTransport) Read(buf []byte) (l int, err error)
Read method get bytes from socket.
func (TDealerTransport) RemainingBytes ¶
func (p TDealerTransport) RemainingBytes() (num_bytes uint64)
RemainingBytes method returns bytes available.
type TRouterServerTransport ¶
type TRouterServerTransport struct {
// contains filtered or unexported fields
}
TRouterServerTransport is a zeromq Router based TServerTransport implementation.
func NewTRouterServerTransport ¶
func NewTRouterServerTransport(endpoint string) TRouterServerTransport
NewTRouterServerTransport function instantiates a new TRouterServerTransport to specified endpoint
func (TRouterServerTransport) Accept ¶
func (t TRouterServerTransport) Accept() (thrift.TTransport, error)
func (TRouterServerTransport) Close ¶
func (t TRouterServerTransport) Close() error
func (TRouterServerTransport) Interrupt ¶
func (t TRouterServerTransport) Interrupt() error
func (TRouterServerTransport) Listen ¶
func (t TRouterServerTransport) Listen() error
type TRouterTransport ¶
type TRouterTransport struct {
// contains filtered or unexported fields
}
TRouterTransport is a TTransport implementation.
func (TRouterTransport) Close ¶
func (t TRouterTransport) Close() error
func (TRouterTransport) Flush ¶
func (p TRouterTransport) Flush() error
func (TRouterTransport) IsOpen ¶
func (t TRouterTransport) IsOpen() bool
func (TRouterTransport) Open ¶
func (t TRouterTransport) Open() error
func (TRouterTransport) RemainingBytes ¶
func (p TRouterTransport) RemainingBytes() (num_bytes uint64)
type WriteMessage ¶
type WriteMessage struct {
// contains filtered or unexported fields
}
Source Files
Directories