websocket

Documentation

Index

• type Websocket
• type WebsocketListener
  • func NewWebsocketListener() *WebsocketListener
  • func (l *WebsocketListener) Events() []testkube.EventType
  • func (l *WebsocketListener) Kind() string
  • func (l *WebsocketListener) Metadata() map[string]string
  • func (l *WebsocketListener) Name() string
  • func (l *WebsocketListener) Notify(event testkube.Event) (result testkube.EventResult)
  • func (l *WebsocketListener) Selector() string
• type WebsocketLoader
  • func NewWebsocketLoader() *WebsocketLoader
  • func (l *WebsocketLoader) Add(conn *websocket.Conn) chan bool
  • func (l *WebsocketLoader) Kind() string
  • func (l *WebsocketLoader) Load() (listeners common.Listeners, err error)

Types

type Websocket

type Websocket struct {
	Id       string
	Conn     *websocket.Conn
	Selector string
	Events   []testkube.EventType
}

type WebsocketListener

type WebsocketListener struct {
	Log *zap.SugaredLogger

	Websockets []Websocket
	// contains filtered or unexported fields
}

func NewWebsocketListener

func NewWebsocketListener() *WebsocketListener

func (*WebsocketListener) Events

func (l *WebsocketListener) Events() []testkube.EventType

func (*WebsocketListener) Kind

func (l *WebsocketListener) Kind() string

func (*WebsocketListener) Metadata

func (l *WebsocketListener) Metadata() map[string]string

func (*WebsocketListener) Name

func (l *WebsocketListener) Name() string

func (*WebsocketListener) Notify

func (l *WebsocketListener) Notify(event testkube.Event) (result testkube.EventResult)

func (*WebsocketListener) Selector

func (l *WebsocketListener) Selector() string

type WebsocketLoader

type WebsocketLoader struct {
	Listener *WebsocketListener
	// contains filtered or unexported fields
}

func NewWebsocketLoader

func NewWebsocketLoader() *WebsocketLoader

func (*WebsocketLoader) Add

func (l *WebsocketLoader) Add(conn *websocket.Conn) chan bool

func (*WebsocketLoader) Kind

func (l *WebsocketLoader) Kind() string

func (*WebsocketLoader) Load

func (l *WebsocketLoader) Load() (listeners common.Listeners, err error)