Documentation
¶
Index ¶
- func ClearOAuth2Cache()
- func ResetSharedHTTPListeners()
- type ChannelBus
- type ChannelDest
- type ChannelSource
- type DICOMDest
- type DICOMSource
- type DatabaseDest
- type DatabaseSource
- type DestinationConnector
- type DirectDest
- type EmailSource
- type FHIRDest
- type FHIRPollSource
- type FHIRSource
- type FHIRSubscriptionSource
- type Factory
- type FileDest
- type FileSource
- type HTTPDest
- type HTTPSource
- type IHESource
- type JMSDest
- type KafkaDest
- type KafkaSource
- type LogDest
- type MessageHandler
- type SFTPDest
- type SFTPSource
- type SMTPDest
- type SOAPSource
- type SourceConnector
- type StubSource
- type TCPDest
- type TCPSource
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ClearOAuth2Cache ¶
func ClearOAuth2Cache()
func ResetSharedHTTPListeners ¶
func ResetSharedHTTPListeners()
ResetSharedHTTPListeners tears down all shared listeners. Intended for tests.
Types ¶
type ChannelBus ¶
type ChannelBus struct {
// contains filtered or unexported fields
}
func GetChannelBus ¶
func GetChannelBus() *ChannelBus
type ChannelDest ¶
type ChannelDest struct {
// contains filtered or unexported fields
}
func NewChannelDest ¶
func NewChannelDest(name, targetChannelID string, logger *slog.Logger) *ChannelDest
func (*ChannelDest) Type ¶
func (c *ChannelDest) Type() string
type ChannelSource ¶
type ChannelSource struct {
// contains filtered or unexported fields
}
func NewChannelSource ¶
func NewChannelSource(cfg *config.ChannelListener, logger *slog.Logger) *ChannelSource
func (*ChannelSource) Start ¶
func (c *ChannelSource) Start(ctx context.Context, handler MessageHandler) error
func (*ChannelSource) Type ¶
func (c *ChannelSource) Type() string
type DICOMDest ¶
type DICOMDest struct {
// contains filtered or unexported fields
}
func NewDICOMDest ¶
type DICOMSource ¶
type DICOMSource struct {
// contains filtered or unexported fields
}
func NewDICOMSource ¶
func NewDICOMSource(cfg *config.DICOMListener, logger *slog.Logger) *DICOMSource
func (*DICOMSource) Addr ¶ added in v1.0.6
func (d *DICOMSource) Addr() string
func (*DICOMSource) Start ¶
func (d *DICOMSource) Start(ctx context.Context, handler MessageHandler) error
func (*DICOMSource) Type ¶
func (d *DICOMSource) Type() string
type DatabaseDest ¶
type DatabaseDest struct {
// contains filtered or unexported fields
}
func NewDatabaseDest ¶
func NewDatabaseDest(name string, cfg *config.DBDestMapConfig, logger *slog.Logger) *DatabaseDest
func (*DatabaseDest) Type ¶
func (d *DatabaseDest) Type() string
type DatabaseSource ¶
type DatabaseSource struct {
// contains filtered or unexported fields
}
func NewDatabaseSource ¶
func NewDatabaseSource(cfg *config.DBListener, logger *slog.Logger) *DatabaseSource
func (*DatabaseSource) Start ¶
func (d *DatabaseSource) Start(ctx context.Context, handler MessageHandler) error
func (*DatabaseSource) Type ¶
func (d *DatabaseSource) Type() string
type DestinationConnector ¶
type DirectDest ¶
type DirectDest struct {
// contains filtered or unexported fields
}
DirectDest implements the Direct messaging protocol for healthcare (Direct Project / Direct Secure Messaging). It sends messages via SMTP/S with S/MIME encryption using certificates.
func NewDirectDest ¶
func NewDirectDest(name string, cfg *config.DirectDestMapConfig, logger *slog.Logger) *DirectDest
func (*DirectDest) Type ¶
func (d *DirectDest) Type() string
type EmailSource ¶
type EmailSource struct {
// contains filtered or unexported fields
}
func NewEmailSource ¶
func NewEmailSource(cfg *config.EmailListener, logger *slog.Logger) *EmailSource
func (*EmailSource) Start ¶
func (e *EmailSource) Start(ctx context.Context, handler MessageHandler) error
func (*EmailSource) Type ¶
func (e *EmailSource) Type() string
type FHIRDest ¶
type FHIRDest struct {
// contains filtered or unexported fields
}
func NewFHIRDest ¶
type FHIRPollSource ¶ added in v1.0.10
type FHIRPollSource struct {
// contains filtered or unexported fields
}
func NewFHIRPollSource ¶ added in v1.0.10
func NewFHIRPollSource(cfg *config.FHIRPollListener, logger *slog.Logger) *FHIRPollSource
func (*FHIRPollSource) Start ¶ added in v1.0.10
func (f *FHIRPollSource) Start(ctx context.Context, handler MessageHandler) error
func (*FHIRPollSource) Stop ¶ added in v1.0.10
func (f *FHIRPollSource) Stop(ctx context.Context) error
func (*FHIRPollSource) Type ¶ added in v1.0.10
func (f *FHIRPollSource) Type() string
type FHIRSource ¶
type FHIRSource struct {
// contains filtered or unexported fields
}
func NewFHIRSource ¶
func NewFHIRSource(cfg *config.FHIRListener, logger *slog.Logger) *FHIRSource
func (*FHIRSource) Addr ¶ added in v1.0.6
func (f *FHIRSource) Addr() string
func (*FHIRSource) Start ¶
func (f *FHIRSource) Start(ctx context.Context, handler MessageHandler) error
func (*FHIRSource) Type ¶
func (f *FHIRSource) Type() string
type FHIRSubscriptionSource ¶ added in v1.0.10
type FHIRSubscriptionSource struct {
// contains filtered or unexported fields
}
func NewFHIRSubscriptionSource ¶ added in v1.0.10
func NewFHIRSubscriptionSource(cfg *config.FHIRSubscriptionListener, logger *slog.Logger) *FHIRSubscriptionSource
func (*FHIRSubscriptionSource) Addr ¶ added in v1.0.10
func (f *FHIRSubscriptionSource) Addr() string
Addr returns the listener address for rest-hook (e.g. "127.0.0.1:9090"). Empty for websocket.
func (*FHIRSubscriptionSource) Start ¶ added in v1.0.10
func (f *FHIRSubscriptionSource) Start(ctx context.Context, handler MessageHandler) error
func (*FHIRSubscriptionSource) Stop ¶ added in v1.0.10
func (f *FHIRSubscriptionSource) Stop(ctx context.Context) error
func (*FHIRSubscriptionSource) Type ¶ added in v1.0.10
func (f *FHIRSubscriptionSource) Type() string
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
func NewFactory ¶
func (*Factory) CreateDestination ¶
func (f *Factory) CreateDestination(name string, dest config.Destination) (DestinationConnector, error)
func (*Factory) CreateSource ¶
func (f *Factory) CreateSource(listenerCfg config.ListenerConfig) (SourceConnector, error)
type FileDest ¶
type FileDest struct {
// contains filtered or unexported fields
}
func NewFileDest ¶
type FileSource ¶
type FileSource struct {
// contains filtered or unexported fields
}
func NewFileSource ¶
func NewFileSource(cfg *config.FileListener, logger *slog.Logger) *FileSource
func (*FileSource) Start ¶
func (f *FileSource) Start(ctx context.Context, handler MessageHandler) error
func (*FileSource) Type ¶
func (f *FileSource) Type() string
type HTTPDest ¶
type HTTPDest struct {
// contains filtered or unexported fields
}
func NewHTTPDest ¶
type HTTPSource ¶
type HTTPSource struct {
// contains filtered or unexported fields
}
func NewHTTPSource ¶
func NewHTTPSource(cfg *config.HTTPListener, logger *slog.Logger) *HTTPSource
func (*HTTPSource) Addr ¶
func (h *HTTPSource) Addr() string
func (*HTTPSource) Start ¶
func (h *HTTPSource) Start(ctx context.Context, handler MessageHandler) error
func (*HTTPSource) Type ¶
func (h *HTTPSource) Type() string
type IHESource ¶
type IHESource struct {
// contains filtered or unexported fields
}
func NewIHESource ¶
func NewIHESource(cfg *config.IHEListener, logger *slog.Logger) *IHESource
type JMSDest ¶
type JMSDest struct {
// contains filtered or unexported fields
}
JMSDest sends messages to a JMS provider via its HTTP/REST bridge API. JMS providers like ActiveMQ, IBM MQ, and others expose REST endpoints for message enqueue operations.
func NewJMSDest ¶
type KafkaDest ¶
type KafkaDest struct {
// contains filtered or unexported fields
}
func NewKafkaDest ¶
type KafkaSource ¶
type KafkaSource struct {
// contains filtered or unexported fields
}
func NewKafkaSource ¶
func NewKafkaSource(cfg *config.KafkaListener, logger *slog.Logger) *KafkaSource
func (*KafkaSource) Start ¶
func (k *KafkaSource) Start(ctx context.Context, handler MessageHandler) error
func (*KafkaSource) Type ¶
func (k *KafkaSource) Type() string
type LogDest ¶
type LogDest struct {
// contains filtered or unexported fields
}
type SFTPDest ¶
type SFTPDest struct {
// contains filtered or unexported fields
}
func NewSFTPDest ¶
type SFTPSource ¶
type SFTPSource struct {
// contains filtered or unexported fields
}
func NewSFTPSource ¶
func NewSFTPSource(cfg *config.SFTPListener, logger *slog.Logger) *SFTPSource
func (*SFTPSource) Start ¶
func (s *SFTPSource) Start(ctx context.Context, handler MessageHandler) error
func (*SFTPSource) Type ¶
func (s *SFTPSource) Type() string
type SMTPDest ¶
type SMTPDest struct {
// contains filtered or unexported fields
}
func NewSMTPDest ¶
type SOAPSource ¶
type SOAPSource struct {
// contains filtered or unexported fields
}
func NewSOAPSource ¶
func NewSOAPSource(cfg *config.SOAPListener, logger *slog.Logger) *SOAPSource
func (*SOAPSource) Addr ¶ added in v1.0.6
func (s *SOAPSource) Addr() string
func (*SOAPSource) Start ¶
func (s *SOAPSource) Start(ctx context.Context, handler MessageHandler) error
func (*SOAPSource) Type ¶
func (s *SOAPSource) Type() string
type SourceConnector ¶
type StubSource ¶
type StubSource struct {
// contains filtered or unexported fields
}
func NewStubSource ¶
func NewStubSource(connType string, logger *slog.Logger) *StubSource
func (*StubSource) Start ¶
func (s *StubSource) Start(ctx context.Context, handler MessageHandler) error
func (*StubSource) Type ¶
func (s *StubSource) Type() string
type TCPDest ¶
type TCPDest struct {
// contains filtered or unexported fields
}
func NewTCPDest ¶
Source Files
¶
- channel_dest.go
- channel_source.go
- connector.go
- database_dest.go
- database_source.go
- dicom_dest.go
- dicom_source.go
- direct_dest.go
- email_source.go
- factory.go
- fhir_dest.go
- fhir_poll_source.go
- fhir_source.go
- fhir_subscription_source.go
- file_dest.go
- file_source.go
- http_auth.go
- http_dest.go
- http_shared.go
- http_source.go
- ihe_source.go
- jms_dest.go
- kafka_dest.go
- kafka_source.go
- log_dest.go
- oauth2_helper.go
- sftp_dest.go
- sftp_source.go
- smtp_dest.go
- soap_source.go
- stub_source.go
- tcp_dest.go
- tcp_source.go
- tls_helper.go
Click to show internal directories.
Click to hide internal directories.