googlesource

Documentation

Index

• func NewSource() sdk.Source
• type Source
  • func (s *Source) Ack(ctx context.Context, position sdk.Position) error
  • func (s *Source) Configure(ctx context.Context, cfg map[string]string) error
  • func (s *Source) Next(ctx context.Context) (sdk.Record, error)
  • func (s *Source) Open(ctx context.Context, pos sdk.Position) (err error)
  • func (s *Source) Parameters() map[string]sdk.Parameter
  • func (s *Source) Read(ctx context.Context) (sdk.Record, error)
  • func (s *Source) ReadGoogleRow(ctx context.Context) (err error)
  • func (s *Source) StopIterator() error
  • func (s *Source) Teardown(ctx context.Context) error

Functions

func NewSource

func NewSource() sdk.Source

Types

type Source

type Source struct {
	sdk.UnimplementedSource
	// contains filtered or unexported fields
}

func (*Source) Ack

func (s *Source) Ack(ctx context.Context, position sdk.Position) error

func (*Source) Configure

func (s *Source) Configure(ctx context.Context, cfg map[string]string) error

func (*Source) Next

func (s *Source) Next(ctx context.Context) (sdk.Record, error)

Next returns the next record from the buffer.

func (*Source) Open

func (s *Source) Open(ctx context.Context, pos sdk.Position) (err error)

func (*Source) Parameters

func (s *Source) Parameters() map[string]sdk.Parameter

Parameters is a map of named Parameters that describe how to configure the Source.

func (*Source) Read

func (s *Source) Read(ctx context.Context) (sdk.Record, error)

func (*Source) ReadGoogleRow

func (s *Source) ReadGoogleRow(ctx context.Context) (err error)

ReadGoogleRow fetches data from endpoint. It creates sdk.record and puts it in response channel

func (*Source) StopIterator

func (s *Source) StopIterator() error

func (*Source) Teardown

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