transporter

type ForwarderStart struct {
	// StreamIn is the incoming stream to forward
	StreamIn string `json:"streamIn" mapstructure:"streamIn"`
	// WebsiteOut indicates the endpoint to send the stream to
	WebsiteOut string `json:"websiteOut,omitempty" mapstructure:"websiteOut"`
	// Streams is the list of all other stream endpoints to send the stream to
	Streams []string `json:"streams" mapstructure:"streams"`
}

type ForwarderStatus struct {
	// Website indicates if the website needs to be accounted for in the log collection
	Website bool `json:"website" mapstructure:"website"`
	// Streams is the number of forwarded streams are to be collected
	Streams int `json:"streams" mapstructure:"streams"`
}

type ForwarderStatusResponse struct {
	// Website contains the log data of the website stream
	Website string `json:"website" mapstructure:"website"`
	// Streams contain the log data of all the forwarded streams
	Streams map[string]string `json:"streams" mapstructure:"streams"`
}

type RecorderStart struct {
	// StreamIn is the incoming stream to forward
	StreamIn string `json:"streamIn" mapstructure:"streamIn"`
	// PathOut is the requested path for the stream to be saved to
	PathOut string `json:"pathOut" mapstructure:"pathOut"`
}

type ResponseTransporter struct {
	// Status is the status of the response, either okay or error and indicates the success of the request
	Status wsMessages.WSMessage `json:"status" mapstructure:"status"`
	// Payload is the data package to send to the server, status information but can be left blank
	Payload interface{} `json:"payload,omitempty" mapstructure:"payload"`
}

type Transporter struct {
	// Action is the action that is to be performed by the recipient
	Action action.Action `json:"action" mapstructure:"action"`
	// Unique is the unique code for each stream
	Unique string `json:"unique" mapstructure:"unique"`
	// Payload is the data package to send to the recipient, start or status information but can be left blank
	Payload interface{} `json:"payload,omitempty" mapstructure:"payload"`
}

type TransporterUnique struct {
	// ID is the unique code used to identify a request
	ID string `json:"id" mapstructure:"id"`
	// Payload is used for either Transporter or a ping
	Payload interface{} `json:"payload" mapstructure:"payload"`
}