repository

Documentation

Index

• func Outdate(outdaters []Outdater, delay time.Duration, stopChan <-chan struct{})
• type LinkRep
  • func NewLinkRep(stopChan <-chan struct{}) *LinkRep
  • func (lr *LinkRep) Count() int
  • func (lr *LinkRep) Read(id string, r *http.Request, closeChan <-chan struct{}) (ptpData *model.PtpData, ok bool)
  • func (lr *LinkRep) WaiterCount() (cnt int)
  • func (lr *LinkRep) Write(id string, linkData *model.LinkData, wSecret string, closeChan <-chan struct{}) (meta *model.Meta, ok bool, auth bool)
• type McastRep
  • func NewMcastRep(stopChan <-chan struct{}) *McastRep
  • func (mr *McastRep) DataCount() (size int)
  • func (mr *McastRep) GetData(id string, seqId int) (data *model.TeeData, ok bool)
  • func (mr *McastRep) Read(id string, wantedSeqId int, cancelChan <-chan struct{}) (data *model.TeeData, seqId int, ok bool)
  • func (mr *McastRep) Size() (size int)
  • func (mr *McastRep) WaiterCount() (size int)
  • func (mr *McastRep) Write(id string, data *model.TeeData, wSecret string) (seqId int, ok bool)
• type McastSeqMap
• type Outdater
• type ProxyRep
  • func NewProxyRep() *ProxyRep
  • func (pr *ProxyRep) GetSer(serId string) *model.ProxySer
• type SyncRep
  • func NewSyncRep(stopChan <-chan struct{}) *SyncRep
  • func (sr *SyncRep) Conduct(id string, syncData *model.SyncData, cancelChan <-chan struct{}) (ptpData *model.PtpData, ok bool)
  • func (sr *SyncRep) Count() int

Functions

func Outdate

func Outdate(outdaters []Outdater, delay time.Duration, stopChan <-chan struct{})

Types

type LinkRep

type LinkRep struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewLinkRep

func NewLinkRep(stopChan <-chan struct{}) *LinkRep

func (*LinkRep) Count

func (lr *LinkRep) Count() int

func (*LinkRep) Read

func (lr *LinkRep) Read(id string, r *http.Request, closeChan <-chan struct{}) (ptpData *model.PtpData, ok bool)

func (*LinkRep) WaiterCount

func (lr *LinkRep) WaiterCount() (cnt int)

func (*LinkRep) Write

func (lr *LinkRep) Write(id string, linkData *model.LinkData, wSecret string, closeChan <-chan struct{}) (meta *model.Meta, ok bool, auth bool)

type McastRep

type McastRep struct {
	McastSeqMap
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMcastRep

func NewMcastRep(stopChan <-chan struct{}) *McastRep

func (*McastRep) DataCount

func (mr *McastRep) DataCount() (size int)

func (*McastRep) GetData

func (mr *McastRep) GetData(id string, seqId int) (data *model.TeeData, ok bool)

func (*McastRep) Read

func (mr *McastRep) Read(id string, wantedSeqId int, cancelChan <-chan struct{}) (data *model.TeeData, seqId int, ok bool)

func (*McastRep) Size

func (mr *McastRep) Size() (size int)

func (*McastRep) WaiterCount

func (mr *McastRep) WaiterCount() (size int)

func (*McastRep) Write

func (mr *McastRep) Write(id string, data *model.TeeData, wSecret string) (seqId int, ok bool)

type McastSeqMap

type McastSeqMap map[string]*model.McastSeq

type Outdater

type Outdater interface {
	// contains filtered or unexported methods
}

type ProxyRep

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

func NewProxyRep

func NewProxyRep() *ProxyRep

func (*ProxyRep) GetSer

func (pr *ProxyRep) GetSer(serId string) *model.ProxySer

type SyncRep

type SyncRep struct {
	sync.RWMutex
	model.Waiters
	// contains filtered or unexported fields
}

func NewSyncRep

func NewSyncRep(stopChan <-chan struct{}) *SyncRep

func (*SyncRep) Conduct

func (sr *SyncRep) Conduct(id string, syncData *model.SyncData, cancelChan <-chan struct{}) (ptpData *model.PtpData, ok bool)

func (*SyncRep) Count

func (sr *SyncRep) Count() int