web

Aug 19, 2021

Changes in this version

type Event

+ Labels []string

Jun 7, 2021

Changes in this version

+ const WatchSnapshot

type Client

+ Reply struct{ ... }

type EventHandler

+ Options func() WatchOptions

type StockEventHandler

+ func (r *StockEventHandler) Options() WatchOptions

+ type WatchOptions = libmodel.WatchOptions

type WatchWriter

+ func (r *WatchWriter) Options() model.WatchOptions

May 17, 2021

Changes in this version

type WatchWriter

+ func (r *WatchWriter) Start(watch *model.Watch)

May 8, 2021

Changes in this version

+ type Param struct

+ Key string

+ Value string

Apr 20, 2021

Changes in this version

type Watch

+ func (r *Watch) ID() uint64

Apr 16, 2021

Changes in this version

type Event

+ ID uint64

+ func (r *Event) String() string

Mar 29, 2021

Changes in this version

+ type StockEventHandler struct

+ func (r *StockEventHandler) Created(Event)

+ func (r *StockEventHandler) Deleted(Event)

+ func (r *StockEventHandler) End()

+ func (r *StockEventHandler) Error(*Watch, error)

+ func (r *StockEventHandler) Parity()

+ func (r *StockEventHandler) Started()

+ func (r *StockEventHandler) Updated(Event)

type Watch

+ func (r *Watch) Alive() bool

+ func (r *Watch) Repair() (err error)

type WatchReader

+ func (r *WatchReader) Repair() (status int, err error)

+ func (r *WatchReader) Terminate()

Mar 18, 2021

Changes in this version

+ const WatchHeader

+ type Client struct

+ Header http.Header

+ Transport http.RoundTripper

+ func (r *Client) Get(url string, out interface{}) (status int, err error)

+ func (r *Client) Post(url string, in interface{}, out interface{}) (status int, err error)

+ func (r *Client) Watch(url string, resource interface{}, handler EventHandler) (status int, w *Watch, err error)

+ type Event struct

+ Action int8

+ Resource interface{}

+ Updated interface{}

+ type EventHandler interface

+ Created func(r Event)

+ Deleted func(r Event)

+ End func()

+ Error func(error)

+ Parity func()

+ Started func()

+ Updated func(r Event)

+ type Parity struct

+ func (c *Parity) EnsureParity(r container.Reconciler, w time.Duration) int

+ type ResourceBuilder func(model.Model) interface

+ type Watch struct

+ func (r *Watch) End()

+ type WatchReader struct

+ type WatchWriter struct

+ func (r *WatchWriter) Created(event model.Event)

+ func (r *WatchWriter) Deleted(event model.Event)

+ func (r *WatchWriter) End()

+ func (r *WatchWriter) Error(err error)

+ func (r *WatchWriter) Parity()

+ func (r *WatchWriter) Started()

+ func (r *WatchWriter) Updated(event model.Event)

+ type Watched struct

+ WatchRequest bool

+ func (h *Watched) Prepare(ctx *gin.Context) int

+ func (r *Watched) Watch(ctx *gin.Context, db model.DB, m model.Model, rb ResourceBuilder) (err error)

Nov 23, 2020

Changes in this version

type WebServer

+ Port int

+ TLS struct{ ... }

Sep 21, 2020

Changes in this version

+ const NsCollection

+ const NsParam

+ const Root

+ type Authorized struct

+ Token string

+ func (h *Authorized) Prepare(ctx *gin.Context) int

+ type Consistent struct

+ func (c *Consistent) EnsureConsistency(r container.Reconciler, w time.Duration) int

+ type Paged struct

+ Page model.Page

+ func (h *Paged) Prepare(ctx *gin.Context) int

+ type RequestHandler interface

+ AddRoutes func(*gin.Engine)

+ Get func(*gin.Context)

+ List func(*gin.Context)

+ type SchemaHandler struct

+ Release int

+ Version string

+ func (h *SchemaHandler) AddRoutes(r *gin.Engine)

+ func (h *SchemaHandler) List(ctx *gin.Context)

+ func (h SchemaHandler) Get(ctx *gin.Context)

+ type WebServer struct

+ AllowedOrigins []string

+ Container *container.Container

+ Handlers []RequestHandler

+ func New(c *container.Container, routes ...RequestHandler) *WebServer

+ func (w *WebServer) Start()