subscribe

Documentation

Index

• func Handler(apiOp *types.APIRequest) (types.APIObject, error)
• func MarshallObject(apiOp *types.APIRequest, event types.APIEvent) types.APIEvent
• func Register(schemas *types.Schemas)
• type Converter
  • func (c *Converter) Encoder(w io.Writer, obj interface{}) error
  • func (c *Converter) ToAPIObject(data interface{}) (types.APIObject, error)
• type Subscribe
• type WatchSession
  • func NewWatchSession(apiOp *types.APIRequest) *WatchSession
  • func (s *WatchSession) Close()
  • func (s *WatchSession) Watch(conn *websocket.Conn) <-chan types.APIEvent

Functions

func Handler

func Handler(apiOp *types.APIRequest) (types.APIObject, error)

func MarshallObject

func MarshallObject(apiOp *types.APIRequest, event types.APIEvent) types.APIEvent

func Register

func Register(schemas *types.Schemas)

Types

type Converter

type Converter struct {
	writer.EncodingResponseWriter
	// contains filtered or unexported fields
}

func (*Converter) Encoder

func (c *Converter) Encoder(w io.Writer, obj interface{}) error

func (*Converter) ToAPIObject

func (c *Converter) ToAPIObject(data interface{}) (types.APIObject, error)

type Subscribe

type Subscribe struct {
	Stop            bool   `json:"stop,omitempty"`
	ResourceType    string `json:"resourceType,omitempty"`
	ResourceVersion string `json:"resourceVersion,omitempty"`
}

type WatchSession

type WatchSession struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewWatchSession

func NewWatchSession(apiOp *types.APIRequest) *WatchSession

func (*WatchSession) Close

func (s *WatchSession) Close()

func (*WatchSession) Watch

func (s *WatchSession) Watch(conn *websocket.Conn) <-chan types.APIEvent