mainframe

package
v1.0.0-rc.2 Latest Latest
Warning

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

Go to latest
Published: Sep 7, 2026 License: MIT Imports: 11 Imported by: 0

Documentation

Index

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
}

type Source

type Source struct {
	// contains filtered or unexported fields
}

func NewSource

func NewSource(config Config, logger hermod.Logger) *Source

func (*Source) Ack

func (s *Source) Ack(ctx context.Context, msg hermod.Message) error

func (*Source) Close

func (s *Source) Close() error

func (*Source) GetState

func (s *Source) GetState() map[string]string

func (*Source) Name

func (s *Source) Name() string

func (*Source) Ping

func (s *Source) Ping(ctx context.Context) error

func (*Source) Read

func (s *Source) Read(ctx context.Context) (hermod.Message, error)

func (*Source) SetState

func (s *Source) SetState(state map[string]string)

func (*Source) TestConnection

func (s *Source) TestConnection(ctx context.Context) error

Jump to

Keyboard shortcuts

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