stream

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

type Proxy interface {
	// Close the proxy.
	Close() error
	// Start listening for packets to send to the satellite and sending back received packets.
	Start(o *SatelliteStreamOptions) (func(), error)
}

type SatelliteStream interface {
	Send(payload []byte) error

	io.Closer
}

type SatelliteStreamOptions struct {
	AcceptedFraming []stellarstation.Framing
	SatelliteID     string
	StreamId        string
	PlanId          string
	GroundStationId string
	IsDebug         bool
	IsVerbose       bool
	ShowStats       bool
	TelemetryFile   *os.File

	CorrectOrder   bool
	DelayThreshold time.Duration

	EnableAutoClose bool
}

type TCPProxyOptions struct {
	Addr string
}

type UDPProxyOptions struct {
	RecvAddr string
	SendAddr string
}