httpts

Documentation

Index

• Variables
• type SubSession
  • func NewSubSession(conn net.Conn, urlCtx base.UrlContext, isWebSocket bool, websocketKey string) *SubSession
  • func (session *SubSession) AppName() string
  • func (session *SubSession) Dispose() error
  • func (session *SubSession) GetStat() base.StatSession
  • func (session *SubSession) IsAlive() (readAlive, writeAlive bool)
  • func (session *SubSession) RawQuery() string
  • func (session *SubSession) RunLoop() error
  • func (session *SubSession) StreamName() string
  • func (session *SubSession) UniqueKey() string
  • func (session *SubSession) UpdateStat(intervalSec uint32)
  • func (session *SubSession) Url() string
  • func (session *SubSession) Write(b []byte)
  • func (session *SubSession) WriteHttpResponseHeader()

Variables

var (
	SubSessionWriteChanSize  = 1024
	SubSessionWriteTimeoutMs = 10000

	Log = nazalog.GetGlobalLogger()
)

Types

type SubSession

type SubSession struct {
	IsFresh            bool
	ShouldWaitBoundary bool
	// contains filtered or unexported fields
}

func NewSubSession

func NewSubSession(conn net.Conn, urlCtx base.UrlContext, isWebSocket bool, websocketKey string) *SubSession

func (*SubSession) AppName

func (session *SubSession) AppName() string

func (*SubSession) Dispose

func (session *SubSession) Dispose() error

func (*SubSession) GetStat

func (session *SubSession) GetStat() base.StatSession

func (*SubSession) IsAlive

func (session *SubSession) IsAlive() (readAlive, writeAlive bool)

func (*SubSession) RawQuery

func (session *SubSession) RawQuery() string

func (*SubSession) RunLoop

func (session *SubSession) RunLoop() error

func (*SubSession) StreamName

func (session *SubSession) StreamName() string

func (*SubSession) UniqueKey

func (session *SubSession) UniqueKey() string

func (*SubSession) UpdateStat

func (session *SubSession) UpdateStat(intervalSec uint32)

func (*SubSession) Url

func (session *SubSession) Url() string

func (*SubSession) Write

func (session *SubSession) Write(b []byte)

func (*SubSession) WriteHttpResponseHeader

func (session *SubSession) WriteHttpResponseHeader()