gcssource

Documentation

Overview

Package gcssource implements files.Source on top of Google Cloud Storage.

Index

• type GCSSource
  • func New(ctx context.Context, instanceConfig *config.InstanceConfig, local bool) (*GCSSource, error)
  • func (s *GCSSource) Start(ctx context.Context) (<-chan file.File, error)

Types

type GCSSource

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

GCSSource implements file.Source for Google Cloud Storage.

func New

func New(ctx context.Context, instanceConfig *config.InstanceConfig, local bool) (*GCSSource, error)

New returns a new *GCSSource

func (*GCSSource) Start

func (s *GCSSource) Start(ctx context.Context) (<-chan file.File, error)

Start implements the file.Source interface.