model

package

v0.0.0-...-3f804d4 Latest Latest Go to latest Published: Mar 31, 2022 License: MIT Imports: 11 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

gitlab.com/jonas.jasas/httprelay

Documentation ¶

Index ¶

Constants
type Link
- func NewLink() *Link
- func (c *Link) Accessed()
- func (l *Link) Chan() chan *LinkData
- func (c *Link) Expired() bool
- func (c *Link) WAuth(wSecret string) bool
type LinkData
- func NewLinkData(r *http.Request) *LinkData
type McastData
- func NewMcastData() *McastData
- func (md *McastData) Close()
- func (md *McastData) Read(closeChan <-chan struct{}) (data *TeeData, ok bool)
- func (md *McastData) Size() int
- func (md *McastData) Write(data *TeeData)
type McastSeq
- func NewMcastSeq(initialSeqId int) *McastSeq
- func (c *McastSeq) Accessed()
- func (ms *McastSeq) Close()
- func (ms *McastSeq) DataCount() int
- func (c *McastSeq) Expired() bool
- func (ms *McastSeq) GetData(seqId int) (data *TeeData, ok bool)
- func (ms *McastSeq) NewSeqId() int
- func (ms *McastSeq) Read(wantedSeqId int, closeChan <-chan struct{}) (data *TeeData, seqId int, ok bool)
- func (ms *McastSeq) Size() int
- func (c *McastSeq) WAuth(wSecret string) bool
- func (ms *McastSeq) Write(data *TeeData) (seqId int)
type Meta
- func NewMeta(r *http.Request) *Meta
- func (m *Meta) Memory() int64
- func (m *Meta) WriteHeaders(w http.ResponseWriter, yourTime time.Time, content bool)
type ProxyCliData
- func NewProxyCliData(r *http.Request, serId, serPath string) (proxyReqData *ProxyCliData)
- func (pcd *ProxyCliData) CloseRespChan() (ok bool)
type ProxySer
- func NewProxySer() *ProxySer
- func (c *ProxySer) Accessed()
- func (ps *ProxySer) AddJob(jobId string, proxyData *ProxyCliData)
- func (c *ProxySer) Expired() bool
- func (ps *ProxySer) RemoveJob(cliData *ProxyCliData)
- func (ps *ProxySer) TakeJob(jobId string) (proxyData *ProxyCliData, ok bool)
- func (c *ProxySer) WAuth(wSecret string) bool
type ProxySerData
- func NewProxySerData(r *http.Request) (proxyRespData *ProxySerData)
type PtpData
- func NewPtpData(r *http.Request) *PtpData
- func (pd *PtpData) Write(w http.ResponseWriter, yourTime time.Time) (err error)
type SyncData
- func NewSyncData(r *http.Request) *SyncData
type TeeData
- func NewTeeData(r *http.Request) *TeeData
- func (td *TeeData) Cancel()
- func (td *TeeData) CopyContent() (n int64, err error)
type Waiters
- func NewWaiters() *Waiters
- func (w *Waiters) AddWaiter()
- func (w *Waiters) HasWaiters() bool
- func (w *Waiters) RemoveWaiter()
- func (w *Waiters) Wait() <-chan struct{}
- func (w *Waiters) WaiterCount() int

Constants ¶

View Source

const MaxAge = time.Minute * 20

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Link ¶

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

func NewLink ¶

func NewLink() *Link

func (*Link) Accessed ¶

func (c *Link) Accessed()

func (*Link) Chan ¶

func (l *Link) Chan() chan *LinkData

func (*Link) Expired ¶

func (c *Link) Expired() bool

func (*Link) WAuth ¶

func (c *Link) WAuth(wSecret string) bool

type LinkData ¶

type LinkData struct {
	Data     *PtpData
	BackChan chan *Meta
}

func NewLinkData ¶

func NewLinkData(r *http.Request) *LinkData

type McastData ¶

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

func NewMcastData ¶

func NewMcastData() *McastData

func (*McastData) Close ¶

func (md *McastData) Close()

func (*McastData) Read ¶

func (md *McastData) Read(closeChan <-chan struct{}) (data *TeeData, ok bool)

func (*McastData) Size ¶

func (md *McastData) Size() int

func (*McastData) Write ¶

func (md *McastData) Write(data *TeeData)

type McastSeq ¶

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

func NewMcastSeq ¶

func NewMcastSeq(initialSeqId int) *McastSeq

func (*McastSeq) Accessed ¶

func (c *McastSeq) Accessed()

func (*McastSeq) Close ¶

func (ms *McastSeq) Close()

