connection

Documentation

Index

• Variables
• type Conn
  • func New(wsConn *websocket.Conn, pushC chan<- map[string]interface{}, ...) *Conn
  • func (c Conn) Duration() (time.Duration, error)
  • func (c *Conn) Finish() *Conn
  • func (c Conn) Listen()

Variables

var (
	ErrEndTimeNotSet = fmt.Errorf("connection end time is not yet set - duration cannot be calculated")
)

Types

type Conn

type Conn struct {
	PushChan chan<- map[string]interface{}
	// contains filtered or unexported fields
}

func New

func New(wsConn *websocket.Conn, pushC chan<- map[string]interface{}, leave chan<- string, cookie string) *Conn

func (Conn) Duration

func (c Conn) Duration() (time.Duration, error)

Duration returns the session duration if the endTime is not the default value

func (*Conn) Finish

func (c *Conn) Finish() *Conn

func (Conn) Listen

func (c Conn) Listen()