connections

type ChanConnection struct {
	Addr net.Addr

	Closed bool
	Lock   sync.Mutex
	// contains filtered or unexported fields
}

type ChanConnectionClient struct {
	Conn *ChanConnection
}

type Conn struct {
	RawConnection
	Info *Info
}

type Consumer interface {
	//OnMessage called when connection message received.
	OnMessage(*Message)
	//OnError called when onconnection error raised.
	OnError(*Error)
	//OnClose called when connection closed.
	OnClose(OutputConnection)
	//OnOpen called when connection open.
	OnOpen(OutputConnection)
	// Stop stop consumer
	Stop()
}

type EmptyConsumer struct {
}

type Error struct {
	//Error raw error
	Error error
	//Conn connection which raised error.
	Conn OutputConnection
}

type Gateway struct {
	//ID gateway id
	ID string
	//IDGenerator connection id generator
	IDGenerator func() (string, error)
	//Connections connections managerd by gateway.
	Connections sync.Map
	// contains filtered or unexported fields
}

type Info struct {
	//ID connection registered id
	ID string
	//Timestamp connection registered timestamp.
	Timestamp int64
}

type InputService interface {
	//MessagesChan return connection message chan.
	MessagesChan() chan *Message
	//ErrorsChan return connection error chan.
	ErrorsChan() chan *Error
	//OnCloseEventsChan return connection on close events chan.
	OnCloseEventsChan() chan OutputConnection
	//OnOpenEventsChan return connection on open events chan.
	OnOpenEventsChan() chan OutputConnection
	//C close chan
	C() chan bool
}

type Message struct {
	//Message raw message
	Message []byte
	//Conn connection which received message
	Conn OutputConnection
}

type OutputConnection interface {
	Close() error
	Send([]byte) error
	ID() string
}

type OutputService interface {
	//Send message to connection by given id.
	Send(id string, msg []byte) error
	//Close close connection by given id.
	Close(id string) error
}

type RawConnection interface {
	//Close close connection.
	//Return any error if raised.
	Close() error
	//Send send message to connction.
	//return any error if raised.
	Send([]byte) error
	//MessagesChan connection message chan
	MessagesChan() chan []byte
	//ErrorsChan connection error chan.
	ErrorsChan() chan error
	//RemoteAddr return connection rempte address.
	RemoteAddr() net.Addr
	//C connection close signal chan.
	C() chan int
}