network

Documentation

Index

• func BrokerServeHttp(w io.Writer, body io.Reader, exename string, exealias string, args ...string)
• func DefaultServeHttp(w io.Writer, method string, url string, body io.Reader)
• func InvokeListener(host string)
• func MapActiveExtension(a ...string)
• func MapRoot(path string, rootpath string)
• func MapRoots(rootsToMap ...string)
• func RegisterCallableResource(resource string, callable func() io.Reader, a ...interface{})
• func RegisterShutdownEnv(shuttingdownEnv func())
• func ShutdownEnv()
• func ShutdownListener()
• type Channel
  • func NewChannel() (chnl *Channel)
  • func (chnl *Channel) EnqueueRequest(reqst *Request)
  • func (chnl *Channel) NextRequest(w http.ResponseWriter, r *http.Request, shuttingDownListener func(), ...) (reqst *Request)
• type Listener
  • func (lstnr *Listener) ListenAndServer(host string)
  • func (lstnr *Listener) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (lstnr *Listener) Shutdown()
  • func (lstnr *Listener) ShutdownHost(host string)
• type Listening
• type Request
  • func NewRequest(chnl *Channel, w http.ResponseWriter, r *http.Request, ...) (reqst *Request)
  • func (reqst *Request) AddResource(resource ...interface{})
  • func (reqst *Request) Close() (err error)
  • func (reqst *Request) Db(alias string) (dbcn *db.DbConnection)
  • func (reqst *Request) DbQuery(alias string, query string, args ...interface{}) (dbquery *db.DBQuery)
  • func (reqst *Request) ExecuteRequest()
  • func (reqst *Request) GetResource(nxtrspath string, a ...interface{}) (rdr io.Reader)
  • func (reqst *Request) InitRequest(w http.ResponseWriter, r *http.Request, shuttingDownListener func(), ...) (err error)
  • func (reqst *Request) Interupted() bool
  • func (reqst *Request) IsActiveContent(ext string) (active bool)
  • func (reqst *Request) Parameters() (params *parameters.Parameters)
  • func (reqst *Request) PopulateParameters()
  • func (reqst *Request) Print(a ...interface{})
  • func (reqst *Request) Println(a ...interface{})
  • func (reqst *Request) Read(p []byte) (n int, err error)
  • func (reqst *Request) ReadFromOffset() int64
  • func (reqst *Request) ReadRune() (r rune, size int, err error)
  • func (reqst *Request) ReadToOffset() int64
  • func (reqst *Request) RequestContent() *iorw.BufferedRW
  • func (reqst *Request) RequestHeader() http.Header
  • func (reqst *Request) RequestHeaders() (hdrs []string)
  • func (reqst *Request) RequestMethod() string
  • func (reqst *Request) RequestProtocol() string
  • func (reqst *Request) ResetRequest() (err error)
  • func (reqst *Request) ResponseHeader() http.Header
  • func (reqst *Request) ResponseHeaders() (hdrs []string)
  • func (reqst *Request) Seek(offset int64, whence int) (n int64, err error)
  • func (reqst *Request) ServeHTTP() (err error)
  • func (reqst *Request) SetRoots()
  • func (reqst *Request) Size() int64
  • func (reqst *Request) Write(p []byte) (n int, err error)
  • func (reqst *Request) WriteTo(w io.Writer) (n int64, err error)
• type Resource
  • func NewResource(reqst *Request, resourcepath string, a ...interface{}) (rsrc *Resource)
  • func (rsrc *Resource) Close() (err error)
  • func (rsrc *Resource) IsActiveContent() (active bool)
  • func (rsrc *Resource) Path() string
  • func (rsrc *Resource) Read(p []byte) (n int, err error)
  • func (rsrc *Resource) ReadRune() (r rune, size int, err error)
  • func (rsrc *Resource) ReadRuneBytes(p []byte) (n int, err error)
  • func (rsrc *Resource) Seek(offset int64, whence int) (n int64, err error)
  • func (rsrc *Resource) Size() int64
• type ResourceInfo
  • func NextResourceInfo(rsrc *Resource, path string, pathroot string, finfo os.FileInfo) (nxtrsinfo *ResourceInfo)
  • func (rsinfo *ResourceInfo) Close()
  • func (rsinfo *ResourceInfo) IsActiveContent() (active bool)
  • func (rsinfo *ResourceInfo) Path() string
  • func (rsinfo *ResourceInfo) PathRoot() string
  • func (rsinfo *ResourceInfo) Reader(rsrc *Resource) (r io.Reader)
• type ResourceInfoHandler
• type ResourcesManager
  • func (rsrcsmngr *ResourcesManager) MapResourceRoot(a ...interface{})
• type Response
  • func NewResponse(w io.Writer, r *http.Request) (resp *Response)
  • func (resp *Response) Header() http.Header
  • func (resp *Response) Write(p []byte) (n int, err error)
  • func (resp *Response) WriteHeader(statusCode int)