func (*McastSeq) DataCount ¶

func (ms *McastSeq) DataCount() int

func (*McastSeq) Expired ¶

func (c *McastSeq) Expired() bool

func (*McastSeq) GetData ¶

func (ms *McastSeq) GetData(seqId int) (data *TeeData, ok bool)

func (*McastSeq) NewSeqId ¶

func (ms *McastSeq) NewSeqId() int

func (*McastSeq) Read ¶

func (ms *McastSeq) Read(wantedSeqId int, closeChan <-chan struct{}) (data *TeeData, seqId int, ok bool)

func (*McastSeq) Size ¶

func (ms *McastSeq) Size() int

func (*McastSeq) WAuth ¶

func (c *McastSeq) WAuth(wSecret string) bool

func (*McastSeq) Write ¶

func (ms *McastSeq) Write(data *TeeData) (seqId int)

type Meta ¶

type Meta struct {
	Time          time.Time
	Header        http.Header
	ContentType   string
	Method        string
	Query         string
	SrcIP         string
	SrcPort       string
	ContentLength int64
}

func NewMeta ¶

func NewMeta(r *http.Request) *Meta

func (*Meta) Memory ¶

func (m *Meta) Memory() int64

func (*Meta) WriteHeaders ¶

func (m *Meta) WriteHeaders(w http.ResponseWriter, yourTime time.Time, content bool)

type ProxyCliData ¶

type ProxyCliData struct {
	Url       string
	Method    string
	Scheme    string
	Host      string
	Port      string
	Path      string
	Query     string
	Fragment  string
	SerId     string
	Header    *http.Header
	Body      *buffreader.BuffReader
	RespChan  chan *ProxySerData
	RespChanL sync.Mutex
}

func NewProxyCliData ¶

func NewProxyCliData(r *http.Request, serId, serPath string) (proxyReqData *ProxyCliData)

func (*ProxyCliData) CloseRespChan ¶

func (pcd *ProxyCliData) CloseRespChan() (ok bool)

type ProxySer ¶

type ProxySer struct {
	ReqChan chan *ProxyCliData
	// contains filtered or unexported fields
}

Creating when first request to/from server is made

func NewProxySer ¶

func NewProxySer() *ProxySer

func (*ProxySer) Accessed ¶

func (c *ProxySer) Accessed()

func (*ProxySer) AddJob ¶

func (ps *ProxySer) AddJob(jobId string, proxyData *ProxyCliData)

func (*ProxySer) Expired ¶

func (c *ProxySer) Expired() bool

func (*ProxySer) RemoveJob ¶

func (ps *ProxySer) RemoveJob(cliData *ProxyCliData)

func (*ProxySer) TakeJob ¶

func (ps *ProxySer) TakeJob(jobId string) (proxyData *ProxyCliData, ok bool)

func (*ProxySer) WAuth ¶

func (c *ProxySer) WAuth(wSecret string) bool

type ProxySerData ¶

type ProxySerData struct {
	Header *http.Header
	Body   *buffreader.BuffReader
}

func NewProxySerData ¶

func NewProxySerData(r *http.Request) (proxyRespData *ProxySerData)

type PtpData ¶

type PtpData struct {
	Meta    *Meta
	Content *buffreader.BuffReader
}

func NewPtpData ¶

func NewPtpData(r *http.Request) *PtpData

func (*PtpData) Write ¶

func (pd *PtpData) Write(w http.ResponseWriter, yourTime time.Time) (err error)

type SyncData ¶

type SyncData struct {
	Data     *PtpData
	BackChan chan *PtpData
}

func NewSyncData ¶

func NewSyncData(r *http.Request) *SyncData

type TeeData ¶

type TeeData struct {
	Meta    *Meta
	Content *bufftee.BuffTee
	// contains filtered or unexported fields
}

func NewTeeData ¶

func NewTeeData(r *http.Request) *TeeData

func (*TeeData) Cancel ¶

func (td *TeeData) Cancel()

func (*TeeData) CopyContent ¶

func (td *TeeData) CopyContent() (n int64, err error)

type Waiters ¶

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

func NewWaiters ¶

func NewWaiters() *Waiters

func (*Waiters) AddWaiter ¶

func (w *Waiters) AddWaiter()

func (*Waiters) HasWaiters ¶

func (w *Waiters) HasWaiters() bool

func (*Waiters) RemoveWaiter ¶

func (w *Waiters) RemoveWaiter()

func (*Waiters) Wait ¶

func (w *Waiters) Wait() <-chan struct{}

func (*Waiters) WaiterCount ¶

func (w *Waiters) WaiterCount() int

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL