Versions in this module Expand all Collapse all v0 v0.1.0 Feb 24, 2018 Changes in this version + func NewConnectionWithAddress(peerAddress string, tslEnabled bool, creds credentials.TransportCredentials) (*grpc.ClientConn, error) + type Connection interface + Close func() + Send func(envelope *message.Envelope, successCallBack func(interface{}), ...) + func NewConnection(clientStream pb.StreamService_StreamClient, ...) (Connection, error) + type ConnectionImpl struct + func (conn *ConnectionImpl) Close() + func (conn *ConnectionImpl) ReadStream(errChan chan error) + func (conn *ConnectionImpl) Send(envelope *message.Envelope, successCallBack func(interface{}), ...) + func (conn *ConnectionImpl) WriteStream() + type ReceiveMessageHandle func(message msg.OutterMessage)
Go to main page