• type RootHandler
• type Talker
  • func NewTalker(h2c ...bool) (tlkr *Talker)
  • func (tlkr *Talker) Close() (err error)
  • func (tlkr *Talker) FSend(w io.Writer, body io.Reader, headers map[string][]string, url string, ...) (err error)
  • func (tlkr *Talker) Print(a ...interface{})
  • func (tlkr *Talker) Println(a ...interface{})
  • func (tlkr *Talker) Read(p []byte) (n int, err error)
  • func (tlkr *Talker) ReadRune() (r rune, size int, err error)
  • func (tlkr *Talker) Reset()
  • func (tlkr *Talker) Send(url string, body io.Reader, headers map[string][]string, params ...interface{}) (err error)
  • func (tlkr *Talker) Write(p []byte) (n int, err error)
• type Talking

Functions

func BrokerServeHttp

func BrokerServeHttp(w io.Writer, body io.Reader, exename string, exealias string, args ...string)

func DefaultServeHttp

func DefaultServeHttp(w io.Writer, method string, url string, body io.Reader)

func InvokeListener

func InvokeListener(host string)

func MapActiveExtension

func MapActiveExtension(a ...string)

func MapRoot

func MapRoot(path string, rootpath string)

func MapRoots

func MapRoots(rootsToMap ...string)

func RegisterCallableResource

func RegisterCallableResource(resource string, callable func() io.Reader, a ...interface{})

func RegisterShutdownEnv

func RegisterShutdownEnv(shuttingdownEnv func())

func ShutdownEnv

func ShutdownEnv()

func ShutdownListener

func ShutdownListener()

Types

type Channel

type Channel struct {
	// contains filtered or unexported fields
}

func NewChannel

func NewChannel() (chnl *Channel)

func (*Channel) EnqueueRequest

func (chnl *Channel) EnqueueRequest(reqst *Request)

func (*Channel) NextRequest

func (chnl *Channel) NextRequest(w http.ResponseWriter, r *http.Request, shuttingDownListener func(), shuttingDownHost func(), canShutdownEnv bool) (reqst *Request)

type Listener

type Listener struct {
	*Channel
	// contains filtered or unexported fields
}

Listener - Listener

func (*Listener) ListenAndServer

func (lstnr *Listener) ListenAndServer(host string)

func (*Listener) ServeHTTP

func (lstnr *Listener) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Listener) Shutdown

func (lstnr *Listener) Shutdown()

func (*Listener) ShutdownHost

func (lstnr *Listener) ShutdownHost(host string)

type Listening

type Listening interface {
	Shutdown()
	ShutdownHost(string)
}

Listening interface

type Request

type Request struct {
	*active.Active
	// contains filtered or unexported fields
}

func NewRequest

func NewRequest(chnl *Channel, w http.ResponseWriter, r *http.Request, shuttingDownListener func(), shuttingDownHost func(), canShutdownEnv bool) (reqst *Request)

func (*Request) AddResource

func (reqst *Request) AddResource(resource ...interface{})

func (*Request) Close

func (reqst *Request) Close() (err error)

func (*Request) Db

func (reqst *Request) Db(alias string) (dbcn *db.DbConnection)

func (*Request) DbQuery

func (reqst *Request) DbQuery(alias string, query string, args ...interface{}) (dbquery *db.DBQuery)

func (*Request) ExecuteRequest

func (reqst *Request) ExecuteRequest()

func (*Request) GetResource

func (reqst *Request) GetResource(nxtrspath string, a ...interface{}) (rdr io.Reader)

func (*Request) InitRequest

func (reqst *Request) InitRequest(w http.ResponseWriter, r *http.Request, shuttingDownListener func(), shuttingDownHost func(), canShutdownEnv bool) (err error)

func (*Request) Interupted

func (reqst *Request) Interupted() bool

func (*Request) IsActiveContent

func (reqst *Request) IsActiveContent(ext string) (active bool)

func (*Request) Parameters

func (reqst *Request) Parameters() (params *parameters.Parameters)

func (*Request) PopulateParameters

func (reqst *Request) PopulateParameters()

func (*Request) Print

func (reqst *Request) Print(a ...interface{})

func (*Request) Println

func (reqst *Request) Println(a ...interface{})

func (*Request) Read

func (reqst *Request) Read(p []byte) (n int, err error)

func (*Request) ReadFromOffset

func (reqst *Request) ReadFromOffset() int64

func (*Request) ReadRune

func (reqst *Request) ReadRune() (r rune, size int, err error)

func (*Request) ReadToOffset

func (reqst *Request) ReadToOffset() int64

func (*Request) RequestContent

func (reqst *Request) RequestContent() *iorw.BufferedRW

func (*Request) RequestHeader

func (reqst *Request) RequestHeader() http.Header

func (*Request) RequestHeaders

func (reqst *Request) RequestHeaders() (hdrs []string)

