websocket

Documentation

Index

• Variables
• func AddSubscription(srv common.LocalService, name string, handler p2p.PubSubConsumerHandler, ...) (subIdex int, err error)
• func Handler(srv common.LocalService, ctx service.Context, conn *websocket.Conn) service.WebSocketHandler
• func New(srv common.LocalService, mmi common.MessagingMapItem, ...) (commonIface.Serviceable, error)
• type WebSocket
  • func (ws *WebSocket) Application() string
  • func (ws *WebSocket) AssetId() string
  • func (ws *WebSocket) Clean()
  • func (w *WebSocket) Close()
  • func (ws *WebSocket) Commit() string
  • func (ws *WebSocket) Config() *structureSpec.Function
  • func (ws *WebSocket) HandleMessage(msg *pubsub.Message) (t time.Time, err error)
  • func (w *WebSocket) Id() (id string)
  • func (ws *WebSocket) Match(matcher components.MatchDefinition) (currentMatchIndex matcherSpec.Index)
  • func (ws *WebSocket) Matcher() components.MatchDefinition
  • func (ws *WebSocket) Name() string
  • func (ws *WebSocket) Project() string
  • func (w *WebSocket) Ready() error
  • func (ws *WebSocket) Service() components.ServiceComponent
  • func (ws *WebSocket) Validate(matcher components.MatchDefinition) error
• type WrappedMessage

Variables

var AttachWebSocket = func(ws *WebSocket) error {

	return nil
}

Functions

func AddSubscription

func AddSubscription(srv common.LocalService, name string, handler p2p.PubSubConsumerHandler, err_handler p2p.PubSubConsumerErrorHandler) (subIdex int, err error)

func Handler

func Handler(srv common.LocalService, ctx service.Context, conn *websocket.Conn) service.WebSocketHandler

func New

func New(srv common.LocalService, mmi common.MessagingMapItem, matcher *common.MatchDefinition) (commonIface.Serviceable, error)

Types

type WebSocket

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

func (*WebSocket) Application

func (ws *WebSocket) Application() string

func (*WebSocket) AssetId

func (ws *WebSocket) AssetId() string

func (*WebSocket) Clean

func (ws *WebSocket) Clean()

func (*WebSocket) Close

func (w *WebSocket) Close()

func (*WebSocket) Commit

func (ws *WebSocket) Commit() string

func (*WebSocket) Config

func (ws *WebSocket) Config() *structureSpec.Function

TODO: Fix this

func (*WebSocket) HandleMessage

func (ws *WebSocket) HandleMessage(msg *pubsub.Message) (t time.Time, err error)

func (*WebSocket) Id

func (w *WebSocket) Id() (id string)

func (*WebSocket) Match

func (ws *WebSocket) Match(matcher components.MatchDefinition) (currentMatchIndex matcherSpec.Index)

func (*WebSocket) Matcher

func (ws *WebSocket) Matcher() components.MatchDefinition

func (*WebSocket) Name

func (ws *WebSocket) Name() string

func (*WebSocket) Project

func (ws *WebSocket) Project() string

func (*WebSocket) Ready

func (w *WebSocket) Ready() error

func (*WebSocket) Service

func (ws *WebSocket) Service() components.ServiceComponent

func (*WebSocket) Validate

func (ws *WebSocket) Validate(matcher components.MatchDefinition) error

type WrappedMessage

type WrappedMessage struct {
	Message []byte `json:"message"`
	Error   string `json:"error"`
}