Documentation ¶
Index ¶
- Constants
- Variables
- type Action
- type Client
- type Command
- type Config
- func (*Config) Descriptor() ([]byte, []int)
- func (m *Config) GetMaxMessageSize() int64
- func (m *Config) GetPingPeriod() string
- func (m *Config) GetPongWait() string
- func (m *Config) GetPort() int32
- func (m *Config) GetWriteWait() string
- func (m *Config) Marshal() (dAtA []byte, err error)
- func (m *Config) MarshalTo(dAtA []byte) (int, error)
- func (m *Config) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Config) ProtoMessage()
- func (m *Config) Reset()
- func (m *Config) Size() (n int)
- func (m *Config) String() string
- func (m *Config) Unmarshal(dAtA []byte) error
- func (m *Config) XXX_DiscardUnknown()
- func (m *Config) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Config) XXX_Merge(src proto.Message)
- func (*Config) XXX_MessageName() string
- func (m *Config) XXX_Size() int
- func (m *Config) XXX_Unmarshal(b []byte) error
- type Hub
- type Payload
- type WebSocket
- func (w *WebSocket) ConfigURL() string
- func (w *WebSocket) Entry()
- func (w *WebSocket) Init(api types.ModuleAPIClient)
- func (w *WebSocket) Name() string
- func (w *WebSocket) NewConfig() proto.Message
- func (w *WebSocket) SetDiscoveryChan(c chan<- types.Event)
- func (w *WebSocket) SetEventsChan(c <-chan types.Event)
- func (w *WebSocket) Stop()
- func (w *WebSocket) UpdateConfig(cfg proto.Message) (e error)
Constants ¶
View Source
const WsStateURL = "/Services/websocket/State"
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct { Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` WriteWait string `protobuf:"bytes,3,opt,name=writeWait,proto3" json:"writeWait,omitempty"` PongWait string `protobuf:"bytes,4,opt,name=pongWait,proto3" json:"pongWait,omitempty"` PingPeriod string `protobuf:"bytes,5,opt,name=pingPeriod,proto3" json:"pingPeriod,omitempty"` MaxMessageSize int64 `protobuf:"varint,6,opt,name=maxMessageSize,proto3" json:"maxMessageSize,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*Config) Descriptor ¶
func (*Config) GetMaxMessageSize ¶
func (*Config) GetPingPeriod ¶
func (*Config) GetPongWait ¶
func (*Config) GetWriteWait ¶
func (*Config) MarshalToSizedBuffer ¶
func (*Config) ProtoMessage ¶
func (*Config) ProtoMessage()
func (*Config) XXX_DiscardUnknown ¶
func (m *Config) XXX_DiscardUnknown()
func (*Config) XXX_Marshal ¶
func (*Config) XXX_MessageName ¶
func (*Config) XXX_Unmarshal ¶
type Payload ¶
type WebSocket ¶
type WebSocket struct {
// contains filtered or unexported fields
}
func (*WebSocket) Init ¶
func (w *WebSocket) Init(api types.ModuleAPIClient)
func (*WebSocket) SetDiscoveryChan ¶
func (*WebSocket) SetEventsChan ¶
SetEventsChan sets the event channel this is generally done by the API
Click to show internal directories.
Click to hide internal directories.