tunnel

type Client struct {
	Client services.DProxyClient
	Conn   *grpc.ClientConn
	Token  string

	PlumberClusterID  string
	PlumberID         string
	PlumberVersion    string
	OutboundMessageCh chan *events.Outbound

	Options *opts.TunnelOptions
	// contains filtered or unexported fields
}

type Config struct {
	PlumberVersion   string
	PlumberClusterID string
	PlumberID        string
}

type ITunnel interface {
	// Start is called by a backend's Tunnel() method. It authorizes the connection
	// and begins reading a GRPC stream of responses consisting of Tunnel protobuf
	// messages.
	Start(ctx context.Context, bus string, errorCh chan<- *records.ErrorRecord) error

	// Read returns a channel that will receive replay events from the dProxy service
	Read() chan *events.Outbound

	// Close closes the connection to dProxy service
	Close() error

	// Delete deletes a tunnel from dProxy and from ui-bff destinations.
	// This should be called after the tunnel is deleted from the plumber cluster to ensure proper cleanup.
	Delete(ctx context.Context, tunnelID string) error
}