signaling

type Backend interface {
	io.Closer

	// Publish a signaling message to a specific peer
	Publish(ctx context.Context, kp *crypto.KeyPair, msg *Message) error

	// Subscribe to messages send by a specific peer
	Subscribe(ctx context.Context, kp *crypto.KeyPair, h MessageHandler) (bool, error)

	// Unsubscribe from messages send by a specific peer
	Unsubscribe(ctx context.Context, kp *crypto.KeyPair, h MessageHandler) (bool, error)

	// Returns the backends type identifier
	Type() signalingproto.BackendType
}

type BackendConfig struct {
	URI *url.URL

	OnReady []BackendReadyHandler
}

type BackendFactory func(*BackendConfig, *log.Logger) (Backend, error)

type BackendPlugin struct {
	New         BackendFactory
	Description string
}

type BackendReadyHandler interface {
	OnSignalingBackendReady(b Backend)
}

type BackendType string // URL schemes

type Envelope = signalingproto.Envelope

type EnvelopeHandler interface {
	OnSignalingEnvelope(*Envelope)
}

type Message = signalingproto.Message

type MessageHandler interface {
	OnSignalingMessage(*crypto.PublicKeyPair, *Message)
}

type MultiBackend struct {
	Backends []Backend
}

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

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