Versions in this module Expand all Collapse all v0 v0.5.6 May 24, 2026 v0.5.5 May 24, 2026 Changes in this version + var File_websocket_proto protoreflect.FileDescriptor + type WSCloseConfig struct + ConnectionId string + func (*WSCloseConfig) Descriptor() ([]byte, []int) + func (*WSCloseConfig) ProtoMessage() + func (x *WSCloseConfig) GetConnectionId() string + func (x *WSCloseConfig) ProtoReflect() protoreflect.Message + func (x *WSCloseConfig) Reset() + func (x *WSCloseConfig) String() string + type WSCloseInput struct + Data *structpb.Struct + func (*WSCloseInput) Descriptor() ([]byte, []int) + func (*WSCloseInput) ProtoMessage() + func (x *WSCloseInput) GetData() *structpb.Struct + func (x *WSCloseInput) ProtoReflect() protoreflect.Message + func (x *WSCloseInput) Reset() + func (x *WSCloseInput) String() string + type WSCloseOutput struct + Closed bool + Error string + func (*WSCloseOutput) Descriptor() ([]byte, []int) + func (*WSCloseOutput) ProtoMessage() + func (x *WSCloseOutput) GetClosed() bool + func (x *WSCloseOutput) GetError() string + func (x *WSCloseOutput) ProtoReflect() protoreflect.Message + func (x *WSCloseOutput) Reset() + func (x *WSCloseOutput) String() string + type WSSendConfig struct + ConnectionId string + Message string + func (*WSSendConfig) Descriptor() ([]byte, []int) + func (*WSSendConfig) ProtoMessage() + func (x *WSSendConfig) GetConnectionId() string + func (x *WSSendConfig) GetMessage() string + func (x *WSSendConfig) ProtoReflect() protoreflect.Message + func (x *WSSendConfig) Reset() + func (x *WSSendConfig) String() string + type WSSendInput struct + Data *structpb.Struct + func (*WSSendInput) Descriptor() ([]byte, []int) + func (*WSSendInput) ProtoMessage() + func (x *WSSendInput) GetData() *structpb.Struct + func (x *WSSendInput) ProtoReflect() protoreflect.Message + func (x *WSSendInput) Reset() + func (x *WSSendInput) String() string + type WSSendOutput struct + Error string + Sent bool + func (*WSSendOutput) Descriptor() ([]byte, []int) + func (*WSSendOutput) ProtoMessage() + func (x *WSSendOutput) GetError() string + func (x *WSSendOutput) GetSent() bool + func (x *WSSendOutput) ProtoReflect() protoreflect.Message + func (x *WSSendOutput) Reset() + func (x *WSSendOutput) String() string + type WSServerConfig struct + AuthRequired bool + MaxConnections int32 + MaxMessageSize int64 + Path string + PingInterval string + PongWait string + func (*WSServerConfig) Descriptor() ([]byte, []int) + func (*WSServerConfig) ProtoMessage() + func (x *WSServerConfig) GetAuthRequired() bool + func (x *WSServerConfig) GetMaxConnections() int32 + func (x *WSServerConfig) GetMaxMessageSize() int64 + func (x *WSServerConfig) GetPath() string + func (x *WSServerConfig) GetPingInterval() string + func (x *WSServerConfig) GetPongWait() string + func (x *WSServerConfig) ProtoReflect() protoreflect.Message + func (x *WSServerConfig) Reset() + func (x *WSServerConfig) String() string + type WebSocketTriggerConfig struct + func (*WebSocketTriggerConfig) Descriptor() ([]byte, []int) + func (*WebSocketTriggerConfig) ProtoMessage() + func (x *WebSocketTriggerConfig) ProtoReflect() protoreflect.Message + func (x *WebSocketTriggerConfig) Reset() + func (x *WebSocketTriggerConfig) String() string