source

Documentation

Index

• type DatabaseSourceConfig
• type DatabaseSourceConfigQuery
• type DatabaseSources
  • func NewDatabaseSources(logger log.Logger, conns *db.Connections, file string) (*DatabaseSources, error)
  • func (s *DatabaseSources) InputSources() (map[string]func(context.Context) ([]byte, error), error)

Types

type DatabaseSourceConfig

type DatabaseSourceConfig struct {
	Queries []DatabaseSourceConfigQuery `json:"queries"`
}

type DatabaseSourceConfigQuery

type DatabaseSourceConfigQuery struct {
	Name         string `json:"name"`
	DatabaseName string `json:"databaseName"`
	Query        string `json:"query"`
}

type DatabaseSources

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

func NewDatabaseSources

func NewDatabaseSources(
	logger log.Logger,
	conns *db.Connections,
	file string,
) (*DatabaseSources, error)

func (*DatabaseSources) InputSources

func (s *DatabaseSources) InputSources() (map[string]func(context.Context) ([]byte, error), error)