Documentation
¶
Index ¶
Constants ¶
const (
WatchHeader = "X-Watch"
)
Header.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶ added in v0.2.9
type Client struct {
// Transport.
Transport http.RoundTripper
// Headers.
Header http.Header
}
REST client.
type Event ¶ added in v0.2.9
type Event struct {
// ID
ID uint64
// Action.
Action uint8
// Affected Resource.
Resource interface{}
// Updated resource.
Updated interface{}
}
Event
type EventHandler ¶ added in v0.2.9
type EventHandler interface {
// The watch has started.
Started(uint64)
// Parity marker.
// The watch has delivered the initial set
// of `Created` events.
Parity()
// Resource created.
Created(r Event)
// Resource updated.
Updated(r Event)
// Resource deleted.
Deleted(r Event)
// An error has occurred.
// The handler may call the Repair() on
// the watch to repair the watch as desired.
Error(*Watch, error)
// The watch has ended.
End()
}
Event handler
type Parity ¶ added in v0.2.9
type Parity struct {
}
Parity (not-partial) request handler.
func (*Parity) EnsureParity ¶ added in v0.2.9
Ensure reconciler has achieved parity.
type RequestHandler ¶
type RequestHandler interface {
// Add routes to the `gin` router.
AddRoutes(*gin.Engine)
// List resources in a REST collection.
List(*gin.Context)
// Get a specific REST resource.
Get(*gin.Context)
}
Web request handler.
type ResourceBuilder ¶ added in v0.2.9
Watched resource builder.
type SchemaHandler ¶
type SchemaHandler struct {
// Schema version
Version string
// Schema release.
Release int
// contains filtered or unexported fields
}
Schema (route) handler.
type StockEventHandler ¶ added in v0.3.1
type StockEventHandler struct{}
Stock event handler. Provides default event methods.
func (*StockEventHandler) Created ¶ added in v0.3.1
func (r *StockEventHandler) Created(Event)
A model has been created.
func (*StockEventHandler) Deleted ¶ added in v0.3.1
func (r *StockEventHandler) Deleted(Event)
A model has been deleted.
func (*StockEventHandler) End ¶ added in v0.3.1
func (r *StockEventHandler) End()
An event watch has ended.
func (*StockEventHandler) Error ¶ added in v0.3.1
func (r *StockEventHandler) Error(*Watch, error)
An error has occurred reading events.
func (*StockEventHandler) Parity ¶ added in v0.3.1
func (r *StockEventHandler) Parity()
Watch has parity.
func (*StockEventHandler) Started ¶ added in v0.3.1
func (r *StockEventHandler) Started(uint64)
Watch has started.
func (*StockEventHandler) Updated ¶ added in v0.3.1
func (r *StockEventHandler) Updated(Event)
A model has been updated.
type Watch ¶ added in v0.2.9
type Watch struct {
// contains filtered or unexported fields
}
Represents a watch.
type WatchReader ¶ added in v0.2.9
type WatchReader struct {
// contains filtered or unexported fields
}
Watch (event) reader.
func (*WatchReader) Repair ¶ added in v0.3.1
func (r *WatchReader) Repair() (status int, err error)
Repair.
type WatchWriter ¶ added in v0.2.9
type WatchWriter struct {
// contains filtered or unexported fields
}
Watch (event) writer.
func (*WatchWriter) Created ¶ added in v0.2.9
func (r *WatchWriter) Created(event model.Event)
A model has been created.
func (*WatchWriter) Deleted ¶ added in v0.2.9
func (r *WatchWriter) Deleted(event model.Event)
A model has been deleted.
func (*WatchWriter) Error ¶ added in v0.2.9
func (r *WatchWriter) Error(err error)
An error has occurred delivering an event.
func (*WatchWriter) Started ¶ added in v0.2.9
func (r *WatchWriter) Started(watchID uint64)
Watch has started.
func (*WatchWriter) Updated ¶ added in v0.2.9
func (r *WatchWriter) Updated(event model.Event)
A model has been updated.
type Watched ¶ added in v0.2.9
type Watched struct {
WatchRequest bool
}
Watched (handler).
type WebServer ¶
type WebServer struct {
// The optional port. Default: 8080
Port int
// Allowed CORS origins.
AllowedOrigins []string
// Reference to the container.
Container *container.Container
// Handlers
Handlers []RequestHandler
// TLS.
TLS struct {
// Enabled.
Enabled bool
// Certificate path.
Certificate string
// Key path
Key string
}
// contains filtered or unexported fields
}
Web server