connector

package

Go to main page

Versions in this module

v1

v1.0.13

Mar 16, 2026

v1.0.12

Mar 16, 2026

v1.0.11

Mar 15, 2026

v1.0.10

Mar 15, 2026

Changes in this version

+ type FHIRPollSource struct

+ func NewFHIRPollSource(cfg *config.FHIRPollListener, logger *slog.Logger) *FHIRPollSource

+ func (f *FHIRPollSource) Start(ctx context.Context, handler MessageHandler) error

+ func (f *FHIRPollSource) Stop(ctx context.Context) error

+ func (f *FHIRPollSource) Type() string

+ type FHIRSubscriptionSource struct

+ func NewFHIRSubscriptionSource(cfg *config.FHIRSubscriptionListener, logger *slog.Logger) *FHIRSubscriptionSource

+ func (f *FHIRSubscriptionSource) Addr() string

+ func (f *FHIRSubscriptionSource) Start(ctx context.Context, handler MessageHandler) error

+ func (f *FHIRSubscriptionSource) Stop(ctx context.Context) error

+ func (f *FHIRSubscriptionSource) Type() string

v1.0.9

Mar 15, 2026

v1.0.8

Mar 14, 2026

v1.0.7

Mar 14, 2026

v1.0.6

Mar 13, 2026

Changes in this version

type DICOMSource

+ func (d *DICOMSource) Addr() string

type FHIRSource

+ func (f *FHIRSource) Addr() string

type IHESource

+ func (i *IHESource) Addr() string

type SOAPSource

+ func (s *SOAPSource) Addr() string

v1.0.5

Mar 11, 2026

v1.0.4

Mar 11, 2026

v1.0.3

Mar 11, 2026

v1.0.2

Mar 10, 2026

v1.0.1

Mar 10, 2026

v1.0.0

Mar 10, 2026

v0

v0.2.7

Mar 10, 2026

Changes in this version

+ func ClearOAuth2Cache()

+ func ResetSharedHTTPListeners()

+ type ChannelBus struct

+ func GetChannelBus() *ChannelBus

+ func (cb *ChannelBus) Publish(channelID string, msg *message.Message)

+ func (cb *ChannelBus) Subscribe(channelID string) chan *message.Message

+ type ChannelDest struct

+ func NewChannelDest(name, targetChannelID string, logger *slog.Logger) *ChannelDest

