replayapi

Documentation

Index

• type Api
  • func (rc *Api) Attached(method string) bool
  • func (rs *Api) Create(w http.ResponseWriter, r *http.Request, _ httprouter.Params)
  • func (rs *Api) Delete(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
  • func (rs *Api) List(w http.ResponseWriter, r *http.Request, _ httprouter.Params)
  • func (rs *Api) Read(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
  • func (rs *Api) Replace(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
  • func (rs *Api) Update(w http.ResponseWriter, r *http.Request, ps httprouter.Params)
• type Job
• type ReplayStore
  • func NewReplayStore(userCache *userapi.UserCache, replayer func(Job)) *ReplayStore

Types

type Api

type Api struct {
	*ReplayStore
}

receiver type

func (*Api) Attached

func (rc *Api) Attached(method string) bool

implement the Cruder interface

func (*Api) Create

func (rs *Api) Create(w http.ResponseWriter, r *http.Request, _ httprouter.Params)

func (*Api) Delete

func (rs *Api) Delete(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

func (*Api) List

func (rs *Api) List(w http.ResponseWriter, r *http.Request, _ httprouter.Params)

func (*Api) Read

func (rs *Api) Read(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

func (*Api) Replace

func (rs *Api) Replace(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

func (*Api) Update

func (rs *Api) Update(w http.ResponseWriter, r *http.Request, ps httprouter.Params)

type Job

type Job struct {
	Id             string
	OriginStart    int64
	OriginStop     int64
	OriginDuration int64
	Observatories  []string `json:,omitempty` // [default: empty list means 'all']
	Start          int64    // Start time [default: NOW]
	Speed          int64    // OriginDuration / Duration
	Reason         string   // Job's purpose
	ServerURL      string
	// report each replay record to be submitted
	Verbose bool
	// data timestamps are time-shifted to now by default
	KeepOriginalDataTimestamps bool
	// non-input fields
	Cancel chan struct{} `json:"-"`
	Done   chan struct{} `json:"-"`
}

type ReplayStore

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

receiver type

func NewReplayStore

func NewReplayStore(userCache *userapi.UserCache, replayer func(Job)) *ReplayStore

generator