RigInboundGatewayWeb.V1.Websocket (Reactive Interaction Gateway v3.0.0-alpha.2) View Source
Cowboy WebSocket handler.
Reactive Interaction Gateway
v3.0.0-alpha.2
- RIG.AuthorizationCheck.External
- RIG.AuthorizationCheck.Submission
- RIG.AuthorizationCheck.Subscription
- RIG.Discovery
- RIG.DistributedSet
- RIG.JWT
- RIG.JWT.Claims
- RIG.JWT.HttpCredentials
- RIG.Plug.BodyReader
- RIG.Session
- RIG.Session.Connection
- RIG.Sources.HTTP.Handler
- RIG.Subscriptions
- RIG.Subscriptions.Parser.JSON
- RIG.Subscriptions.Parser.JWT
- RIG.Tracing
- RIG.Tracing.CloudEvent
- RIG.Tracing.Plug
- Result
- Rig.BrokerConnection
- Rig.Config
- Rig.Connection.Codec
- Rig.EventFilter
- Rig.EventFilter.Config
- Rig.EventFilter.Server
- Rig.EventFilter.Sup
- Rig.EventStream.KafkaToFilter
- Rig.EventStream.KinesisToFilter
- Rig.EventStream.NatsToFilter
- Rig.KafkaConfig
- Rig.KafkaConsumerSetup
- Rig.Plug.AuthHeader
- RigApi
-
RigApi.Endpoint
- Top
- Summary
-
Functions
- broadcast/3
- broadcast!/3
- broadcast_from/4
- broadcast_from!/4
- call/2
- child_spec/1
- config/0
- config/2
- config_change/2
- host/0
- init/1
- local_broadcast/3
- local_broadcast_from/4
- path/1
- script_name/0
- start_link/1
- static_integrity/1
- static_lookup/1
- static_path/1
- static_url/0
- struct_url/0
- subscribe/2
- unsubscribe/1
- url/0
- RigApi.ErrorView
- RigApi.Fallback
- RigApi.Health
- RigApi.Router
-
RigApi.Router.Helpers
- Top
- Summary
-
Functions
- ap_is_path/2
- ap_is_path/3
- ap_is_path/4
- ap_is_url/2
- ap_is_url/3
- ap_is_url/4
- health_path/2
- health_path/3
- health_url/2
- health_url/3
- live_dashboard_path/2
- live_dashboard_path/3
- live_dashboard_path/4
- live_dashboard_path/5
- live_dashboard_url/2
- live_dashboard_url/3
- live_dashboard_url/4
- live_dashboard_url/5
- messages_path/2
- messages_path/3
- messages_url/2
- messages_url/3
- path/2
- responses_path/2
- responses_path/3
- responses_url/2
- responses_url/3
- session_blacklist_path/2
- session_blacklist_path/3
- session_blacklist_path/4
- session_blacklist_url/2
- session_blacklist_url/3
- session_blacklist_url/4
- static_integrity/2
- static_path/2
- static_url/2
- url/1
- RigApi.V2.APIs
- RigApi.V2.Messages
- RigApi.V2.Responses
- RigApi.V2.SessionBlacklist
- RigApi.V3.APIs
- RigApi.V3.Messages
- RigApi.V3.Responses
- RigApi.V3.SessionBlacklist
- RigCloudEvents.CloudEvent
- RigCloudEvents.Parser
- RigCloudEvents.Parser.FullParser
- RigCloudEvents.Parser.PartialParser
- RigCloudEvents.PlugUtils
- RigInboundGateway.ApiProxy.Api
- RigInboundGateway.ApiProxy.Auth
- RigInboundGateway.ApiProxy.Auth.Jwt
-
RigInboundGateway.ApiProxy.Base
- Top
- Summary
- Types
-
Functions
- config/0
- delete/3
- delete!/3
- get/3
- get!/3
- head/3
- head!/3
- options/3
- options!/3
- patch/4
- patch!/4
- post/4
- post!/4
- process_headers/1
- process_request_body/1
- process_request_headers/1
- process_request_options/1
- process_request_params/1
- process_request_url/1
- process_response/1
- process_response_body/1
- process_response_chunk/1
- process_response_headers/1
- process_response_status_code/1
- process_status_code/1
- process_url/1
- put/4
- put!/4
- request/1
- request/5
- request!/5
- start/0
- stream_next/1
- RigInboundGateway.ApiProxy.Handler
- RigInboundGateway.ApiProxy.Handler.Http
- RigInboundGateway.ApiProxy.Handler.HttpHeader
- RigInboundGateway.ApiProxy.Handler.Kafka
- RigInboundGateway.ApiProxy.Handler.Kinesis
- RigInboundGateway.ApiProxy.Handler.Nats
- RigInboundGateway.ApiProxy.Plug
- RigInboundGateway.ApiProxy.PresenceHandler
- RigInboundGateway.ApiProxy.ResponseFromParser
- RigInboundGateway.ApiProxy.Router
- RigInboundGateway.ApiProxy.Serializer
- RigInboundGateway.ApiProxy.Sup
- RigInboundGateway.ApiProxy.Tracker
-
RigInboundGateway.ApiProxy.Validations
- Top
- Summary
- Types
-
Functions
- config/0
- to_map/1
- type_validation/4
- validate/1
- validate!/1
- validate_all/1
- validate_auth/2
- validate_auth_type/1
- validate_endpoint_target/2
- validate_endpoints/2
- validate_integer/2
- validate_list/2
- validate_proxy/1
- validate_required_props/2
- validate_secured_endpoint/2
- validate_string/2
- validate_version_data/1
- with_any_error/2
- with_nested_presence/3
- RigInboundGateway.Events
- RigInboundGateway.Proxy
- RigInboundGateway.RequestLogger
- RigInboundGateway.RequestLogger.ConfigValidation
- RigInboundGateway.RequestLogger.Console
- RigInboundGateway.RequestLogger.Kafka
- RigInboundGatewayWeb
- RigInboundGatewayWeb.ConnectionInit
- RigInboundGatewayWeb.ConnectionLimit
-
RigInboundGatewayWeb.Endpoint
- Top
- Summary
-
Functions
- broadcast/3
- broadcast!/3
- broadcast_from/4
- broadcast_from!/4
- call/2
- child_spec/1
- config/0
- config/2
- config_change/2
- host/0
- init/1
- local_broadcast/3
- local_broadcast_from/4
- path/1
- script_name/0
- start_link/1
- static_integrity/1
- static_lookup/1
- static_path/1
- static_url/0
- struct_url/0
- subscribe/2
- unsubscribe/1
- url/0
- RigInboundGatewayWeb.ErrorView
- RigInboundGatewayWeb.EventBuffer
- RigInboundGatewayWeb.HealthController
- RigInboundGatewayWeb.MediaTypeHandling
- RigInboundGatewayWeb.Router
-
RigInboundGatewayWeb.Router.Helpers
- Top
- Summary
-
Functions
- event_path/2
- event_path/3
- event_url/2
- event_url/3
- health_path/2
- health_path/3
- health_url/2
- health_url/3
- longpolling_path/2
- longpolling_path/3
- longpolling_url/2
- longpolling_url/3
- path/2
- static_integrity/2
- static_path/2
- static_url/2
- subscription_path/3
- subscription_path/4
- subscription_url/3
- subscription_url/4
- url/1
- RigInboundGatewayWeb.Session
- RigInboundGatewayWeb.V1.EventController
- RigInboundGatewayWeb.V1.LongpollingController
- RigInboundGatewayWeb.V1.SSE
- RigInboundGatewayWeb.V1.SubscriptionController
- RigInboundGatewayWeb.V1.Websocket
- RigKafka
- RigKafka.Avro
- RigKafka.Client
- RigKafka.Client.GroupSubscriber
- RigKafka.Config
- RigKafka.Serializer
- RigMetrics.DistributedSetMetrics
- RigMetrics.EventsMetrics
- RigMetrics.MetricsPlugExporter
- RigMetrics.ProxyMetrics
- RigMetrics.SubscriptionsMetrics
- RigMetrics.Telemetry
- RigOutboundGateway.Kinesis.JavaClient
- RigOutboundGateway.Kinesis.LogStream
- Exceptions
- RIG.JWT.DecodeError
- RIG.Subscriptions.Error
- RIG.Subscriptions.Parser.JSON.DecodeError
- RIG.Subscriptions.Parser.JSON.ParseError
- RIG.Subscriptions.Parser.JWT.Error
- Rig.Config.SyntaxError
- Rig.Subscription.ValidationError
- RigInboundGatewayWeb.ConnectionLimit.MaxConnectionsError