+ func (c *ChannelDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (c *ChannelDest) Stop(ctx context.Context) error

+ func (c *ChannelDest) Type() string

+ type ChannelSource struct

+ func NewChannelSource(cfg *config.ChannelListener, logger *slog.Logger) *ChannelSource

+ func (c *ChannelSource) Start(ctx context.Context, handler MessageHandler) error

+ func (c *ChannelSource) Stop(ctx context.Context) error

+ func (c *ChannelSource) Type() string

+ type DICOMDest struct

+ func NewDICOMDest(name string, cfg *config.DICOMDestMapConfig, logger *slog.Logger) *DICOMDest

+ func (d *DICOMDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (d *DICOMDest) Stop(ctx context.Context) error

+ func (d *DICOMDest) Type() string

+ type DICOMSource struct

+ func NewDICOMSource(cfg *config.DICOMListener, logger *slog.Logger) *DICOMSource

+ func (d *DICOMSource) Start(ctx context.Context, handler MessageHandler) error

+ func (d *DICOMSource) Stop(ctx context.Context) error

+ func (d *DICOMSource) Type() string

+ type DatabaseDest struct

+ func NewDatabaseDest(name string, cfg *config.DBDestMapConfig, logger *slog.Logger) *DatabaseDest

+ func (d *DatabaseDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (d *DatabaseDest) Stop(ctx context.Context) error

+ func (d *DatabaseDest) Type() string

+ type DatabaseSource struct

+ func NewDatabaseSource(cfg *config.DBListener, logger *slog.Logger) *DatabaseSource

+ func (d *DatabaseSource) Start(ctx context.Context, handler MessageHandler) error

+ func (d *DatabaseSource) Stop(ctx context.Context) error

+ func (d *DatabaseSource) Type() string

+ type DestinationConnector interface

+ Send func(ctx context.Context, msg *message.Message) (*message.Response, error)

+ Stop func(ctx context.Context) error

+ Type func() string

+ type DirectDest struct

+ func NewDirectDest(name string, cfg *config.DirectDestMapConfig, logger *slog.Logger) *DirectDest

+ func (d *DirectDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (d *DirectDest) Stop(ctx context.Context) error

+ func (d *DirectDest) Type() string

+ type EmailSource struct

+ func NewEmailSource(cfg *config.EmailListener, logger *slog.Logger) *EmailSource

+ func (e *EmailSource) Start(ctx context.Context, handler MessageHandler) error

+ func (e *EmailSource) Stop(ctx context.Context) error

+ func (e *EmailSource) Type() string

+ type FHIRDest struct

+ func NewFHIRDest(name string, cfg *config.FHIRDestMapConfig, logger *slog.Logger) *FHIRDest

+ func (f *FHIRDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (f *FHIRDest) Stop(ctx context.Context) error

+ func (f *FHIRDest) Type() string

+ type FHIRSource struct

+ func NewFHIRSource(cfg *config.FHIRListener, logger *slog.Logger) *FHIRSource

+ func (f *FHIRSource) Start(ctx context.Context, handler MessageHandler) error

+ func (f *FHIRSource) Stop(ctx context.Context) error

+ func (f *FHIRSource) Type() string

+ type Factory struct

+ func NewFactory(logger *slog.Logger) *Factory

+ func (f *Factory) CreateDestination(name string, dest config.Destination) (DestinationConnector, error)

+ func (f *Factory) CreateSource(listenerCfg config.ListenerConfig) (SourceConnector, error)

+ type FileDest struct

+ func NewFileDest(name string, cfg *config.FileDestMapConfig, logger *slog.Logger) *FileDest

+ func (f *FileDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (f *FileDest) Stop(ctx context.Context) error

+ func (f *FileDest) Type() string

+ type FileSource struct

+ func NewFileSource(cfg *config.FileListener, logger *slog.Logger) *FileSource

+ func (f *FileSource) Start(ctx context.Context, handler MessageHandler) error

+ func (f *FileSource) Stop(ctx context.Context) error

+ func (f *FileSource) Type() string

+ type HTTPDest struct

+ func NewHTTPDest(name string, cfg *config.HTTPDestConfig, logger *slog.Logger) *HTTPDest

+ func (h *HTTPDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (h *HTTPDest) Stop(ctx context.Context) error

+ func (h *HTTPDest) Type() string

+ type HTTPSource struct

+ func NewHTTPSource(cfg *config.HTTPListener, logger *slog.Logger) *HTTPSource

+ func (h *HTTPSource) Addr() string

+ func (h *HTTPSource) Start(ctx context.Context, handler MessageHandler) error

+ func (h *HTTPSource) Stop(ctx context.Context) error

+ func (h *HTTPSource) Type() string

+ type IHESource struct

+ func NewIHESource(cfg *config.IHEListener, logger *slog.Logger) *IHESource

+ func (i *IHESource) Start(ctx context.Context, handler MessageHandler) error

+ func (i *IHESource) Stop(ctx context.Context) error

+ func (i *IHESource) Type() string

+ type JMSDest struct

+ func NewJMSDest(name string, cfg *config.JMSDestMapConfig, logger *slog.Logger) *JMSDest

+ func (j *JMSDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (j *JMSDest) Stop(ctx context.Context) error

+ func (j *JMSDest) Type() string

+ type KafkaDest struct

+ func NewKafkaDest(name string, cfg *config.KafkaDestConfig, logger *slog.Logger) *KafkaDest

+ func (k *KafkaDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (k *KafkaDest) Stop(ctx context.Context) error

+ func (k *KafkaDest) Type() string

+ type KafkaSource struct

+ func NewKafkaSource(cfg *config.KafkaListener, logger *slog.Logger) *KafkaSource

+ func (k *KafkaSource) Start(ctx context.Context, handler MessageHandler) error

+ func (k *KafkaSource) Stop(ctx context.Context) error

+ func (k *KafkaSource) Type() string

+ type LogDest struct

+ func NewLogDest(name string, logger *slog.Logger) *LogDest

+ func (l *LogDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (l *LogDest) Stop(ctx context.Context) error

+ func (l *LogDest) Type() string

+ type MessageHandler func(ctx context.Context, msg *message.Message) error

+ type SFTPDest struct

+ func NewSFTPDest(name string, cfg *config.SFTPDestMapConfig, logger *slog.Logger) *SFTPDest

+ func (s *SFTPDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (s *SFTPDest) Stop(ctx context.Context) error

+ func (s *SFTPDest) Type() string

+ type SFTPSource struct

+ func NewSFTPSource(cfg *config.SFTPListener, logger *slog.Logger) *SFTPSource

+ func (s *SFTPSource) Start(ctx context.Context, handler MessageHandler) error

+ func (s *SFTPSource) Stop(ctx context.Context) error

+ func (s *SFTPSource) Type() string

+ type SMTPDest struct

+ func NewSMTPDest(name string, cfg *config.SMTPDestMapConfig, logger *slog.Logger) *SMTPDest

+ func (s *SMTPDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (s *SMTPDest) Stop(ctx context.Context) error

+ func (s *SMTPDest) Type() string

+ type SOAPSource struct

+ func NewSOAPSource(cfg *config.SOAPListener, logger *slog.Logger) *SOAPSource

+ func (s *SOAPSource) Start(ctx context.Context, handler MessageHandler) error

+ func (s *SOAPSource) Stop(ctx context.Context) error

+ func (s *SOAPSource) Type() string

+ type SourceConnector interface

+ Start func(ctx context.Context, handler MessageHandler) error

+ Stop func(ctx context.Context) error

+ Type func() string

+ type StubSource struct

+ func NewStubSource(connType string, logger *slog.Logger) *StubSource

+ func (s *StubSource) Start(ctx context.Context, handler MessageHandler) error

+ func (s *StubSource) Stop(ctx context.Context) error

+ func (s *StubSource) Type() string

+ type TCPDest struct

+ func NewTCPDest(name string, cfg *config.TCPDestMapConfig, logger *slog.Logger) *TCPDest

+ func (t *TCPDest) Send(ctx context.Context, msg *message.Message) (*message.Response, error)

+ func (t *TCPDest) Stop(ctx context.Context) error

+ func (t *TCPDest) Type() string

+ type TCPSource struct

+ func NewTCPSource(cfg *config.TCPListener, logger *slog.Logger) *TCPSource

+ func (t *TCPSource) Addr() string

+ func (t *TCPSource) Start(ctx context.Context, handler MessageHandler) error

+ func (t *TCPSource) Stop(ctx context.Context) error

+ func (t *TCPSource) Type() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL