plugin

Documentation

Index

• type Plugin
  • func New(getConfigValue func(string) string, metadataProvider metadata.Provider, ...) (*Plugin, error)
  • func (p *Plugin) InitClient() error
  • func (p *Plugin) Transform(provider nextRecordProvider, tag string) map[model.Resource][]*model.Entry
  • func (p *Plugin) WriteAll(resourceToEntries map[model.Resource][]*model.Entry) (results chan error, resCount int)

Types

type Plugin

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

func New

func New(getConfigValue func(string) string, metadataProvider metadata.Provider, ingestionClient client.Client) (*Plugin, error)

func (*Plugin) InitClient

func (p *Plugin) InitClient() error

func (*Plugin) Transform

func (p *Plugin) Transform(provider nextRecordProvider, tag string) map[model.Resource][]*model.Entry

func (*Plugin) WriteAll

func (p *Plugin) WriteAll(resourceToEntries map[model.Resource][]*model.Entry) (results chan error, resCount int)