func (*Request) RequestMethod

func (reqst *Request) RequestMethod() string

func (*Request) RequestProtocol

func (reqst *Request) RequestProtocol() string

func (*Request) ResetRequest

func (reqst *Request) ResetRequest() (err error)

func (*Request) ResponseHeader

func (reqst *Request) ResponseHeader() http.Header

func (*Request) ResponseHeaders

func (reqst *Request) ResponseHeaders() (hdrs []string)

func (*Request) Seek

func (reqst *Request) Seek(offset int64, whence int) (n int64, err error)

func (*Request) ServeHTTP

func (reqst *Request) ServeHTTP() (err error)

func (*Request) SetRoots

func (reqst *Request) SetRoots()

func (*Request) Size

func (reqst *Request) Size() int64

func (*Request) Write

func (reqst *Request) Write(p []byte) (n int, err error)

func (*Request) WriteTo

func (reqst *Request) WriteTo(w io.Writer) (n int64, err error)

type Resource

type Resource struct {
	// contains filtered or unexported fields
}

func NewResource

func NewResource(reqst *Request, resourcepath string, a ...interface{}) (rsrc *Resource)

func (*Resource) Close

func (rsrc *Resource) Close() (err error)

func (*Resource) IsActiveContent

func (rsrc *Resource) IsActiveContent() (active bool)

func (*Resource) Path

func (rsrc *Resource) Path() string

func (*Resource) Read

func (rsrc *Resource) Read(p []byte) (n int, err error)

func (*Resource) ReadRune

func (rsrc *Resource) ReadRune() (r rune, size int, err error)

func (*Resource) ReadRuneBytes

func (rsrc *Resource) ReadRuneBytes(p []byte) (n int, err error)

func (*Resource) Seek

func (rsrc *Resource) Seek(offset int64, whence int) (n int64, err error)

func (*Resource) Size

func (rsrc *Resource) Size() int64

type ResourceInfo

type ResourceInfo struct {
	*active.Active
	// contains filtered or unexported fields
}

func NextResourceInfo

func NextResourceInfo(rsrc *Resource, path string, pathroot string, finfo os.FileInfo) (nxtrsinfo *ResourceInfo)

func (*ResourceInfo) Close

func (rsinfo *ResourceInfo) Close()

func (*ResourceInfo) IsActiveContent

func (rsinfo *ResourceInfo) IsActiveContent() (active bool)

func (*ResourceInfo) Path

func (rsinfo *ResourceInfo) Path() string

func (*ResourceInfo) PathRoot

func (rsinfo *ResourceInfo) PathRoot() string

func (*ResourceInfo) Reader

func (rsinfo *ResourceInfo) Reader(rsrc *Resource) (r io.Reader)

type ResourceInfoHandler

type ResourceInfoHandler struct {
}

type ResourcesManager

type ResourcesManager struct {
	// contains filtered or unexported fields
}

func (*ResourcesManager) MapResourceRoot

func (rsrcsmngr *ResourcesManager) MapResourceRoot(a ...interface{})

type Response

type Response struct {
	// contains filtered or unexported fields
}

func NewResponse

func NewResponse(w io.Writer, r *http.Request) (resp *Response)

func (*Response) Header

func (resp *Response) Header() http.Header

func (*Response) Write

func (resp *Response) Write(p []byte) (n int, err error)

func (*Response) WriteHeader

func (resp *Response) WriteHeader(statusCode int)

type RootHandler

type RootHandler struct {
	// contains filtered or unexported fields
}

type Talker

type Talker struct {
	// contains filtered or unexported fields
}

func NewTalker

func NewTalker(h2c ...bool) (tlkr *Talker)

func (*Talker) Close

func (tlkr *Talker) Close() (err error)

func (*Talker) FSend

func (tlkr *Talker) FSend(w io.Writer, body io.Reader, headers map[string][]string, url string, params ...interface{}) (err error)

func (*Talker) Print

func (tlkr *Talker) Print(a ...interface{})

Print iorw.Printing Print

func (*Talker) Println

func (tlkr *Talker) Println(a ...interface{})

Println iorw.Printing Print

func (*Talker) Read

func (tlkr *Talker) Read(p []byte) (n int, err error)

Read io.Reader Read

func (*Talker) ReadRune

func (tlkr *Talker) ReadRune() (r rune, size int, err error)

func (*Talker) Reset

func (tlkr *Talker) Reset()

func (*Talker) Send

func (tlkr *Talker) Send(url string, body io.Reader, headers map[string][]string, params ...interface{}) (err error)

func (*Talker) Write

func (tlkr *Talker) Write(p []byte) (n int, err error)

Write io.Writer Write

type Talking

type Talking interface {
	Send(url string, body io.Reader, headers map[string][]string, params ...interface{}) (err error)
	FSend(w io.Writer, body io.Reader, headers map[string][]string, url string, params ...interface{}) (err error)
}