controller

Documentation

Index

• type LinkCtrl
  • func NewLinkCtrl(rep LinkRep, stopChan <-chan struct{}) *LinkCtrl
  • func (lc *LinkCtrl) Conduct(w http.ResponseWriter, r *http.Request)
• type LinkRep
• type McastCtrl
  • func NewMcastCtrl(rep McastRep, stopChan <-chan struct{}) *McastCtrl
  • func (mc *McastCtrl) Conduct(w http.ResponseWriter, r *http.Request)
• type McastRep
• type ProxyCtrl
  • func NewProxyCtrl(rep *repository.ProxyRep, stopChan <-chan struct{}) *ProxyCtrl
  • func (pc *ProxyCtrl) Conduct(w http.ResponseWriter, r *http.Request)
• type SyncCtrl
  • func NewSyncCtrl(rep SyncRep, stopChan <-chan struct{}) *SyncCtrl
  • func (sc *SyncCtrl) Conduct(w http.ResponseWriter, r *http.Request)
• type SyncRep

Types

type LinkCtrl

type LinkCtrl struct {
	*model.Waiters
	// contains filtered or unexported fields
}

func NewLinkCtrl

func NewLinkCtrl(rep LinkRep, stopChan <-chan struct{}) *LinkCtrl

func (*LinkCtrl) Conduct

func (lc *LinkCtrl) Conduct(w http.ResponseWriter, r *http.Request)

type LinkRep

type LinkRep interface {
	Read(id string, r *http.Request, cancelChan <-chan struct{}) (ptpData *model.PtpData, ok bool)
	Write(id string, linkData *model.LinkData, wSecret string, cancelChan <-chan struct{}) (meta *model.Meta, ok bool, auth bool)
}

type McastCtrl

type McastCtrl struct {
	*model.Waiters
	// contains filtered or unexported fields
}

func NewMcastCtrl

func NewMcastCtrl(rep McastRep, stopChan <-chan struct{}) *McastCtrl

func (*McastCtrl) Conduct

func (mc *McastCtrl) Conduct(w http.ResponseWriter, r *http.Request)

type McastRep

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

type ProxyCtrl

type ProxyCtrl struct {
	*model.Waiters
	// contains filtered or unexported fields
}

func NewProxyCtrl

func NewProxyCtrl(rep *repository.ProxyRep, stopChan <-chan struct{}) *ProxyCtrl

func (*ProxyCtrl) Conduct

func (pc *ProxyCtrl) Conduct(w http.ResponseWriter, r *http.Request)

type SyncCtrl

type SyncCtrl struct {
	*model.Waiters
	// contains filtered or unexported fields
}

func NewSyncCtrl

func NewSyncCtrl(rep SyncRep, stopChan <-chan struct{}) *SyncCtrl

func (*SyncCtrl) Conduct

func (sc *SyncCtrl) Conduct(w http.ResponseWriter, r *http.Request)

type SyncRep

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