streams

type CableReadyMesssage struct {
	Identifier string `json:"identifier"`
}

type Config struct {
	// Secret is a key used to sign and verify streams
	Secret string `toml:"secret"`

	// Public determines if public (unsigned) streams are allowed
	Public bool `toml:"public"`

	// Whisper determines if whispering is enabled for pub/sub streams
	Whisper bool `toml:"whisper"`

	// PubSubChannel is the channel name used for direct pub/sub
	PubSubChannel string `toml:"pubsub_channel"`

	// Turbo is a flag to enable Turbo Streams support
	Turbo bool `toml:"turbo"`

	// TurboSecret is a custom secret key used to verify Turbo Streams
	TurboSecret string `toml:"turbo_secret"`

	// CableReady is a flag to enable CableReady support
	CableReady bool `toml:"cable_ready"`

	// CableReadySecret is a custom secret key used to verify CableReady streams
	CableReadySecret string `toml:"cable_ready_secret"`
}

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

type StreamResolver = func(string) (*SubscribeRequest, error)

type SubscribeRequest struct {
	StreamName       string `json:"stream_name"`
	SignedStreamName string `json:"signed_stream_name"`
	// contains filtered or unexported fields
}

type TurboMessage struct {
	SignedStreamName string `json:"signed_stream_name"`
}