message

type ContentType string

type DICOMMeta struct {
	CallingAE string
	CalledAE  string
}

type DatabaseMeta struct {
	Query  string
	Params map[string]any
}

type FTPMeta struct {
	Filename  string
	Directory string
}

type FileMeta struct {
	Filename  string
	Directory string
}

type HTTPMeta struct {
	Headers     map[string]string
	QueryParams map[string]string
	PathParams  map[string]string
	Method      string
	StatusCode  int
}

type KafkaMeta struct {
	Headers   map[string]string
	Topic     string
	Key       string
	Partition int
	Offset    int64
}

type Message struct {
	ID            string
	CorrelationID string
	ChannelID     string
	Raw           []byte
	Transport     string
	ContentType   ContentType
	HTTP          *HTTPMeta
	File          *FileMeta
	FTP           *FTPMeta
	Kafka         *KafkaMeta
	TCP           *TCPMeta
	SMTP          *SMTPMeta
	DICOM         *DICOMMeta
	Database      *DatabaseMeta
	Metadata      map[string]any
	Timestamp     time.Time
}

type Response struct {
	StatusCode int
	Body       []byte
	Headers    map[string]string
	Error      error
}

type SMTPMeta struct {
	From    string
	To      []string
	Subject string
	CC      []string
	BCC     []string
}

type TCPMeta struct {
	RemoteAddr string
}