core

Documentation

Index

• Constants
• func DescribeSources() (types.SourceMetadataMap, error)
• func NewPlugin() (_ plugin.TailpipePlugin, err error)
• type Plugin
  • func (p *Plugin) Collect(ctx context.Context, req *proto.CollectRequest) (*row_source.ResolvedFromTime, *schema.TableSchema, error)

Constants

const PluginName = "core"

Functions

func DescribeSources

func DescribeSources() (types.SourceMetadataMap, error)

DescribeSources returns a map of source metadata - it is called by the CLI to determine which sources are provided by the core plugin

func NewPlugin

func NewPlugin() (_ plugin.TailpipePlugin, err error)

Types

type Plugin

type Plugin struct {
	plugin.PluginImpl
}

func (*Plugin) Collect

func (p *Plugin) Collect(ctx context.Context, req *proto.CollectRequest) (*row_source.ResolvedFromTime, *schema.TableSchema, error)

Collect overrides the Collect method in PluginImpl - we do this to parse the format which is used to register the custom table