message

package
v1.0.5 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 11, 2026 License: MPL-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ResponseToIntuJSON added in v1.0.4 

func ResponseToIntuJSON(resp *Response) ([]byte, error)

ResponseToIntuJSON converts a destination Response into IntuMessage JSON.

Types

type ContentType 

type ContentType string
const (
	ContentTypeRaw       ContentType = "raw"
	ContentTypeJSON      ContentType = "json"
	ContentTypeXML       ContentType = "xml"
	ContentTypeCSV       ContentType = "csv"
	ContentTypeHL7v2     ContentType = "hl7v2"
	ContentTypeHL7v3     ContentType = "hl7v3"
	ContentTypeFHIR      ContentType = "fhir_r4"
	ContentTypeX12       ContentType = "x12"
	ContentTypeDICOM     ContentType = "dicom"
	ContentTypeDelimited ContentType = "delimited"
	ContentTypeBinary    ContentType = "binary"
	ContentTypeCCDA      ContentType = "ccda"
)

type DICOMMeta added in v1.0.0 

type DICOMMeta struct {
	CallingAE string
	CalledAE  string
}

type DatabaseMeta added in v1.0.0 

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

type FTPMeta added in v1.0.0 

type FTPMeta struct {
	Filename  string
	Directory string
}

type FileMeta added in v1.0.0 

type FileMeta struct {
	Filename  string
	Directory string
}

type HTTPMeta added in v1.0.0 

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

type KafkaMeta added in v1.0.0 

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

type Message 

type Message struct {
	ID            string
	CorrelationID string
	ChannelID     string
	Raw           []byte
	Transport     string
	ContentType   ContentType
	SourceCharset string // e.g. "iso-8859-1", "utf-16le"; empty means UTF-8
	HTTP          *HTTPMeta
	File          *FileMeta
	FTP           *FTPMeta
	Kafka         *KafkaMeta
	TCP           *TCPMeta
	SMTP          *SMTPMeta
	DICOM         *DICOMMeta
	Database      *DatabaseMeta
	Metadata      map[string]any
	Timestamp     time.Time
}

func FromIntuJSON added in v1.0.4 

func FromIntuJSON(data []byte, channelID string) (*Message, error)

FromIntuJSON reconstructs a Message from IntuMessage JSON stored in content. Returns the Message with Raw set to the body, transport metadata restored. Falls back to treating data as a raw payload if it is not valid IntuMessage JSON.

func New 

func New(channelID string, raw []byte) *Message

func (*Message) ClearTransportMeta added in v1.0.4 

func (m *Message) ClearTransportMeta()

ClearTransportMeta resets all transport-specific metadata fields so a destination connector can stamp fresh values without stale source metadata.

func (*Message) CloneWithRaw added in v1.0.4 

func (m *Message) CloneWithRaw(raw []byte) *Message

CloneWithRaw returns a shallow copy of the message with Raw replaced.

func (*Message) EnsureHTTP added in v1.0.0 

func (m *Message) EnsureHTTP() *HTTPMeta

EnsureHTTP initializes the HTTP meta if nil and returns it.

func (*Message) ToIntuJSON added in v1.0.4 

func (m *Message) ToIntuJSON() ([]byte, error)

ToIntuJSON serializes the Message as an IntuMessage JSON envelope. If Raw is valid UTF-8 the body is stored as a string; otherwise it is base64-encoded to avoid data corruption in JSON.

type Response 

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

type SMTPMeta added in v1.0.0 

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

type TCPMeta added in v1.0.0 

type TCPMeta struct {
	RemoteAddr string
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.