airtable

Documentation

Index

• func NewAirTableSourcePlugin(config Config, s []schema.StreamSchema) sources.DataSource
• type Config
• type SourcePlugin
  • func (s *SourcePlugin) Connect(ctx context.Context) error
  • func (s *SourcePlugin) Events() chan sources.MessageEvent
  • func (s *SourcePlugin) Start()
  • func (s *SourcePlugin) Stop()

Functions

func NewAirTableSourcePlugin

func NewAirTableSourcePlugin(config Config, s []schema.StreamSchema) sources.DataSource

Types

type Config

type Config struct {
	ApiKey string `json:"api_key" yaml:"api_key"`
}

type SourcePlugin

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

func (*SourcePlugin) Connect

func (s *SourcePlugin) Connect(ctx context.Context) error

func (*SourcePlugin) Events

func (s *SourcePlugin) Events() chan sources.MessageEvent

func (*SourcePlugin) Start

func (s *SourcePlugin) Start()

func (*SourcePlugin) Stop

func (s *SourcePlugin) Stop()