plugin_manager

type CollectResponse struct {
	ExecutionId     string
	PartitionSchema *schema.RowSchema
}

type Observer interface {
	Notify(event *proto.Event)
}

type PluginClient struct {
	shared.TailpipePluginClientWrapper
	Name string
	// contains filtered or unexported fields
}

type PluginManager struct {
	// map of running plugins, keyed by plugin name
	Plugins map[string]*PluginClient
	// contains filtered or unexported fields
}