importer

Documentation

Index

• Constants
• func RegisterImporter(ctx context.Context, scheme string, init_func ImporterInitializationFunc) error
• func Schemes() []string
• type ImportEvent
• type Importer
  • func NewImporter(ctx context.Context, uri string) (Importer, error)
  • func NewLambdaImporter(ctx context.Context, uri string) (Importer, error)
  • func NewNullImporter(ctx context.Context, uri string) (Importer, error)
• type ImporterInitializationFunc
• type LambdaImporter
  • func (i *LambdaImporter) ImportIDs(ctx context.Context, ids ...int64) error
• type NullImporter
  • func (i *NullImporter) ImportIDs(ctx context.Context, ids ...int64) error

Constants

const LAMBDA_SCHEME string = "lambda"

const NULL_SCHEME string = "null"

Functions

func RegisterImporter

func RegisterImporter(ctx context.Context, scheme string, init_func ImporterInitializationFunc) error

RegisterImporter registers 'scheme' as a key pointing to 'init_func' in an internal lookup table used to create new `Importer` instances by the `NewImporter` method.

func Schemes

func Schemes() []string

Schemes returns the list of schemes that have been registered.

Types

type ImportEvent

type ImportEvent struct {
	Ids []int64 `json:"ids"`
}

type Importer

type Importer interface {
	ImportIDs(context.Context, ...int64) error
}

func NewImporter

func NewImporter(ctx context.Context, uri string) (Importer, error)

NewImporter returns a new `Importer` instance configured by 'uri'. The value of 'uri' is parsed as a `url.URL` and its scheme is used as the key for a corresponding `ImporterInitializationFunc` function used to instantiate the new `Importer`. It is assumed that the scheme (and initialization function) have been registered by the `RegisterImporter` method.

func NewLambdaImporter

func NewLambdaImporter(ctx context.Context, uri string) (Importer, error)

func NewNullImporter

func NewNullImporter(ctx context.Context, uri string) (Importer, error)

type ImporterInitializationFunc

type ImporterInitializationFunc func(ctx context.Context, uri string) (Importer, error)

ImporterInitializationFunc is a function defined by individual importer package and used to create an instance of that importer

type LambdaImporter

type LambdaImporter struct {
	Importer
	// contains filtered or unexported fields
}

func (*LambdaImporter) ImportIDs

func (i *LambdaImporter) ImportIDs(ctx context.Context, ids ...int64) error

type NullImporter

type NullImporter struct {
	Importer
}

func (*NullImporter) ImportIDs

func (i *NullImporter) ImportIDs(ctx context.Context, ids ...int64) error