Documentation
¶
Index ¶
- type Config
- type Source
- func (s *Source) Ack(ctx context.Context, msg hermod.Message) error
- func (s *Source) Close() error
- func (s *Source) GetState() map[string]string
- func (s *Source) Name() string
- func (s *Source) Ping(ctx context.Context) error
- func (s *Source) Read(ctx context.Context) (hermod.Message, error)
- func (s *Source) SetState(state map[string]string)
- func (s *Source) TestConnection(ctx context.Context) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Host string `json:"host"`
Port int `json:"port"`
User string `json:"user"`
Password string `json:"password"`
Database string `json:"database"`
Schema string `json:"schema"`
Table string `json:"table"`
Type string `json:"type"` // "db2", "vsam"
Interval string `json:"interval"`
// Additional for VSAM simulation/bridge
DatasetName string `json:"dataset_name,omitempty"`
LocalBridge string `json:"local_bridge,omitempty"` // Path to a local file acting as VSAM bridge
}
Click to show internal directories.
Click to hide internal directories.