ssepubsub

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

type MessageHandler func(topic string, event SSEEvent)

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

type PubSubClient interface {
	SSESubscribe(ctx context.Context, topic string) (<-chan SSEEvent, error)
	Publish(ctx context.Context, topic string, event SSEEvent) error
}

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

type SSEEvent struct {
	Type string `json:"type"`
	Data string `json:"data"`
}